06:05:17,177 PM [test-akka.actor.default-dispatcher-5] [INFO] Slf4jLogger - Slf4jLogger started
06:05:17,204 PM [test-akka.actor.default-dispatcher-5] [INFO] ArteryTransport - Remoting started with transport [Artery tcp]; listening on address [akka://test@127.0.0.1:2565] with UID [7498505454021706124]
06:05:17,204 PM [test-akka.actor.default-dispatcher-5] [INFO] Cluster - Cluster Node [akka://test@127.0.0.1:2565] - Starting up, Akka version [2.6.21] ...
06:05:17,211 PM [test-akka.actor.default-dispatcher-5] [INFO] Cluster - Cluster Node [akka://test@127.0.0.1:2565] - Registered cluster JMX MBean [akka:type=Cluster]
06:05:17,211 PM [test-akka.actor.default-dispatcher-5] [INFO] Cluster - Cluster Node [akka://test@127.0.0.1:2565] - Started up successfully
06:05:17,224 PM [test-akka.actor.default-dispatcher-5] [INFO] Cluster - Cluster Node [akka://test@127.0.0.1:2565] - No downing-provider-class configured, manual cluster downing required, see https://doc.akka.io/docs/akka/current/typed/cluster.html#downing
06:05:17,224 PM [test-akka.actor.default-dispatcher-5] [INFO] Cluster - Cluster Node [akka://test@127.0.0.1:2565] - No seed-nodes configured, manual cluster join required, see https://doc.akka.io/docs/akka/current/typed/cluster.html#joining
06:05:17,363 PM [test-akka.actor.default-dispatcher-5] [INFO] EmptyLocalActorRef - Message [org.opendaylight.controller.cluster.common.actor.Monitor] from Actor[akka://test/user/$a#-800059040] to Actor[akka://test/user/termination-monitor] was not delivered. [1] dead letters encountered. If this is not an expected behavior then Actor[akka://test/user/termination-monitor] may have terminated unexpectedly. This logging can be turned off or adjusted with configuration settings 'akka.log-dead-letters' and 'akka.log-dead-letters-during-shutdown'.
06:05:17,387 PM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - Starting ShardManager shard-manager-config1
06:05:17,436 PM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Recovery complete : shard-manager-config1
06:05:17,436 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config1: Creating local shard: member-1-shard-default-config1
06:05:17,451 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1
06:05:17,451 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - Creating Shard member-1-shard-default-config1
06:05:17,452 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config1: Initializing shard [default]
06:05:17,452 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardInformation - Shard member-1-shard-default-config1 is initialized
06:05:17,452 PM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - shard-manager-config1: Received role changed for member-1-shard-default-config1 from null to Follower
06:05:17,453 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config1: onChangeShardServersVotingStatus: ChangeShardMembersVotingStatus [shardName=default, meberVotingStatusMap={member-2=true}]
06:05:17,454 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config1: findLocalShard : default
06:05:17,459 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config1: Sending ChangeServersVotingStatus message ChangeServersVotingStatus [serverVotingStatusMap={member-2-shard-default-config1=true}, serversVisited=[]] to local shard akka://test/user/member-1-shard-default-config1
06:05:17,461 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config1: Received ServerChangeReply{status=NO_LEADER} from local shard akka://test/user/member-1-shard-default-config1
06:05:17,461 PM [test-akka.actor.default-dispatcher-11] [WARN] ShardManager - shard-manager-config1: ChangeServersVotingStatus failed for shard default with status NO_LEADER
06:05:17,622 PM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/member-1-shard-default-config1#-1676862736]
06:05:17,635 PM [main] [INFO] ShardManagerTest - testOnReceiveFindPrimaryWaitForShardLeader starting
06:05:17,637 PM [test-akka.actor.default-dispatcher-11] [INFO] EmptyLocalActorRef - Message [org.opendaylight.controller.cluster.common.actor.Monitor] from Actor[akka://test/user/$b#-1963156800] to Actor[akka://test/user/termination-monitor] was not delivered. [2] dead letters encountered. If this is not an expected behavior then Actor[akka://test/user/termination-monitor] may have terminated unexpectedly. This logging can be turned off or adjusted with configuration settings 'akka.log-dead-letters' and 'akka.log-dead-letters-during-shutdown'.
06:05:17,637 PM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - Starting ShardManager shard-manager-config2
06:05:17,639 PM [test-akka.actor.default-dispatcher-13] [INFO] ShardManager - Recovery complete : shard-manager-config2
06:05:17,639 PM [test-akka.actor.default-dispatcher-13] [DEBUG] ShardManager - shard-manager-config2: Creating local shard: member-1-shard-default-config2
06:05:17,648 PM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1
06:05:17,648 PM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - Creating Shard member-1-shard-default-config2
06:05:17,650 PM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - shard-manager-config2: In findPrimary: org.opendaylight.controller.cluster.datastore.messages.FindPrimary [shardName=default, waitUntilReady=true]
06:05:17,656 PM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - shard-manager-config2: Scheduling 10000 ms timer to wait for shard ShardInformation [shardId=member-1-shard-default-config2, leaderAvailable=false, actorInitialized=false, followerSyncStatus=false, role=null, leaderId=null, activeMember=true]
06:05:17,800 PM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - shard-manager-config2: Initializing shard [default]
06:05:17,800 PM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardInformation - Shard member-1-shard-default-config2 is initialized
06:05:17,800 PM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardInformation - Shard member-1-shard-default-config2 is initialized - notifying 1 OnShardInitialized callbacks
06:05:17,948 PM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - shard-manager-config2: Received role changed for member-1-shard-default-config2 from Candidate to Leader
06:05:17,948 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardInformation - Shard member-1-shard-default-config2 is initialized - notifying 1 OnShardInitialized callbacks
06:05:18,101 PM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - shard-manager-config2: Received LeaderStateChanged message: LeaderStateChanged [memberId=member-1-shard-default-config2, leaderId=member-1-shard-default-config2, leaderPayloadVersion=13]
06:05:18,101 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardInformation - Shard member-1-shard-default-config2 is ready - notifying 1 OnShardInitialized callbacks
06:05:18,102 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config2: Found primary for default: LocalPrimaryShardFound [primaryPath=akka://test@127.0.0.1:2565/user/member-1-shard-default-config#-466082835, localShardDataTree=org.opendaylight.yangtools.yang.data.tree.api.DataTree$MockitoMock$1bGo7AjM@2e901ccc]
06:05:18,103 PM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - shard-manager-config2: All Shards are ready - data store config2 is ready
06:05:18,302 PM [main] [INFO] ShardManagerTest - testOnReceiveFindPrimaryWaitForShardLeader ending
06:05:18,404 PM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/$b#-1963156800]
06:05:18,415 PM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - Stopping ShardManager shard-manager-config2
06:05:18,427 PM [test-akka.actor.default-dispatcher-10] [INFO] EmptyLocalActorRef - Message [org.opendaylight.controller.cluster.common.actor.Monitor] from TestActor[akka://test/user/$$a] to Actor[akka://test/user/termination-monitor] was not delivered. [3] dead letters encountered. If this is not an expected behavior then Actor[akka://test/user/termination-monitor] may have terminated unexpectedly. This logging can be turned off or adjusted with configuration settings 'akka.log-dead-letters' and 'akka.log-dead-letters-during-shutdown'.
06:05:18,427 PM [main] [INFO] ShardManager - Starting ShardManager shard-manager-config3
06:05:18,429 PM [test-akka.actor.default-dispatcher-5] [INFO] ShardManager - Recovery complete : shard-manager-config3
06:05:18,429 PM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - shard-manager-config3: Creating local shard: member-1-shard-default-config3
06:05:18,430 PM [main] [INFO] ShardManager - shard-manager-config3: Received role changed for member-1-shard-default-config3 from Follower to Candidate
06:05:18,430 PM [main] [INFO] ShardManager - shard-manager-config3 Received follower initial sync status for member-1-shard-default-config3 status sync done true
06:05:18,532 PM [main] [INFO] TestActorFactory - Killing actor TestActor[akka://test/user/$$a]
06:05:18,544 PM [main] [INFO] ShardManager - Stopping ShardManager shard-manager-config3
06:05:18,558 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] Slf4jLogger - Slf4jLogger started
06:05:18,582 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] ArteryTransport - Remoting started with transport [Artery tcp]; listening on address [akka://cluster-test@127.0.0.1:2558] with UID [9159811973242859622]
06:05:18,582 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2558] - Starting up, Akka version [2.6.21] ...
06:05:18,587 PM [cluster-test-akka.actor.default-dispatcher-10] [WARN] Cluster - Could not register Cluster JMX MBean with name=akka:type=Cluster as it is already registered. If you are running multiple clusters in the same JVM, set 'akka.cluster.jmx.multi-mbeans-in-same-jvm = on' in config
06:05:18,587 PM [cluster-test-akka.actor.default-dispatcher-10] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2558] - Started up successfully
06:05:18,595 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2558] - No downing-provider-class configured, manual cluster downing required, see https://doc.akka.io/docs/akka/current/typed/cluster.html#downing
06:05:18,595 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2558] - No seed-nodes configured, manual cluster join required, see https://doc.akka.io/docs/akka/current/typed/cluster.html#joining
06:05:18,613 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] EmptyLocalActorRef - Message [org.opendaylight.controller.cluster.common.actor.Monitor] from TestActor[akka://cluster-test/user/shardmanager-config4] to Actor[akka://cluster-test/user/termination-monitor] was not delivered. [1] dead letters encountered. If this is not an expected behavior then Actor[akka://cluster-test/user/termination-monitor] may have terminated unexpectedly. This logging can be turned off or adjusted with configuration settings 'akka.log-dead-letters' and 'akka.log-dead-letters-during-shutdown'.
06:05:18,614 PM [cluster-test-akka.actor.default-dispatcher-10] [INFO] ShardManager - Starting ShardManager shard-manager-config4
06:05:18,617 PM [cluster-test-akka.actor.default-dispatcher-12] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2558] - Node [akka://cluster-test@127.0.0.1:2558] is JOINING itself (with roles [member-1, dc-default], version [0.0.0]) and forming new cluster
06:05:18,622 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] Slf4jLogger - Slf4jLogger started
06:05:18,623 PM [cluster-test-akka.actor.default-dispatcher-18] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2558] - is the new leader among reachable nodes (more leaders may exist)
06:05:18,623 PM [cluster-test-akka.actor.default-dispatcher-18] [INFO] ShardManager - Recovery complete : shard-manager-config4
06:05:18,635 PM [cluster-test-akka.actor.default-dispatcher-18] [DEBUG] ShardManager - shard-manager-config4: Creating local shard: member-1-shard-default-config4
06:05:18,631 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2558] - Leader is moving node [akka://cluster-test@127.0.0.1:2558] to [Up]
06:05:18,636 PM [cluster-test-akka.actor.default-dispatcher-18] [DEBUG] ShardManager - shard-manager-config4: Creating local shard: member-1-shard-astronauts-config4
06:05:18,661 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] ArteryTransport - Remoting started with transport [Artery tcp]; listening on address [akka://cluster-test@127.0.0.1:2559] with UID [9115806570488578648]
06:05:18,662 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2559] - Starting up, Akka version [2.6.21] ...
06:05:18,666 PM [cluster-test-akka.actor.default-dispatcher-17] [INFO] ShardManager - shard-manager-config4: Received MemberUp: memberName: MemberName{name=member-1}, address: akka://cluster-test@127.0.0.1:2558
06:05:18,666 PM [cluster-test-akka.actor.default-dispatcher-17] [INFO] ShardInformation - updatePeerAddress for peer member-1-shard-default-config4 with address akka://cluster-test@127.0.0.1:2558/user/shardmanager-config4/member-1-shard-default-config4
06:05:18,666 PM [cluster-test-akka.actor.default-dispatcher-17] [INFO] ShardInformation - updatePeerAddress for peer member-1-shard-astronauts-config4 with address akka://cluster-test@127.0.0.1:2558/user/shardmanager-config4/member-1-shard-astronauts-config4
06:05:18,675 PM [cluster-test-akka.actor.default-dispatcher-5] [WARN] Cluster - Could not register Cluster JMX MBean with name=akka:type=Cluster as it is already registered. If you are running multiple clusters in the same JVM, set 'akka.cluster.jmx.multi-mbeans-in-same-jvm = on' in config
06:05:18,675 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2559] - Started up successfully
06:05:18,675 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2559] - No downing-provider-class configured, manual cluster downing required, see https://doc.akka.io/docs/akka/current/typed/cluster.html#downing
06:05:18,675 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2559] - No seed-nodes configured, manual cluster join required, see https://doc.akka.io/docs/akka/current/typed/cluster.html#joining
06:05:18,682 PM [main] [ERROR] ShardManagerTest - Mock Shard Leader Actor : TestActor[akka://cluster-test/user/member-2-shard-default-config4]
06:05:18,694 PM [cluster-test-akka.actor.default-dispatcher-10] [INFO] EmptyLocalActorRef - Message [org.opendaylight.controller.cluster.common.actor.Monitor] from TestActor[akka://cluster-test/user/shardmanager-config4] to Actor[akka://cluster-test/user/termination-monitor] was not delivered. [1] dead letters encountered. If this is not an expected behavior then Actor[akka://cluster-test/user/termination-monitor] may have terminated unexpectedly. This logging can be turned off or adjusted with configuration settings 'akka.log-dead-letters' and 'akka.log-dead-letters-during-shutdown'.
06:05:18,696 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] ShardManager - Starting ShardManager shard-manager-config4
06:05:18,698 PM [main] [ERROR] ShardManagerTest - Forwarding actor : Actor[akka://cluster-test/user/shardmanager-config4/member-2-shard-default-config4#939760638]
06:05:18,707 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] ShardManager - Recovery complete : shard-manager-config4
06:05:18,707 PM [cluster-test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - shard-manager-config4: Creating local shard: member-2-shard-default-config4
06:05:18,709 PM [cluster-test-akka.actor.default-dispatcher-17] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1
06:05:18,709 PM [cluster-test-akka.actor.default-dispatcher-17] [DEBUG] ShardManager - Creating Shard member-1-shard-default-config4
06:05:18,709 PM [cluster-test-akka.actor.default-dispatcher-17] [INFO] ShardInformation - updatePeerAddress for peer member-1-shard-default-config4 with address akka://cluster-test@127.0.0.1:2558/user/shardmanager-config4/member-1-shard-default-config4
06:05:18,709 PM [cluster-test-akka.actor.default-dispatcher-17] [DEBUG] ShardInformation - Sending PeerAddressResolved for peer member-1-shard-default-config4 with address akka://cluster-test@127.0.0.1:2558/user/shardmanager-config4/member-1-shard-default-config4 to akka://cluster-test/user/member-1-shard-default-config
06:05:18,710 PM [cluster-test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1
06:05:18,710 PM [cluster-test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - Creating Shard member-2-shard-default-config4
06:05:18,710 PM [cluster-test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config4: Initializing shard [default]
06:05:18,710 PM [cluster-test-akka.actor.default-dispatcher-11] [DEBUG] ShardInformation - Shard member-2-shard-default-config4 is initialized
06:05:18,710 PM [cluster-test-akka.actor.default-dispatcher-17] [DEBUG] ShardManager - shard-manager-config4: updated peer member-1-shard-default-config4 on member MemberName{name=member-1} with address akka://cluster-test@127.0.0.1:2558/user/shardmanager-config4/member-1-shard-default-config4 on shard member-1-shard-default-config4 whose actor address is Actor[akka://cluster-test/user/member-1-shard-default-config#400149157]
06:05:18,710 PM [cluster-test-akka.actor.default-dispatcher-17] [DEBUG] ShardManager - Creating Shard member-1-shard-astronauts-config4
06:05:18,710 PM [cluster-test-akka.actor.default-dispatcher-11] [INFO] ShardManager - shard-manager-config4: Received LeaderStateChanged message: LeaderStateChanged [memberId=member-2-shard-default-config4, leaderId=member-2-shard-default-config4, leaderPayloadVersion=12]
06:05:18,710 PM [cluster-test-akka.actor.default-dispatcher-17] [INFO] ShardInformation - updatePeerAddress for peer member-1-shard-astronauts-config4 with address akka://cluster-test@127.0.0.1:2558/user/shardmanager-config4/member-1-shard-astronauts-config4
06:05:18,710 PM [cluster-test-akka.actor.default-dispatcher-17] [DEBUG] ShardInformation - Sending PeerAddressResolved for peer member-1-shard-astronauts-config4 with address akka://cluster-test@127.0.0.1:2558/user/shardmanager-config4/member-1-shard-astronauts-config4 to akka://cluster-test/user/member-1-shard-default-config
06:05:18,710 PM [cluster-test-akka.actor.default-dispatcher-17] [DEBUG] ShardManager - shard-manager-config4: updated peer member-1-shard-astronauts-config4 on member MemberName{name=member-1} with address akka://cluster-test@127.0.0.1:2558/user/shardmanager-config4/member-1-shard-astronauts-config4 on shard member-1-shard-astronauts-config4 whose actor address is Actor[akka://cluster-test/user/member-1-shard-default-config#400149157]
06:05:18,710 PM [cluster-test-akka.actor.default-dispatcher-11] [INFO] ShardManager - shard-manager-config4: Received role changed for member-2-shard-default-config4 from Candidate to Leader
06:05:18,710 PM [cluster-test-akka.actor.default-dispatcher-11] [INFO] ShardManager - shard-manager-config4: All Shards are ready - data store config4 is ready
06:05:18,710 PM [cluster-test-akka.actor.default-dispatcher-17] [DEBUG] ShardManager - shard-manager-config4: Initializing shard [default]
06:05:18,710 PM [cluster-test-akka.actor.default-dispatcher-17] [DEBUG] ShardInformation - Shard member-1-shard-default-config4 is initialized
06:05:18,711 PM [cluster-test-akka.actor.default-dispatcher-17] [INFO] ShardManager - shard-manager-config4: Received LeaderStateChanged message: LeaderStateChanged [memberId=member-1-shard-default-config4, leaderId=member-2-shard-default-config4, leaderPayloadVersion=12]
06:05:18,711 PM [cluster-test-akka.actor.default-dispatcher-17] [INFO] ShardManager - shard-manager-config4: Received role changed for member-1-shard-default-config4 from Candidate to Follower
06:05:19,44 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2558] - Node [akka://cluster-test@127.0.0.1:2559] is JOINING, roles [member-2, dc-default], version [0.0.0]
06:05:19,83 PM [cluster-test-akka.actor.default-dispatcher-13] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2559] - Welcome from [akka://cluster-test@127.0.0.1:2558]
06:05:19,94 PM [cluster-test-akka.actor.default-dispatcher-13] [INFO] ShardManager - shard-manager-config4: Received MemberUp: memberName: MemberName{name=member-1}, address: akka://cluster-test@127.0.0.1:2558
06:05:19,94 PM [cluster-test-akka.actor.default-dispatcher-13] [INFO] ShardInformation - updatePeerAddress for peer member-1-shard-default-config4 with address akka://cluster-test@127.0.0.1:2558/user/shardmanager-config4/member-1-shard-default-config4
06:05:19,94 PM [cluster-test-akka.actor.default-dispatcher-13] [DEBUG] ShardInformation - Sending PeerAddressResolved for peer member-1-shard-default-config4 with address akka://cluster-test@127.0.0.1:2558/user/shardmanager-config4/member-1-shard-default-config4 to akka://cluster-test/user/member-2-shard-default-config4
06:05:19,94 PM [cluster-test-akka.actor.default-dispatcher-13] [INFO] ShardManager - shard-manager-config4: All Shards are ready - data store config4 is ready
06:05:19,613 PM [cluster-test-akka.actor.default-dispatcher-17] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2558] - Leader is moving node [akka://cluster-test@127.0.0.1:2559] to [Up]
06:05:19,613 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] ShardManager - shard-manager-config4: Received MemberUp: memberName: MemberName{name=member-2}, address: akka://cluster-test@127.0.0.1:2559
06:05:19,613 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] ShardInformation - updatePeerAddress for peer member-2-shard-default-config4 with address akka://cluster-test@127.0.0.1:2559/user/shardmanager-config4/member-2-shard-default-config4
06:05:19,613 PM [cluster-test-akka.actor.default-dispatcher-5] [DEBUG] ShardInformation - Sending PeerAddressResolved for peer member-2-shard-default-config4 with address akka://cluster-test@127.0.0.1:2559/user/shardmanager-config4/member-2-shard-default-config4 to akka://cluster-test/user/member-1-shard-default-config
06:05:19,613 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] ShardInformation - updatePeerAddress for peer member-2-shard-astronauts-config4 with address akka://cluster-test@127.0.0.1:2559/user/shardmanager-config4/member-2-shard-astronauts-config4
06:05:19,613 PM [cluster-test-akka.actor.default-dispatcher-5] [DEBUG] ShardInformation - Sending PeerAddressResolved for peer member-2-shard-astronauts-config4 with address akka://cluster-test@127.0.0.1:2559/user/shardmanager-config4/member-2-shard-astronauts-config4 to akka://cluster-test/user/member-1-shard-default-config
06:05:19,617 PM [cluster-test-akka.actor.default-dispatcher-17] [DEBUG] ShardManager - shard-manager-config4: onRemoveShardReplica: RemoveShardReplica [shardName=default, memberName=MemberName{name=member-1}]
06:05:19,620 PM [cluster-test-akka.actor.default-dispatcher-17] [DEBUG] ShardManager - shard-manager-config4: In findPrimary: org.opendaylight.controller.cluster.datastore.messages.FindPrimary [shardName=default, waitUntilReady=true]
06:05:19,620 PM [cluster-test-akka.actor.default-dispatcher-17] [DEBUG] ShardManager - shard-manager-config4: Found primary for default: RemotePrimaryShardFound [primaryPath=akka://cluster-test@127.0.0.1:2559/user/shardmanager-config4/member-2-shard-default-config4, primaryVersion=12]
06:05:19,621 PM [cluster-test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - shard-manager-config4: Sending RemoveServer message to peer akka://cluster-test@127.0.0.1:2559/user/shardmanager-config4/member-2-shard-default-config4 for shard member-1-shard-default-config4
06:05:19,640 PM [cluster-test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - shard-manager-config4: Received RemoveServerReply{status=OK, leaderHint=member-2-shard-default-config4} for shard default
06:05:19,640 PM [cluster-test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - shard-manager-config4: Leader shard successfully removed the replica shard default
06:05:19,699 PM [cluster-test-akka.actor.default-dispatcher-13] [INFO] ShardManager - shard-manager-config4: Received MemberUp: memberName: MemberName{name=member-2}, address: akka://cluster-test@127.0.0.1:2559
06:05:19,699 PM [cluster-test-akka.actor.default-dispatcher-13] [INFO] ShardInformation - updatePeerAddress for peer member-2-shard-default-config4 with address akka://cluster-test@127.0.0.1:2559/user/shardmanager-config4/member-2-shard-default-config4
06:05:19,699 PM [cluster-test-akka.actor.default-dispatcher-13] [DEBUG] ShardInformation - Sending PeerAddressResolved for peer member-2-shard-default-config4 with address akka://cluster-test@127.0.0.1:2559/user/shardmanager-config4/member-2-shard-default-config4 to akka://cluster-test/user/member-2-shard-default-config4
06:05:19,699 PM [cluster-test-akka.actor.default-dispatcher-13] [INFO] ShardManager - shard-manager-config4: All Shards are ready - data store config4 is ready
06:05:19,772 PM [cluster-test-akka.actor.default-dispatcher-18] [INFO] ShardManager - Stopping ShardManager shard-manager-config4
06:05:19,773 PM [cluster-test-akka.actor.default-dispatcher-18] [INFO] RemoteActorRefProvider$RemotingTerminator - Shutting down remote daemon.
06:05:19,773 PM [cluster-test-akka.actor.default-dispatcher-18] [INFO] RemoteActorRefProvider$RemotingTerminator - Remote daemon shut down; proceeding with flushing remote transports.
06:05:19,805 PM [cluster-test-akka.actor.default-dispatcher-18] [WARN] Materializer - [outbound connection to [akka://cluster-test@127.0.0.1:2559], control stream] Upstream failed, cause: StreamTcpException: The connection has been aborted
06:05:19,805 PM [cluster-test-akka.actor.default-dispatcher-18] [WARN] Materializer - [outbound connection to [akka://cluster-test@127.0.0.1:2559], message stream] Upstream failed, cause: StreamTcpException: The connection has been aborted
06:05:19,806 PM [cluster-test-akka.actor.default-dispatcher-18] [INFO] RemoteActorRefProvider$RemotingTerminator - Remoting shut down.
06:05:19,812 PM [cluster-test-akka.actor.default-dispatcher-13] [WARN] Materializer - [outbound connection to [akka://cluster-test@127.0.0.1:2558], message stream] Upstream failed, cause: StreamTcpException: The connection closed with error: Connection reset
06:05:19,821 PM [cluster-test-akka.actor.default-dispatcher-13] [WARN] Materializer - [outbound connection to [akka://cluster-test@127.0.0.1:2558], control stream] Upstream failed, cause: StreamTcpException: The connection closed with error: Connection reset
06:05:19,849 PM [cluster-test-akka.actor.default-dispatcher-13] [INFO] ShardManager - Stopping ShardManager shard-manager-config4
06:05:19,852 PM [cluster-test-akka.actor.default-dispatcher-13] [INFO] RemoteActorRefProvider$RemotingTerminator - Shutting down remote daemon.
06:05:19,852 PM [cluster-test-akka.actor.default-dispatcher-13] [INFO] RemoteActorRefProvider$RemotingTerminator - Remote daemon shut down; proceeding with flushing remote transports.
[WARN] [01/08/2024 18:05:20.873] [cluster-test-akka.actor.internal-dispatcher-7] [Cluster(akka://cluster-test)] Could not unregister Cluster JMX MBean with name=akka:type=Cluster as it was not found. If you are running multiple clusters in the same JVM, set 'akka.cluster.jmx.multi-mbeans-in-same-jvm = on' in config
06:05:20,893 PM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - Starting ShardManager shard-manager-config5
06:05:20,894 PM [test-akka.actor.default-dispatcher-15] [INFO] EmptyLocalActorRef - Message [org.opendaylight.controller.cluster.common.actor.Monitor] from Actor[akka://test/user/$c#1732637530] to Actor[akka://test/user/termination-monitor] was not delivered. [4] dead letters encountered. If this is not an expected behavior then Actor[akka://test/user/termination-monitor] may have terminated unexpectedly. This logging can be turned off or adjusted with configuration settings 'akka.log-dead-letters' and 'akka.log-dead-letters-during-shutdown'.
06:05:20,912 PM [test-akka.actor.default-dispatcher-5] [INFO] ShardManager - Recovery complete : shard-manager-config5
06:05:20,912 PM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - shard-manager-config5: Creating local shard: member-1-shard-default-config5
06:05:20,912 PM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1
06:05:20,912 PM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - Creating Shard member-1-shard-default-config5
06:05:20,912 PM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - shard-manager-config5: Initializing shard [default]
06:05:20,912 PM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardInformation - Shard member-1-shard-default-config5 is initialized
06:05:21,57 PM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/$c#1732637530]
06:05:21,68 PM [test-akka.actor.default-dispatcher-16] [INFO] ShardManager - Stopping ShardManager shard-manager-config5
06:05:21,72 PM [test-akka.actor.default-dispatcher-16] [INFO] EmptyLocalActorRef - Message [org.opendaylight.controller.cluster.common.actor.Monitor] from TestActor[akka://test/user/$$b] to Actor[akka://test/user/termination-monitor] was not delivered. [5] dead letters encountered. If this is not an expected behavior then Actor[akka://test/user/termination-monitor] may have terminated unexpectedly. This logging can be turned off or adjusted with configuration settings 'akka.log-dead-letters' and 'akka.log-dead-letters-during-shutdown'.
06:05:21,79 PM [main] [INFO] ShardManager - Starting ShardManager shard-manager-config6
06:05:21,83 PM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Recovery complete : shard-manager-config6
06:05:21,84 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config6: Creating local shard: member-1-shard-default-config6
06:05:21,84 PM [main] [INFO] ShardManager - shard-manager-config6: Received role changed for member-1-shard-default-config6 from null to Follower
06:05:21,95 PM [main] [INFO] ShardManager - shard-manager-config6: Received MemberUp: memberName: MemberName{name=member-2}, address: akka://test
06:05:21,95 PM [main] [INFO] ShardInformation - updatePeerAddress for peer member-2-shard-default-config6 with address akka://test/user/shardmanager-config6/member-2-shard-default-config6
06:05:21,95 PM [main] [INFO] ShardManager - shard-manager-config6: Received LeaderStateChanged message: LeaderStateChanged [memberId=member-1-shard-default-config6, leaderId=member-2-shard-default-config6, leaderPayloadVersion=13]
06:05:21,95 PM [main] [INFO] ShardManager - shard-manager-config6: All Shards are ready - data store config6 is ready
06:05:21,197 PM [main] [INFO] TestActorFactory - Killing actor TestActor[akka://test/user/$$b]
06:05:21,208 PM [main] [INFO] ShardManager - Stopping ShardManager shard-manager-config6
06:05:21,213 PM [test-akka.actor.default-dispatcher-11] [INFO] EmptyLocalActorRef - Message [org.opendaylight.controller.cluster.common.actor.Monitor] from Actor[akka://test/user/$d#-909172098] to Actor[akka://test/user/termination-monitor] was not delivered. [6] dead letters encountered. If this is not an expected behavior then Actor[akka://test/user/termination-monitor] may have terminated unexpectedly. This logging can be turned off or adjusted with configuration settings 'akka.log-dead-letters' and 'akka.log-dead-letters-during-shutdown'.
06:05:21,213 PM [test-akka.actor.default-dispatcher-13] [INFO] ShardManager - Starting ShardManager shard-manager-config7
06:05:21,216 PM [test-akka.actor.default-dispatcher-16] [INFO] ShardManager - Recovery complete : shard-manager-config7
06:05:21,224 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config7: onRemoveShardReplica: RemoveShardReplica [shardName=model-inventory, memberName=MemberName{name=member-1}]
06:05:21,224 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config7: In findPrimary: org.opendaylight.controller.cluster.datastore.messages.FindPrimary [shardName=model-inventory, waitUntilReady=true]
06:05:21,224 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config7: No shard found for model-inventory
06:05:21,225 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config7: Failed to find leader for shard model-inventory: received response: {}
org.opendaylight.controller.cluster.datastore.exceptions.PrimaryNotFoundException: No primary shard found for model-inventory.
	at org.opendaylight.controller.cluster.datastore.shardmanager.ShardManager.findPrimary(ShardManager.java:1051)
	at org.opendaylight.controller.cluster.datastore.shardmanager.ShardManager.handleCommand(ShardManager.java:207)
	at org.opendaylight.controller.cluster.datastore.shardmanager.ShardManagerTest$TestShardManager.handleCommand(ShardManagerTest.java:2198)
	at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:24)
	at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:20)
	at scala.PartialFunction.applyOrElse(PartialFunction.scala:214)
	at scala.PartialFunction.applyOrElse$(PartialFunction.scala:213)
	at akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:20)
	at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:269)
	at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:270)
	at akka.actor.Actor.aroundReceive(Actor.scala:537)
	at akka.actor.Actor.aroundReceive$(Actor.scala:535)
	at akka.persistence.AbstractPersistentActor.akka$persistence$Eventsourced$$super$aroundReceive(PersistentActor.scala:295)
	at akka.persistence.Eventsourced$$anon$4.stateReceive(Eventsourced.scala:917)
	at akka.persistence.Eventsourced.aroundReceive(Eventsourced.scala:245)
	at akka.persistence.Eventsourced.aroundReceive$(Eventsourced.scala:244)
	at akka.persistence.AbstractPersistentActor.aroundReceive(PersistentActor.scala:295)
	at akka.actor.ActorCell.receiveMessage(ActorCell.scala:579)
	at akka.actor.ActorCell.invoke(ActorCell.scala:547)
	at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:270)
	at akka.dispatch.Mailbox.run(Mailbox.scala:231)
	at akka.dispatch.Mailbox.exec(Mailbox.scala:243)
	at java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:373)
	at java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1182)
	at java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1655)
	at java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1622)
	at java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:165)
06:05:21,327 PM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/$d#-909172098]
06:05:21,338 PM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Stopping ShardManager shard-manager-config7
06:05:21,340 PM [main] [INFO] ShardManagerTest - testAddShardReplicaWithPreExistingLocalReplicaLeader starting
06:05:21,343 PM [test-akka.actor.default-dispatcher-11] [INFO] EmptyLocalActorRef - Message [org.opendaylight.controller.cluster.common.actor.Monitor] from Actor[akka://test/user/$e#108218308] to Actor[akka://test/user/termination-monitor] was not delivered. [7] dead letters encountered. If this is not an expected behavior then Actor[akka://test/user/termination-monitor] may have terminated unexpectedly. This logging can be turned off or adjusted with configuration settings 'akka.log-dead-letters' and 'akka.log-dead-letters-during-shutdown'.
06:05:21,344 PM [test-akka.actor.default-dispatcher-13] [INFO] ShardManager - Starting ShardManager shard-manager-config8
06:05:21,346 PM [test-akka.actor.default-dispatcher-16] [INFO] ShardManager - Recovery complete : shard-manager-config8
06:05:21,346 PM [test-akka.actor.default-dispatcher-16] [DEBUG] ShardManager - shard-manager-config8: Creating local shard: member-1-shard-default-config8
06:05:21,354 PM [test-akka.actor.default-dispatcher-13] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1
06:05:21,354 PM [test-akka.actor.default-dispatcher-13] [DEBUG] ShardManager - Creating Shard member-1-shard-default-config8
06:05:21,355 PM [test-akka.actor.default-dispatcher-13] [DEBUG] ShardManager - shard-manager-config8: Initializing shard [default]
06:05:21,355 PM [test-akka.actor.default-dispatcher-13] [DEBUG] ShardInformation - Shard member-1-shard-default-config8 is initialized
06:05:21,355 PM [test-akka.actor.default-dispatcher-13] [INFO] ShardManager - shard-manager-config8: Received LeaderStateChanged message: LeaderStateChanged [memberId=member-1-shard-default-config8, leaderId=member-1-shard-default-config8, leaderPayloadVersion=13]
06:05:21,355 PM [test-akka.actor.default-dispatcher-13] [INFO] ShardManager - shard-manager-config8: Received role changed for member-1-shard-default-config8 from Candidate to Leader
06:05:21,355 PM [test-akka.actor.default-dispatcher-13] [INFO] ShardManager - shard-manager-config8: All Shards are ready - data store config8 is ready
06:05:21,355 PM [test-akka.actor.default-dispatcher-13] [DEBUG] ShardManager - shard-manager-config8: onAddShardReplica: AddShardReplica[ShardName=default]
06:05:21,356 PM [test-akka.actor.default-dispatcher-13] [DEBUG] ShardManager - shard-manager-config8: In findPrimary: org.opendaylight.controller.cluster.datastore.messages.FindPrimary [shardName=default, waitUntilReady=true]
06:05:21,356 PM [test-akka.actor.default-dispatcher-13] [DEBUG] ShardManager - shard-manager-config8: Found primary for default: LocalPrimaryShardFound [primaryPath=akka://test@127.0.0.1:2565/user/member-1-shard-default-config#-1994754624, localShardDataTree=org.opendaylight.yangtools.yang.data.tree.api.DataTree$MockitoMock$1bGo7AjM@7899948d]
06:05:21,356 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config8: Local shard default already exists
06:05:21,357 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config8: findLocalShard : default
06:05:21,357 PM [main] [INFO] ShardManagerTest - testAddShardReplicaWithPreExistingLocalReplicaLeader ending
06:05:21,458 PM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/$e#108218308]
06:05:21,469 PM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Stopping ShardManager shard-manager-config8
06:05:21,471 PM [main] [INFO] ShardManagerTest - testOnReceiveFindLocalShardWaitForShardInitialized starting
06:05:21,474 PM [test-akka.actor.default-dispatcher-11] [INFO] EmptyLocalActorRef - Message [org.opendaylight.controller.cluster.common.actor.Monitor] from Actor[akka://test/user/$f#2064996470] to Actor[akka://test/user/termination-monitor] was not delivered. [8] dead letters encountered. If this is not an expected behavior then Actor[akka://test/user/termination-monitor] may have terminated unexpectedly. This logging can be turned off or adjusted with configuration settings 'akka.log-dead-letters' and 'akka.log-dead-letters-during-shutdown'.
06:05:21,474 PM [test-akka.actor.default-dispatcher-13] [INFO] ShardManager - Starting ShardManager shard-manager-config9
06:05:21,475 PM [test-akka.actor.default-dispatcher-13] [INFO] ShardManager - Recovery complete : shard-manager-config9
06:05:21,475 PM [test-akka.actor.default-dispatcher-13] [DEBUG] ShardManager - shard-manager-config9: Creating local shard: member-1-shard-default-config9
06:05:21,485 PM [test-akka.actor.default-dispatcher-16] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1
06:05:21,485 PM [test-akka.actor.default-dispatcher-16] [DEBUG] ShardManager - Creating Shard member-1-shard-default-config9
06:05:21,485 PM [test-akka.actor.default-dispatcher-16] [DEBUG] ShardManager - shard-manager-config9: findLocalShard : default
06:05:21,485 PM [test-akka.actor.default-dispatcher-16] [DEBUG] ShardManager - shard-manager-config9: Scheduling 600 ms timer to wait for shard ShardInformation [shardId=member-1-shard-default-config9, leaderAvailable=false, actorInitialized=false, followerSyncStatus=false, role=null, leaderId=null, activeMember=true]
06:05:21,485 PM [test-akka.actor.default-dispatcher-16] [DEBUG] ShardManager - shard-manager-config9: Initializing shard [default]
06:05:21,485 PM [test-akka.actor.default-dispatcher-16] [DEBUG] ShardInformation - Shard member-1-shard-default-config9 is initialized
06:05:21,485 PM [test-akka.actor.default-dispatcher-16] [DEBUG] ShardInformation - Shard member-1-shard-default-config9 is initialized - notifying 1 OnShardInitialized callbacks
06:05:21,490 PM [main] [INFO] ShardManagerTest - testOnReceiveFindLocalShardWaitForShardInitialized starting
06:05:21,591 PM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/$f#2064996470]
06:05:21,603 PM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Stopping ShardManager shard-manager-config9
06:05:21,605 PM [main] [INFO] ShardManagerTest - testShardAvailabilityChangeOnMemberUnreachableAndLeadershipChange starting
06:05:21,613 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] Slf4jLogger - Slf4jLogger started
06:05:21,623 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] ArteryTransport - Remoting started with transport [Artery tcp]; listening on address [akka://cluster-test@127.0.0.1:2558] with UID [8008786926493993473]
06:05:21,623 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2558] - Starting up, Akka version [2.6.21] ...
06:05:21,632 PM [cluster-test-akka.actor.default-dispatcher-10] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2558] - Registered cluster JMX MBean [akka:type=Cluster]
06:05:21,632 PM [cluster-test-akka.actor.default-dispatcher-10] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2558] - Started up successfully
06:05:21,632 PM [cluster-test-akka.actor.default-dispatcher-10] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2558] - No downing-provider-class configured, manual cluster downing required, see https://doc.akka.io/docs/akka/current/typed/cluster.html#downing
06:05:21,632 PM [cluster-test-akka.actor.default-dispatcher-10] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2558] - No seed-nodes configured, manual cluster join required, see https://doc.akka.io/docs/akka/current/typed/cluster.html#joining
06:05:21,634 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2558] - Node [akka://cluster-test@127.0.0.1:2558] is JOINING itself (with roles [member-1, dc-default], version [0.0.0]) and forming new cluster
06:05:21,634 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2558] - is the new leader among reachable nodes (more leaders may exist)
06:05:21,634 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2558] - Leader is moving node [akka://cluster-test@127.0.0.1:2558] to [Up]
06:05:21,639 PM [cluster-test-akka.actor.default-dispatcher-11] [INFO] EmptyLocalActorRef - Message [org.opendaylight.controller.cluster.common.actor.Monitor] from TestActor[akka://cluster-test/user/shardmanager-config10] to Actor[akka://cluster-test/user/termination-monitor] was not delivered. [1] dead letters encountered. If this is not an expected behavior then Actor[akka://cluster-test/user/termination-monitor] may have terminated unexpectedly. This logging can be turned off or adjusted with configuration settings 'akka.log-dead-letters' and 'akka.log-dead-letters-during-shutdown'.
06:05:21,645 PM [cluster-test-akka.actor.default-dispatcher-6] [INFO] Slf4jLogger - Slf4jLogger started
06:05:21,646 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] ShardManager - Starting ShardManager shard-manager-config10
06:05:21,653 PM [cluster-test-akka.actor.default-dispatcher-6] [INFO] ArteryTransport - Remoting started with transport [Artery tcp]; listening on address [akka://cluster-test@127.0.0.1:2559] with UID [-2321163360689398503]
06:05:21,653 PM [cluster-test-akka.actor.default-dispatcher-6] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2559] - Starting up, Akka version [2.6.21] ...
06:05:21,661 PM [cluster-test-akka.actor.default-dispatcher-6] [WARN] Cluster - Could not register Cluster JMX MBean with name=akka:type=Cluster as it is already registered. If you are running multiple clusters in the same JVM, set 'akka.cluster.jmx.multi-mbeans-in-same-jvm = on' in config
06:05:21,661 PM [cluster-test-akka.actor.default-dispatcher-6] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2559] - Started up successfully
06:05:21,661 PM [cluster-test-akka.actor.default-dispatcher-6] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2559] - No downing-provider-class configured, manual cluster downing required, see https://doc.akka.io/docs/akka/current/typed/cluster.html#downing
06:05:21,661 PM [cluster-test-akka.actor.default-dispatcher-6] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2559] - No seed-nodes configured, manual cluster join required, see https://doc.akka.io/docs/akka/current/typed/cluster.html#joining
06:05:21,668 PM [cluster-test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Starting ShardManager shard-manager-config10
06:05:21,673 PM [cluster-test-akka.actor.default-dispatcher-10] [INFO] EmptyLocalActorRef - Message [org.opendaylight.controller.cluster.common.actor.Monitor] from TestActor[akka://cluster-test/user/shardmanager-config10] to Actor[akka://cluster-test/user/termination-monitor] was not delivered. [1] dead letters encountered. If this is not an expected behavior then Actor[akka://cluster-test/user/termination-monitor] may have terminated unexpectedly. This logging can be turned off or adjusted with configuration settings 'akka.log-dead-letters' and 'akka.log-dead-letters-during-shutdown'.
06:05:21,674 PM [cluster-test-akka.actor.default-dispatcher-14] [INFO] ShardManager - Recovery complete : shard-manager-config10
06:05:21,674 PM [cluster-test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - shard-manager-config10: Creating local shard: member-1-shard-default-config10
06:05:21,675 PM [cluster-test-akka.actor.default-dispatcher-14] [INFO] ShardManager - shard-manager-config10: Received MemberUp: memberName: MemberName{name=member-1}, address: akka://cluster-test@127.0.0.1:2558
06:05:21,675 PM [cluster-test-akka.actor.default-dispatcher-14] [INFO] ShardInformation - updatePeerAddress for peer member-1-shard-default-config10 with address akka://cluster-test@127.0.0.1:2558/user/shardmanager-config10/member-1-shard-default-config10
06:05:21,676 PM [cluster-test-akka.actor.default-dispatcher-15] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1
06:05:21,676 PM [cluster-test-akka.actor.default-dispatcher-15] [DEBUG] ShardManager - Creating Shard member-1-shard-default-config10
06:05:21,676 PM [cluster-test-akka.actor.default-dispatcher-15] [INFO] ShardInformation - updatePeerAddress for peer member-1-shard-default-config10 with address akka://cluster-test@127.0.0.1:2558/user/shardmanager-config10/member-1-shard-default-config10
06:05:21,676 PM [cluster-test-akka.actor.default-dispatcher-15] [DEBUG] ShardInformation - Sending PeerAddressResolved for peer member-1-shard-default-config10 with address akka://cluster-test@127.0.0.1:2558/user/shardmanager-config10/member-1-shard-default-config10 to akka://cluster-test/user/member-1-shard-default-config
06:05:21,676 PM [cluster-test-akka.actor.default-dispatcher-15] [DEBUG] ShardManager - shard-manager-config10: updated peer member-1-shard-default-config10 on member MemberName{name=member-1} with address akka://cluster-test@127.0.0.1:2558/user/shardmanager-config10/member-1-shard-default-config10 on shard member-1-shard-default-config10 whose actor address is Actor[akka://cluster-test/user/member-1-shard-default-config#-2042219853]
06:05:21,676 PM [cluster-test-akka.actor.default-dispatcher-15] [DEBUG] ShardManager - shard-manager-config10: Initializing shard [default]
06:05:21,676 PM [cluster-test-akka.actor.default-dispatcher-15] [DEBUG] ShardInformation - Shard member-1-shard-default-config10 is initialized
06:05:21,676 PM [cluster-test-akka.actor.default-dispatcher-15] [INFO] ShardManager - shard-manager-config10: Received LeaderStateChanged message: LeaderStateChanged [memberId=member-1-shard-default-config10, leaderId=member-2-shard-default-config10, leaderPayloadVersion=13]
06:05:21,676 PM [cluster-test-akka.actor.default-dispatcher-15] [INFO] ShardManager - shard-manager-config10: Received role changed for member-1-shard-default-config10 from Candidate to Follower
06:05:21,679 PM [cluster-test-akka.actor.default-dispatcher-12] [INFO] ShardManager - Recovery complete : shard-manager-config10
06:05:21,679 PM [cluster-test-akka.actor.default-dispatcher-12] [DEBUG] ShardManager - shard-manager-config10: Creating local shard: member-2-shard-default-config10
06:05:21,679 PM [cluster-test-akka.actor.default-dispatcher-12] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1
06:05:21,680 PM [cluster-test-akka.actor.default-dispatcher-12] [DEBUG] ShardManager - Creating Shard member-2-shard-default-config10
06:05:21,680 PM [cluster-test-akka.actor.default-dispatcher-12] [DEBUG] ShardManager - shard-manager-config10: Initializing shard [default]
06:05:21,680 PM [cluster-test-akka.actor.default-dispatcher-12] [DEBUG] ShardInformation - Shard member-2-shard-default-config10 is initialized
06:05:21,680 PM [cluster-test-akka.actor.default-dispatcher-12] [INFO] ShardManager - shard-manager-config10: Received LeaderStateChanged message: LeaderStateChanged [memberId=member-2-shard-default-config10, leaderId=member-2-shard-default-config10, leaderPayloadVersion=13]
06:05:21,680 PM [cluster-test-akka.actor.default-dispatcher-12] [INFO] ShardManager - shard-manager-config10: Received role changed for member-2-shard-default-config10 from Candidate to Leader
06:05:21,680 PM [cluster-test-akka.actor.default-dispatcher-12] [INFO] ShardManager - shard-manager-config10: All Shards are ready - data store config10 is ready
06:05:21,747 PM [cluster-test-akka.actor.default-dispatcher-15] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2558] - Node [akka://cluster-test@127.0.0.1:2559] is JOINING, roles [member-2, dc-default], version [0.0.0]
06:05:21,753 PM [cluster-test-akka.actor.default-dispatcher-13] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2559] - Welcome from [akka://cluster-test@127.0.0.1:2558]
06:05:21,753 PM [cluster-test-akka.actor.default-dispatcher-13] [INFO] ShardManager - shard-manager-config10: Received MemberUp: memberName: MemberName{name=member-1}, address: akka://cluster-test@127.0.0.1:2558
06:05:21,753 PM [cluster-test-akka.actor.default-dispatcher-13] [INFO] ShardInformation - updatePeerAddress for peer member-1-shard-default-config10 with address akka://cluster-test@127.0.0.1:2558/user/shardmanager-config10/member-1-shard-default-config10
06:05:21,753 PM [cluster-test-akka.actor.default-dispatcher-13] [DEBUG] ShardInformation - Sending PeerAddressResolved for peer member-1-shard-default-config10 with address akka://cluster-test@127.0.0.1:2558/user/shardmanager-config10/member-1-shard-default-config10 to akka://cluster-test/user/member-2-shard-default-config
06:05:21,753 PM [cluster-test-akka.actor.default-dispatcher-13] [INFO] ShardManager - shard-manager-config10: All Shards are ready - data store config10 is ready
06:05:22,642 PM [cluster-test-akka.actor.default-dispatcher-15] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2558] - Leader is moving node [akka://cluster-test@127.0.0.1:2559] to [Up]
06:05:22,644 PM [cluster-test-akka.actor.default-dispatcher-15] [INFO] ShardManager - shard-manager-config10: Received MemberUp: memberName: MemberName{name=member-2}, address: akka://cluster-test@127.0.0.1:2559
06:05:22,644 PM [cluster-test-akka.actor.default-dispatcher-15] [INFO] ShardInformation - updatePeerAddress for peer member-2-shard-default-config10 with address akka://cluster-test@127.0.0.1:2559/user/shardmanager-config10/member-2-shard-default-config10
06:05:22,644 PM [cluster-test-akka.actor.default-dispatcher-15] [DEBUG] ShardInformation - Sending PeerAddressResolved for peer member-2-shard-default-config10 with address akka://cluster-test@127.0.0.1:2559/user/shardmanager-config10/member-2-shard-default-config10 to akka://cluster-test/user/member-1-shard-default-config
06:05:22,644 PM [cluster-test-akka.actor.default-dispatcher-15] [INFO] ShardManager - shard-manager-config10: All Shards are ready - data store config10 is ready
06:05:22,644 PM [cluster-test-akka.actor.default-dispatcher-15] [DEBUG] ShardManager - shard-manager-config10: In findPrimary: org.opendaylight.controller.cluster.datastore.messages.FindPrimary [shardName=default, waitUntilReady=true]
06:05:22,644 PM [cluster-test-akka.actor.default-dispatcher-15] [DEBUG] ShardManager - shard-manager-config10: Found primary for default: RemotePrimaryShardFound [primaryPath=akka://cluster-test@127.0.0.1:2559/user/shardmanager-config10/member-2-shard-default-config10, primaryVersion=13]
06:05:22,645 PM [cluster-test-akka.actor.default-dispatcher-15] [INFO] ShardManager - Received UnreachableMember: memberName MemberName{name=member-2}, address: akka://cluster-test@127.0.0.1:2558
06:05:22,645 PM [cluster-test-akka.actor.default-dispatcher-15] [DEBUG] ShardManager - Marking Leader member-2-shard-default-config10 as unavailable.
06:05:22,645 PM [cluster-test-akka.actor.default-dispatcher-15] [DEBUG] ShardManager - shard-manager-config10: In findPrimary: org.opendaylight.controller.cluster.datastore.messages.FindPrimary [shardName=default, waitUntilReady=true]
06:05:22,646 PM [cluster-test-akka.actor.default-dispatcher-15] [DEBUG] ShardManager - shard-manager-config10: Scheduling 1200 ms timer to wait for shard ShardInformation [shardId=member-1-shard-default-config10, leaderAvailable=false, actorInitialized=true, followerSyncStatus=false, role=Follower, leaderId=member-2-shard-default-config10, activeMember=true]
06:05:22,673 PM [cluster-test-akka.actor.default-dispatcher-12] [INFO] ShardManager - shard-manager-config10: Received MemberUp: memberName: MemberName{name=member-2}, address: akka://cluster-test@127.0.0.1:2559
06:05:22,673 PM [cluster-test-akka.actor.default-dispatcher-12] [INFO] ShardInformation - updatePeerAddress for peer member-2-shard-default-config10 with address akka://cluster-test@127.0.0.1:2559/user/shardmanager-config10/member-2-shard-default-config10
06:05:22,674 PM [cluster-test-akka.actor.default-dispatcher-12] [DEBUG] ShardInformation - Sending PeerAddressResolved for peer member-2-shard-default-config10 with address akka://cluster-test@127.0.0.1:2559/user/shardmanager-config10/member-2-shard-default-config10 to akka://cluster-test/user/member-2-shard-default-config
06:05:22,674 PM [cluster-test-akka.actor.default-dispatcher-12] [INFO] ShardManager - shard-manager-config10: All Shards are ready - data store config10 is ready
06:05:23,861 PM [cluster-test-akka.actor.default-dispatcher-15] [DEBUG] ShardManager - shard-manager-config10: Received ShardNotInitializedTimeout message for shard default
06:05:23,861 PM [cluster-test-akka.actor.default-dispatcher-15] [DEBUG] ShardManager - shard-manager-config10: Returning NoShardLeaderException for shard default
06:05:23,862 PM [cluster-test-akka.actor.default-dispatcher-15] [INFO] ShardManager - shard-manager-config10: Received LeaderStateChanged message: LeaderStateChanged [memberId=member-1-shard-default-config10, leaderId=member-1-shard-default-config10, leaderPayloadVersion=13]
06:05:23,862 PM [cluster-test-akka.actor.default-dispatcher-15] [INFO] ShardManager - shard-manager-config10: All Shards are ready - data store config10 is ready
06:05:23,862 PM [cluster-test-akka.actor.default-dispatcher-15] [INFO] ShardManager - shard-manager-config10: Received role changed for member-1-shard-default-config10 from Follower to Leader
06:05:23,862 PM [cluster-test-akka.actor.default-dispatcher-15] [INFO] ShardManager - shard-manager-config10: All Shards are ready - data store config10 is ready
06:05:23,862 PM [cluster-test-akka.actor.default-dispatcher-15] [DEBUG] ShardManager - shard-manager-config10: In findPrimary: org.opendaylight.controller.cluster.datastore.messages.FindPrimary [shardName=default, waitUntilReady=true]
06:05:23,862 PM [cluster-test-akka.actor.default-dispatcher-15] [DEBUG] ShardManager - shard-manager-config10: Found primary for default: LocalPrimaryShardFound [primaryPath=akka://cluster-test@127.0.0.1:2558/user/member-1-shard-default-config#-2042219853, localShardDataTree=org.opendaylight.yangtools.yang.data.tree.api.DataTree$MockitoMock$1bGo7AjM@44afeee]
06:05:23,862 PM [main] [INFO] ShardManagerTest - testShardAvailabilityChangeOnMemberUnreachableAndLeadershipChange ending
06:05:23,964 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] ShardManager - Stopping ShardManager shard-manager-config10
06:05:23,969 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] RemoteActorRefProvider$RemotingTerminator - Shutting down remote daemon.
06:05:23,969 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] RemoteActorRefProvider$RemotingTerminator - Remote daemon shut down; proceeding with flushing remote transports.
06:05:23,976 PM [cluster-test-akka.actor.default-dispatcher-5] [WARN] Materializer - [outbound connection to [akka://cluster-test@127.0.0.1:2559], control stream] Upstream failed, cause: StreamTcpException: The connection has been aborted
06:05:23,976 PM [cluster-test-akka.actor.default-dispatcher-5] [WARN] Materializer - [outbound connection to [akka://cluster-test@127.0.0.1:2559], message stream] Upstream failed, cause: StreamTcpException: The connection has been aborted
06:05:23,991 PM [cluster-test-akka.actor.default-dispatcher-10] [INFO] ShardManager - Stopping ShardManager shard-manager-config10
06:05:23,992 PM [cluster-test-akka.actor.default-dispatcher-10] [INFO] RemoteActorRefProvider$RemotingTerminator - Shutting down remote daemon.
06:05:23,992 PM [cluster-test-akka.actor.default-dispatcher-10] [INFO] RemoteActorRefProvider$RemotingTerminator - Remote daemon shut down; proceeding with flushing remote transports.
06:05:25,5 PM [cluster-test-akka.actor.default-dispatcher-10] [INFO] RemoteActorRefProvider$RemotingTerminator - Remoting shut down.
[WARN] [01/08/2024 18:05:25.008] [cluster-test-akka.actor.internal-dispatcher-4] [Cluster(akka://cluster-test)] Could not unregister Cluster JMX MBean with name=akka:type=Cluster as it was not found. If you are running multiple clusters in the same JVM, set 'akka.cluster.jmx.multi-mbeans-in-same-jvm = on' in config
06:05:25,30 PM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Starting ShardManager shard-manager-config11
06:05:25,31 PM [test-akka.actor.default-dispatcher-11] [INFO] EmptyLocalActorRef - Message [org.opendaylight.controller.cluster.common.actor.Monitor] from TestActor[akka://test/user/shardmanager-config11] to Actor[akka://test/user/termination-monitor] was not delivered. [9] dead letters encountered. If this is not an expected behavior then Actor[akka://test/user/termination-monitor] may have terminated unexpectedly. This logging can be turned off or adjusted with configuration settings 'akka.log-dead-letters' and 'akka.log-dead-letters-during-shutdown'.
06:05:25,34 PM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Recovery complete : shard-manager-config11
06:05:25,52 PM [test-akka.actor.default-dispatcher-16] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1
06:05:25,52 PM [test-akka.actor.default-dispatcher-16] [DEBUG] ShardManager - shard-manager-config11: onAddShardReplica: AddShardReplica[ShardName=astronauts]
06:05:25,54 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config11: Sending AddServer message to peer akka://test@127.0.0.1:2565/system/testProbe-529#416808543 for shard member-1-shard-astronauts-config11
06:05:25,65 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config11: onRemoveShardReplica: RemoveShardReplica [shardName=astronauts, memberName=MemberName{name=member-2}]
06:05:25,66 PM [test-akka.actor.default-dispatcher-16] [DEBUG] ShardManager - shard-manager-config11: A shard replica operation for astronauts is already in progress
06:05:25,169 PM [main] [INFO] ShardManagerTest - testPerShardDatastoreContext starting
06:05:25,177 PM [test-akka.actor.default-dispatcher-16] [INFO] ShardManager - Starting ShardManager shard-manager-config12
06:05:25,178 PM [test-akka.actor.default-dispatcher-16] [INFO] ShardManager - Recovery complete : shard-manager-config12
06:05:25,178 PM [test-akka.actor.default-dispatcher-16] [DEBUG] ShardManager - shard-manager-config12: Creating local shard: member-1-shard-default-config12
06:05:25,178 PM [test-akka.actor.default-dispatcher-16] [DEBUG] ShardManager - shard-manager-config12: Creating local shard: member-1-shard-topology-config12
06:05:25,180 PM [test-akka.actor.default-dispatcher-11] [INFO] EmptyLocalActorRef - Message [org.opendaylight.controller.cluster.common.actor.Monitor] from Actor[akka://test/user/$g#-1430829000] to Actor[akka://test/user/termination-monitor] was not delivered. [10] dead letters encountered, no more dead letters will be logged in next [5.000 min]. If this is not an expected behavior then Actor[akka://test/user/termination-monitor] may have terminated unexpectedly. This logging can be turned off or adjusted with configuration settings 'akka.log-dead-letters' and 'akka.log-dead-letters-during-shutdown'.
06:05:25,188 PM [test-akka.actor.default-dispatcher-13] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1
06:05:25,188 PM [test-akka.actor.default-dispatcher-13] [DEBUG] ShardManager - Creating Shard member-1-shard-default-config12
06:05:25,188 PM [test-akka.actor.default-dispatcher-13] [DEBUG] ShardManager - Creating Shard member-1-shard-topology-config12
06:05:25,189 PM [test-akka.actor.default-dispatcher-13] [DEBUG] ShardInformation - Sending new DatastoreContext to member-1-shard-default-config12
06:05:25,189 PM [test-akka.actor.default-dispatcher-13] [DEBUG] ShardInformation - Sending new DatastoreContext to member-1-shard-topology-config12
06:05:25,239 PM [main] [INFO] ShardManagerTest - testPerShardDatastoreContext ending
06:05:25,343 PM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/default1#-1184703360]
06:05:25,354 PM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/topology2#-443679615]
06:05:25,354 PM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/$g#-1430829000]
06:05:25,355 PM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Stopping ShardManager shard-manager-config12
06:05:25,356 PM [main] [INFO] ShardManagerTest - testOnReceiveFindPrimaryForLocalLeaderShard starting
06:05:25,358 PM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Starting ShardManager shard-manager-config13
06:05:25,360 PM [test-akka.actor.default-dispatcher-13] [INFO] ShardManager - Recovery complete : shard-manager-config13
06:05:25,360 PM [test-akka.actor.default-dispatcher-13] [DEBUG] ShardManager - shard-manager-config13: Creating local shard: member-1-shard-default-config13
06:05:25,369 PM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1
06:05:25,369 PM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - Creating Shard member-1-shard-default-config13
06:05:25,369 PM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - shard-manager-config13: Initializing shard [default]
06:05:25,369 PM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardInformation - Shard member-1-shard-default-config13 is initialized
06:05:25,369 PM [test-akka.actor.default-dispatcher-5] [INFO] ShardManager - shard-manager-config13: Received LeaderStateChanged message: LeaderStateChanged [memberId=member-1-shard-default-config13, leaderId=member-1-shard-default-config13, leaderPayloadVersion=13]
06:05:25,420 PM [test-akka.actor.default-dispatcher-5] [INFO] ShardManager - shard-manager-config13: Received role changed for member-1-shard-default-config13 from Candidate to Leader
06:05:25,420 PM [test-akka.actor.default-dispatcher-5] [INFO] ShardManager - shard-manager-config13: All Shards are ready - data store config13 is ready
06:05:25,420 PM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - shard-manager-config13: In findPrimary: org.opendaylight.controller.cluster.datastore.messages.FindPrimary [shardName=default, waitUntilReady=false]
06:05:25,420 PM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - shard-manager-config13: Found primary for default: LocalPrimaryShardFound [primaryPath=akka://test@127.0.0.1:2565/user/member-1-shard-default-config#-521112333, localShardDataTree=org.opendaylight.yangtools.yang.data.tree.api.DataTree$MockitoMock$1bGo7AjM@662ad103]
06:05:25,420 PM [main] [INFO] ShardManagerTest - testOnReceiveFindPrimaryForLocalLeaderShard ending
06:05:25,522 PM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/$h#291098748]
06:05:25,533 PM [test-akka.actor.default-dispatcher-5] [INFO] ShardManager - Stopping ShardManager shard-manager-config13
06:05:25,534 PM [main] [INFO] ShardManagerTest - testShardAvailabilityChangeOnMemberWithNameContainedInLeaderIdUnreachable starting
06:05:25,546 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] Slf4jLogger - Slf4jLogger started
06:05:25,553 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] ArteryTransport - Remoting started with transport [Artery tcp]; listening on address [akka://cluster-test@127.0.0.1:2562] with UID [2647097408170708813]
06:05:25,555 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2562] - Starting up, Akka version [2.6.21] ...
06:05:25,555 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2562] - Registered cluster JMX MBean [akka:type=Cluster]
06:05:25,555 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2562] - Started up successfully
06:05:25,556 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2562] - No downing-provider-class configured, manual cluster downing required, see https://doc.akka.io/docs/akka/current/typed/cluster.html#downing
06:05:25,556 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2562] - No seed-nodes configured, manual cluster join required, see https://doc.akka.io/docs/akka/current/typed/cluster.html#joining
06:05:25,586 PM [cluster-test-akka.actor.default-dispatcher-11] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2562] - Node [akka://cluster-test@127.0.0.1:2562] is JOINING itself (with roles [member-256, dc-default], version [0.0.0]) and forming new cluster
06:05:25,586 PM [cluster-test-akka.actor.default-dispatcher-11] [INFO] EmptyLocalActorRef - Message [org.opendaylight.controller.cluster.common.actor.Monitor] from TestActor[akka://cluster-test/user/shardmanager-config14] to Actor[akka://cluster-test/user/termination-monitor] was not delivered. [1] dead letters encountered. If this is not an expected behavior then Actor[akka://cluster-test/user/termination-monitor] may have terminated unexpectedly. This logging can be turned off or adjusted with configuration settings 'akka.log-dead-letters' and 'akka.log-dead-letters-during-shutdown'.
06:05:25,587 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] ShardManager - Starting ShardManager shard-manager-config14
06:05:25,588 PM [cluster-test-akka.actor.default-dispatcher-12] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2562] - is the new leader among reachable nodes (more leaders may exist)
06:05:25,589 PM [cluster-test-akka.actor.default-dispatcher-12] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2562] - Leader is moving node [akka://cluster-test@127.0.0.1:2562] to [Up]
06:05:25,597 PM [cluster-test-akka.actor.default-dispatcher-13] [INFO] ShardManager - Recovery complete : shard-manager-config14
06:05:25,597 PM [cluster-test-akka.actor.default-dispatcher-13] [DEBUG] ShardManager - shard-manager-config14: Creating local shard: member-256-shard-default-config14
06:05:25,597 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] Slf4jLogger - Slf4jLogger started
06:05:25,598 PM [cluster-test-akka.actor.default-dispatcher-13] [INFO] ShardManager - shard-manager-config14: Received MemberUp: memberName: MemberName{name=member-256}, address: akka://cluster-test@127.0.0.1:2562
06:05:25,598 PM [cluster-test-akka.actor.default-dispatcher-13] [INFO] ShardInformation - updatePeerAddress for peer member-256-shard-default-config14 with address akka://cluster-test@127.0.0.1:2562/user/shardmanager-config14/member-256-shard-default-config14
06:05:25,607 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] ArteryTransport - Remoting started with transport [Artery tcp]; listening on address [akka://cluster-test@127.0.0.1:2559] with UID [-6037147364045610662]
06:05:25,607 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2559] - Starting up, Akka version [2.6.21] ...
06:05:25,610 PM [cluster-test-akka.actor.default-dispatcher-5] [WARN] Cluster - Could not register Cluster JMX MBean with name=akka:type=Cluster as it is already registered. If you are running multiple clusters in the same JVM, set 'akka.cluster.jmx.multi-mbeans-in-same-jvm = on' in config
06:05:25,610 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2559] - Started up successfully
06:05:25,615 PM [cluster-test-akka.actor.default-dispatcher-10] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2559] - No downing-provider-class configured, manual cluster downing required, see https://doc.akka.io/docs/akka/current/typed/cluster.html#downing
06:05:25,615 PM [cluster-test-akka.actor.default-dispatcher-10] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2559] - No seed-nodes configured, manual cluster join required, see https://doc.akka.io/docs/akka/current/typed/cluster.html#joining
06:05:25,622 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] EmptyLocalActorRef - Message [org.opendaylight.controller.cluster.common.actor.Monitor] from TestActor[akka://cluster-test/user/shardmanager-config14] to Actor[akka://cluster-test/user/termination-monitor] was not delivered. [1] dead letters encountered. If this is not an expected behavior then Actor[akka://cluster-test/user/termination-monitor] may have terminated unexpectedly. This logging can be turned off or adjusted with configuration settings 'akka.log-dead-letters' and 'akka.log-dead-letters-during-shutdown'.
06:05:25,624 PM [cluster-test-akka.actor.default-dispatcher-10] [INFO] ShardManager - Starting ShardManager shard-manager-config14
06:05:25,629 PM [cluster-test-akka.actor.default-dispatcher-13] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1
06:05:25,629 PM [cluster-test-akka.actor.default-dispatcher-13] [DEBUG] ShardManager - Creating Shard member-256-shard-default-config14
06:05:25,629 PM [cluster-test-akka.actor.default-dispatcher-13] [INFO] ShardInformation - updatePeerAddress for peer member-256-shard-default-config14 with address akka://cluster-test@127.0.0.1:2562/user/shardmanager-config14/member-256-shard-default-config14
06:05:25,629 PM [cluster-test-akka.actor.default-dispatcher-13] [DEBUG] ShardInformation - Sending PeerAddressResolved for peer member-256-shard-default-config14 with address akka://cluster-test@127.0.0.1:2562/user/shardmanager-config14/member-256-shard-default-config14 to akka://cluster-test/user/member-256-shard-default-config
06:05:25,629 PM [cluster-test-akka.actor.default-dispatcher-13] [DEBUG] ShardManager - shard-manager-config14: updated peer member-256-shard-default-config14 on member MemberName{name=member-256} with address akka://cluster-test@127.0.0.1:2562/user/shardmanager-config14/member-256-shard-default-config14 on shard member-256-shard-default-config14 whose actor address is Actor[akka://cluster-test/user/member-256-shard-default-config#964070269]
06:05:25,630 PM [cluster-test-akka.actor.default-dispatcher-13] [DEBUG] ShardManager - shard-manager-config14: Initializing shard [default]
06:05:25,630 PM [cluster-test-akka.actor.default-dispatcher-13] [DEBUG] ShardInformation - Shard member-256-shard-default-config14 is initialized
06:05:25,630 PM [cluster-test-akka.actor.default-dispatcher-13] [INFO] ShardManager - shard-manager-config14: Received LeaderStateChanged message: LeaderStateChanged [memberId=member-256-shard-default-config14, leaderId=member-256-shard-default-config14, leaderPayloadVersion=13]
06:05:25,630 PM [cluster-test-akka.actor.default-dispatcher-13] [INFO] ShardManager - shard-manager-config14: Received role changed for member-256-shard-default-config14 from Candidate to Leader
06:05:25,630 PM [cluster-test-akka.actor.default-dispatcher-13] [INFO] ShardManager - shard-manager-config14: All Shards are ready - data store config14 is ready
06:05:25,630 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] ShardManager - Recovery complete : shard-manager-config14
06:05:25,630 PM [cluster-test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - shard-manager-config14: Creating local shard: member-2-shard-default-config14
06:05:25,631 PM [cluster-test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1
06:05:25,631 PM [cluster-test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - Creating Shard member-2-shard-default-config14
06:05:25,631 PM [cluster-test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - shard-manager-config14: Initializing shard [default]
06:05:25,631 PM [cluster-test-akka.actor.default-dispatcher-5] [DEBUG] ShardInformation - Shard member-2-shard-default-config14 is initialized
06:05:25,631 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] ShardManager - shard-manager-config14: Received LeaderStateChanged message: LeaderStateChanged [memberId=member-2-shard-default-config14, leaderId=member-256-shard-default-config14, leaderPayloadVersion=13]
06:05:25,642 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] ShardManager - shard-manager-config14: Received role changed for member-2-shard-default-config14 from Candidate to Follower
06:05:25,702 PM [cluster-test-akka.actor.default-dispatcher-13] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2562] - Node [akka://cluster-test@127.0.0.1:2559] is JOINING, roles [member-2, dc-default], version [0.0.0]
06:05:25,705 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2559] - Welcome from [akka://cluster-test@127.0.0.1:2562]
06:05:25,707 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] ShardManager - shard-manager-config14: Received MemberUp: memberName: MemberName{name=member-256}, address: akka://cluster-test@127.0.0.1:2562
06:05:25,707 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] ShardInformation - updatePeerAddress for peer member-256-shard-default-config14 with address akka://cluster-test@127.0.0.1:2562/user/shardmanager-config14/member-256-shard-default-config14
06:05:25,707 PM [cluster-test-akka.actor.default-dispatcher-5] [DEBUG] ShardInformation - Sending PeerAddressResolved for peer member-256-shard-default-config14 with address akka://cluster-test@127.0.0.1:2562/user/shardmanager-config14/member-256-shard-default-config14 to akka://cluster-test/user/member-2-shard-default-config
06:05:25,707 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] ShardManager - shard-manager-config14: All Shards are ready - data store config14 is ready
06:05:26,571 PM [cluster-test-akka.actor.default-dispatcher-13] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2562] - Leader is moving node [akka://cluster-test@127.0.0.1:2559] to [Up]
06:05:26,572 PM [cluster-test-akka.actor.default-dispatcher-13] [INFO] ShardManager - shard-manager-config14: Received MemberUp: memberName: MemberName{name=member-2}, address: akka://cluster-test@127.0.0.1:2559
06:05:26,572 PM [cluster-test-akka.actor.default-dispatcher-13] [INFO] ShardInformation - updatePeerAddress for peer member-2-shard-default-config14 with address akka://cluster-test@127.0.0.1:2559/user/shardmanager-config14/member-2-shard-default-config14
06:05:26,572 PM [cluster-test-akka.actor.default-dispatcher-13] [DEBUG] ShardInformation - Sending PeerAddressResolved for peer member-2-shard-default-config14 with address akka://cluster-test@127.0.0.1:2559/user/shardmanager-config14/member-2-shard-default-config14 to akka://cluster-test/user/member-256-shard-default-config
06:05:26,572 PM [cluster-test-akka.actor.default-dispatcher-13] [INFO] ShardManager - shard-manager-config14: All Shards are ready - data store config14 is ready
06:05:26,573 PM [cluster-test-akka.actor.default-dispatcher-12] [DEBUG] ShardManager - shard-manager-config14: In findPrimary: org.opendaylight.controller.cluster.datastore.messages.FindPrimary [shardName=default, waitUntilReady=true]
06:05:26,573 PM [cluster-test-akka.actor.default-dispatcher-12] [DEBUG] ShardManager - shard-manager-config14: Found primary for default: LocalPrimaryShardFound [primaryPath=akka://cluster-test@127.0.0.1:2562/user/member-256-shard-default-config#964070269, localShardDataTree=org.opendaylight.yangtools.yang.data.tree.api.DataTree$MockitoMock$1bGo7AjM@9c230ab]
06:05:26,574 PM [cluster-test-akka.actor.default-dispatcher-12] [INFO] ShardManager - Received UnreachableMember: memberName MemberName{name=member-2}, address: akka://cluster-test@127.0.0.1:2558
06:05:26,574 PM [cluster-test-akka.actor.default-dispatcher-12] [DEBUG] ShardManager - shard-manager-config14: In findPrimary: org.opendaylight.controller.cluster.datastore.messages.FindPrimary [shardName=default, waitUntilReady=true]
06:05:26,575 PM [cluster-test-akka.actor.default-dispatcher-12] [DEBUG] ShardManager - shard-manager-config14: Found primary for default: LocalPrimaryShardFound [primaryPath=akka://cluster-test@127.0.0.1:2562/user/member-256-shard-default-config#964070269, localShardDataTree=org.opendaylight.yangtools.yang.data.tree.api.DataTree$MockitoMock$1bGo7AjM@9c230ab]
06:05:26,577 PM [main] [INFO] ShardManagerTest - testShardAvailabilityChangeOnMemberWithNameContainedInLeaderIdUnreachable ending
06:05:26,635 PM [cluster-test-akka.actor.default-dispatcher-10] [INFO] ShardManager - shard-manager-config14: Received MemberUp: memberName: MemberName{name=member-2}, address: akka://cluster-test@127.0.0.1:2559
06:05:26,635 PM [cluster-test-akka.actor.default-dispatcher-10] [INFO] ShardInformation - updatePeerAddress for peer member-2-shard-default-config14 with address akka://cluster-test@127.0.0.1:2559/user/shardmanager-config14/member-2-shard-default-config14
06:05:26,635 PM [cluster-test-akka.actor.default-dispatcher-10] [DEBUG] ShardInformation - Sending PeerAddressResolved for peer member-2-shard-default-config14 with address akka://cluster-test@127.0.0.1:2559/user/shardmanager-config14/member-2-shard-default-config14 to akka://cluster-test/user/member-2-shard-default-config
06:05:26,636 PM [cluster-test-akka.actor.default-dispatcher-10] [INFO] ShardManager - shard-manager-config14: All Shards are ready - data store config14 is ready
06:05:26,679 PM [cluster-test-akka.actor.default-dispatcher-10] [INFO] ShardManager - Stopping ShardManager shard-manager-config14
06:05:26,680 PM [cluster-test-akka.actor.default-dispatcher-10] [INFO] RemoteActorRefProvider$RemotingTerminator - Shutting down remote daemon.
06:05:26,680 PM [cluster-test-akka.actor.default-dispatcher-10] [INFO] RemoteActorRefProvider$RemotingTerminator - Remote daemon shut down; proceeding with flushing remote transports.
06:05:26,696 PM [cluster-test-akka.actor.default-dispatcher-10] [WARN] Materializer - [outbound connection to [akka://cluster-test@127.0.0.1:2559], message stream] Upstream failed, cause: StreamTcpException: The connection has been aborted
06:05:26,697 PM [cluster-test-akka.actor.default-dispatcher-10] [WARN] Materializer - [outbound connection to [akka://cluster-test@127.0.0.1:2559], control stream] Upstream failed, cause: StreamTcpException: The connection has been aborted
06:05:26,707 PM [cluster-test-akka.actor.default-dispatcher-10] [INFO] RemoteActorRefProvider$RemotingTerminator - Remoting shut down.
06:05:26,725 PM [cluster-test-akka.actor.default-dispatcher-10] [INFO] ShardManager - Stopping ShardManager shard-manager-config14
06:05:26,725 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] RemoteActorRefProvider$RemotingTerminator - Shutting down remote daemon.
06:05:26,725 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] RemoteActorRefProvider$RemotingTerminator - Remote daemon shut down; proceeding with flushing remote transports.
06:05:27,644 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2559] - is the new leader among reachable nodes (more leaders may exist)
06:05:27,746 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] RemoteActorRefProvider$RemotingTerminator - Remoting shut down.
[WARN] [01/08/2024 18:05:27.748] [cluster-test-akka.actor.internal-dispatcher-4] [Cluster(akka://cluster-test)] Could not unregister Cluster JMX MBean with name=akka:type=Cluster as it was not found. If you are running multiple clusters in the same JVM, set 'akka.cluster.jmx.multi-mbeans-in-same-jvm = on' in config
06:05:27,763 PM [main] [INFO] ShardManager - Starting ShardManager shard-manager-config15
06:05:27,765 PM [test-akka.actor.default-dispatcher-5] [INFO] ShardManager - Recovery complete : shard-manager-config15
06:05:27,766 PM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - shard-manager-config15: Creating local shard: member-1-shard-default-config15
06:05:27,766 PM [main] [INFO] ShardManager - shard-manager-config15: Received role changed for member-1-shard-default-config15 from Follower to Leader
06:05:27,867 PM [main] [INFO] TestActorFactory - Killing actor TestActor[akka://test/user/$$c]
06:05:27,878 PM [main] [INFO] ShardManager - Stopping ShardManager shard-manager-config15
06:05:27,883 PM [main] [INFO] ShardManager - Starting ShardManager shard-manager-config16
06:05:27,885 PM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Recovery complete : shard-manager-config16
06:05:27,885 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config16: Creating local shard: member-1-shard-default-config16
06:05:27,886 PM [main] [INFO] ShardManager - shard-manager-config16: Received role changed for member-1-shard-default-config16 from Candidate to Leader
06:05:27,886 PM [main] [INFO] ShardManager - shard-manager-config16: Received LeaderStateChanged message: LeaderStateChanged [memberId=member-1-shard-default-config16, leaderId=member-1-shard-default-config16, leaderPayloadVersion=13]
06:05:27,886 PM [main] [INFO] ShardManager - shard-manager-config16: All Shards are ready - data store config16 is ready
06:05:27,988 PM [main] [INFO] TestActorFactory - Killing actor TestActor[akka://test/user/$$d]
06:05:27,999 PM [main] [INFO] ShardManager - Stopping ShardManager shard-manager-config16
06:05:28,1 PM [main] [INFO] ShardManagerTest - testOnCreateShardWithLocalMemberNotInShardConfig starting
06:05:28,6 PM [test-akka.actor.default-dispatcher-16] [INFO] ShardManager - Starting ShardManager shard-manager-config17
06:05:28,8 PM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Recovery complete : shard-manager-config17
06:05:28,8 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1
06:05:28,20 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config17: onCreateShard: CreateShard [moduleShardConfig=ModuleShardConfiguration [namespace=foo-ns, moduleName=foo-module, shardName=foo, shardMemberNames=[MemberName{name=member-5}, MemberName{name=member-6}], shardStrategyName=null], shardPropsCreator=org.opendaylight.controller.cluster.datastore.Shard$Builder@33566a1]
06:05:28,21 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config17 doCreateShard: shardId: member-1-shard-foo-config17, memberNames: [MemberName{name=member-5}, MemberName{name=member-6}], peerAddresses: {}, isActiveMember: false
06:05:28,24 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config17: findLocalShard : foo
06:05:28,24 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config17: Scheduling 60000 ms timer to wait for shard ShardInformation [shardId=member-1-shard-foo-config17, leaderAvailable=false, actorInitialized=false, followerSyncStatus=false, role=null, leaderId=null, activeMember=false]
06:05:28,41 PM [test-shard-dispatcher-17] [INFO] Shard - Shard created : member-1-shard-foo-config17, persistent : true
06:05:28,55 PM [test-akka.actor.default-dispatcher-16] [INFO] RoleChangeNotifier - RoleChangeNotifier:akka://test@127.0.0.1:2565/user/$i/member-1-shard-foo-config17/member-1-shard-foo-config17-notifier#1102531263 created and ready for shard:member-1-shard-foo-config17
06:05:28,64 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardSnapshotActor - Actor created Actor[akka://test/user/$i/member-1-shard-foo-config17/shard-member-1:snapshot-read#-896524889]
06:05:28,65 PM [test-shard-dispatcher-17] [INFO] Shard - Starting recovery for member-1-shard-foo-config17 with journal batch size 1
06:05:28,78 PM [test-shard-dispatcher-17] [DEBUG] Shard - member-1-shard-foo-config17: onReceiveRecover: Received message class akka.persistence.RecoveryCompleted$ from Actor[akka://test/deadLetters]
06:05:28,80 PM [test-shard-dispatcher-17] [INFO] Shard - member-1-shard-foo-config17: Recovery completed  - Switching actor to Follower - last log index = -1, last log term = -1, snapshot index = -1, snapshot term = -1, journal size = 0
06:05:28,81 PM [test-akka.actor.default-dispatcher-16] [DEBUG] ShardManager - shard-manager-config17: Initializing shard [foo]
06:05:28,81 PM [test-akka.actor.default-dispatcher-16] [DEBUG] ShardInformation - Shard member-1-shard-foo-config17 is initialized
06:05:28,81 PM [test-akka.actor.default-dispatcher-16] [DEBUG] ShardInformation - Shard member-1-shard-foo-config17 is initialized - notifying 1 OnShardInitialized callbacks
06:05:28,81 PM [main] [INFO] ShardManagerTest - testOnCreateShardWithLocalMemberNotInShardConfig ending
06:05:28,87 PM [test-shard-dispatcher-17] [DEBUG] DataTreeChangeListenerSupport - member-1-shard-foo-config17: onLeadershipChange, isLeader: false, hasLeader : false
06:05:28,87 PM [test-shard-dispatcher-17] [DEBUG] Shard - member-1-shard-foo-config17: onStateChanged: Closing all transaction chains because shard member-1-shard-foo-config17 is no longer the leader
06:05:28,88 PM [test-akka.actor.default-dispatcher-16] [INFO] RoleChangeNotifier - RoleChangeNotifier for member-1-shard-foo-config17 , received role change from null to Follower
06:05:28,91 PM [test-shard-dispatcher-17] [INFO] DefaultConfigParamsImpl - Trying to use custom RaftPolicy org.opendaylight.controller.cluster.raft.policy.DisableElectionsRaftPolicy
06:05:28,93 PM [test-akka.actor.default-dispatcher-11] [INFO] RoleChangeNotifier - RoleChangeNotifier for member-1-shard-foo-config17 , registered listener akka://test/user/$i
06:05:28,93 PM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - shard-manager-config17: Received role changed for member-1-shard-foo-config17 from null to Follower
06:05:28,183 PM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/$i#23929939]
06:05:28,194 PM [test-shard-dispatcher-17] [INFO] Shard - Stopping Shard member-1-shard-foo-config17
06:05:28,194 PM [test-shard-dispatcher-17] [DEBUG] MessageAssembler - member-1-shard-foo-config17 (Follower): Closing
06:05:28,195 PM [test-shard-dispatcher-17] [DEBUG] Shard - member-1-shard-foo-config17: Aborting 0 pending queued transactions
06:05:28,195 PM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Stopping ShardManager shard-manager-config17
06:05:28,197 PM [main] [INFO] ShardManagerTest - testServerRemovedShardActorNotRunning starting
06:05:28,200 PM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Starting ShardManager shard-manager-config18
06:05:28,201 PM [test-akka.actor.default-dispatcher-5] [INFO] ShardManager - Recovery complete : shard-manager-config18
06:05:28,202 PM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - shard-manager-config18: Creating local shard: member-1-shard-default-config18
06:05:28,202 PM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - shard-manager-config18: Creating local shard: member-1-shard-people-config18
06:05:28,311 PM [test-akka.actor.default-dispatcher-16] [DEBUG] ShardManager - shard-manager-config18: findLocalShard : people
06:05:28,311 PM [test-akka.actor.default-dispatcher-16] [DEBUG] ShardManager - shard-manager-config18: Returning NotInitializedException for shard people
06:05:28,311 PM [test-akka.actor.default-dispatcher-16] [DEBUG] ShardManager - shard-manager-config18: findLocalShard : default
06:05:28,311 PM [test-akka.actor.default-dispatcher-16] [DEBUG] ShardManager - shard-manager-config18: Returning NotInitializedException for shard default
06:05:28,313 PM [test-akka.actor.default-dispatcher-16] [DEBUG] ShardManager - shard-manager-config18 : Local Shard replica for shard default has been removed
06:05:28,313 PM [test-akka.actor.default-dispatcher-16] [DEBUG] ShardManager - shard-manager-config18: persisting the shard list [people]
06:05:28,314 PM [main] [INFO] ShardManagerTest - testServerRemovedShardActorNotRunning ending
06:05:28,322 PM [test-akka.actor.default-dispatcher-16] [DEBUG] ShardManager - shard-manager-config18 saved ShardManager snapshot successfully. Deleting the prev snapshot if available
06:05:28,329 PM [test-akka.actor.default-dispatcher-16] [DEBUG] ShardManager - shard-manager-config18: Successfully deleted prior snapshots
06:05:28,415 PM [main] [INFO] TestActorFactory - Killing actor TestActor[akka://test/user/$$e]
06:05:28,426 PM [test-akka.actor.default-dispatcher-16] [INFO] ShardManager - Stopping ShardManager shard-manager-config18
06:05:28,430 PM [test-akka.actor.default-dispatcher-16] [INFO] ShardManager - Starting ShardManager shard-manager-config19
06:05:28,432 PM [test-akka.actor.default-dispatcher-16] [INFO] ShardManager - Recovery complete : shard-manager-config19
06:05:28,432 PM [test-akka.actor.default-dispatcher-16] [DEBUG] ShardManager - shard-manager-config19: Creating local shard: member-1-shard-default-config19
06:05:28,441 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1
06:05:28,441 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - Creating Shard member-1-shard-default-config19
06:05:28,441 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config19: Initializing shard [default]
06:05:28,441 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardInformation - Shard member-1-shard-default-config19 is initialized
06:05:28,441 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config19: In findPrimary: org.opendaylight.controller.cluster.datastore.messages.FindPrimary [shardName=default, waitUntilReady=false]
06:05:28,441 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config19: Returning NoShardLeaderException for shard default
06:05:28,543 PM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/$j#-2132262522]
06:05:28,554 PM [test-akka.actor.default-dispatcher-5] [INFO] ShardManager - Stopping ShardManager shard-manager-config19
06:05:28,556 PM [main] [INFO] ShardManagerTest - testOnReceiveFindPrimaryForFollowerShardWithNoInitialLeaderId starting
06:05:28,559 PM [test-akka.actor.default-dispatcher-5] [INFO] ShardManager - Starting ShardManager shard-manager-config20
06:05:28,560 PM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Recovery complete : shard-manager-config20
06:05:28,561 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config20: Creating local shard: member-1-shard-default-config20
06:05:28,570 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1
06:05:28,570 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - Creating Shard member-1-shard-default-config20
06:05:28,570 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config20: Initializing shard [default]
06:05:28,570 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardInformation - Shard member-1-shard-default-config20 is initialized
06:05:28,570 PM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - shard-manager-config20: Received role changed for member-1-shard-default-config20 from Candidate to Follower
06:05:28,570 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config20: In findPrimary: org.opendaylight.controller.cluster.datastore.messages.FindPrimary [shardName=default, waitUntilReady=false]
06:05:28,570 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config20: Returning NoShardLeaderException for shard default
06:05:28,570 PM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - shard-manager-config20: Received LeaderStateChanged message: LeaderStateChanged [memberId=member-1-shard-default-config20, leaderId=member-1-shard-default-config20, leaderPayloadVersion=13]
06:05:28,571 PM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - shard-manager-config20: All Shards are ready - data store config20 is ready
06:05:28,571 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config20: In findPrimary: org.opendaylight.controller.cluster.datastore.messages.FindPrimary [shardName=default, waitUntilReady=false]
06:05:28,571 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config20: Found primary for default: LocalPrimaryShardFound [primaryPath=akka://test@127.0.0.1:2565/user/member-1-shard-default-config#593934826, localShardDataTree=org.opendaylight.yangtools.yang.data.tree.api.DataTree$MockitoMock$1bGo7AjM@60c27969]
06:05:28,571 PM [main] [INFO] ShardManagerTest - testOnReceiveFindPrimaryForFollowerShardWithNoInitialLeaderId starting
06:05:28,672 PM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/$k#173336605]
06:05:28,683 PM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - Stopping ShardManager shard-manager-config20
06:05:28,688 PM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - Starting ShardManager shard-manager-config21
06:05:28,692 PM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Recovery complete : shard-manager-config21
06:05:28,708 PM [test-akka.actor.default-dispatcher-15] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1
06:05:28,709 PM [test-akka.actor.default-dispatcher-15] [DEBUG] ShardManager - shard-manager-config21: onAddShardReplica: AddShardReplica[ShardName=astronauts]
06:05:28,710 PM [test-akka.actor.default-dispatcher-15] [DEBUG] ShardManager - shard-manager-config21: Sending AddServer message to peer akka://test@127.0.0.1:2565/system/testProbe-547#1468661236 for shard member-1-shard-astronauts-config21
06:05:28,721 PM [test-akka.actor.default-dispatcher-15] [DEBUG] ShardManager - shard-manager-config21: onAddShardReplica: AddShardReplica[ShardName=astronauts]
06:05:28,721 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config21: A shard replica operation for astronauts is already in progress
06:05:28,825 PM [main] [INFO] ShardManagerTest - testOnReceiveFindPrimaryWaitForReadyWithCandidateShard starting
06:05:28,827 PM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - Starting ShardManager shard-manager-config22
06:05:28,828 PM [test-akka.actor.default-dispatcher-15] [INFO] ShardManager - Recovery complete : shard-manager-config22
06:05:28,828 PM [test-akka.actor.default-dispatcher-15] [DEBUG] ShardManager - shard-manager-config22: Creating local shard: member-1-shard-default-config22
06:05:28,838 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1
06:05:28,838 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - Creating Shard member-1-shard-default-config22
06:05:28,838 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config22: Initializing shard [default]
06:05:28,838 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardInformation - Shard member-1-shard-default-config22 is initialized
06:05:28,838 PM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - shard-manager-config22: Received role changed for member-1-shard-default-config22 from null to Candidate
06:05:28,838 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config22: In findPrimary: org.opendaylight.controller.cluster.datastore.messages.FindPrimary [shardName=default, waitUntilReady=true]
06:05:28,838 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config22: Scheduling 1200 ms timer to wait for shard ShardInformation [shardId=member-1-shard-default-config22, leaderAvailable=false, actorInitialized=true, followerSyncStatus=false, role=Candidate, leaderId=null, activeMember=true]
06:05:30,53 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config22: Received ShardNotInitializedTimeout message for shard default
06:05:30,53 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config22: Returning NoShardLeaderException for shard default
06:05:30,54 PM [main] [INFO] ShardManagerTest - testOnReceiveFindPrimaryWaitForReadyWithCandidateShard ending
06:05:30,155 PM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/$l#557619047]
06:05:30,166 PM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - Stopping ShardManager shard-manager-config22
06:05:30,168 PM [main] [INFO] ShardManagerTest - testAddShardReplicaWithAddServerReplyFailure starting
06:05:30,171 PM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - Starting ShardManager shard-manager-config23
06:05:30,172 PM [test-akka.actor.default-dispatcher-15] [INFO] ShardManager - Recovery complete : shard-manager-config23
06:05:30,191 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1
06:05:30,202 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config23: onAddShardReplica: AddShardReplica[ShardName=astronauts]
06:05:30,203 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config23: Sending AddServer message to peer akka://test@127.0.0.1:2565/system/testProbe-552#1714875153 for shard member-1-shard-astronauts-config23
06:05:30,204 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config23: Received AddServerReply{status=TIMEOUT} for shard astronauts from leader akka://test@127.0.0.1:2565/system/testProbe-552#1714875153
06:05:30,204 PM [test-akka.actor.default-dispatcher-10] [WARN] ShardManager - shard-manager-config23: Leader failed to add shard replica astronauts with status TIMEOUT
06:05:30,204 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config23: findLocalShard : astronauts
06:05:30,204 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config23: Local shard astronauts not found - shards present: []
06:05:30,206 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config23: onAddShardReplica: AddShardReplica[ShardName=astronauts]
06:05:30,206 PM [test-akka.actor.default-dispatcher-15] [DEBUG] ShardManager - shard-manager-config23: Sending AddServer message to peer akka://test@127.0.0.1:2565/system/testProbe-552#1714875153 for shard member-1-shard-astronauts-config23
06:05:30,207 PM [test-akka.actor.default-dispatcher-15] [DEBUG] ShardManager - shard-manager-config23: Received AddServerReply{status=NO_LEADER} for shard astronauts from leader akka://test@127.0.0.1:2565/system/testProbe-552#1714875153
06:05:30,207 PM [test-akka.actor.default-dispatcher-15] [WARN] ShardManager - shard-manager-config23: Leader failed to add shard replica astronauts with status NO_LEADER
06:05:30,207 PM [main] [INFO] ShardManagerTest - testAddShardReplicaWithAddServerReplyFailure ending
06:05:30,308 PM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/member-1-shard-astronauts-config#754654044]
06:05:30,319 PM [main] [INFO] TestActorFactory - Killing actor TestActor[akka://test/user/shardmanager-config23]
06:05:30,319 PM [test-akka.actor.default-dispatcher-15] [INFO] ShardManager - Stopping ShardManager shard-manager-config23
06:05:30,323 PM [main] [INFO] ShardManager - Starting ShardManager shard-manager-config24
06:05:30,325 PM [test-akka.actor.default-dispatcher-15] [INFO] ShardManager - Recovery complete : shard-manager-config24
06:05:30,325 PM [test-akka.actor.default-dispatcher-15] [DEBUG] ShardManager - shard-manager-config24: Creating local shard: member-1-shard-default-config24
06:05:30,330 PM [main] [INFO] ShardManager - shard-manager-config24: Received role changed for member-1-shard-default-config24 from Candidate to Follower
06:05:30,330 PM [main] [INFO] ShardManager - shard-manager-config24 Received follower initial sync status for member-1-shard-default-config24 status sync done true
06:05:30,330 PM [main] [INFO] ShardManager - shard-manager-config24 Received follower initial sync status for member-1-shard-default-config24 status sync done false
06:05:30,432 PM [main] [INFO] TestActorFactory - Killing actor TestActor[akka://test/user/$$f]
06:05:30,443 PM [main] [INFO] ShardManager - Stopping ShardManager shard-manager-config24
06:05:30,447 PM [main] [INFO] ShardManager - Starting ShardManager shard-manager-config25
06:05:30,449 PM [test-akka.actor.default-dispatcher-5] [INFO] ShardManager - Recovery complete : shard-manager-config25
06:05:30,449 PM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - shard-manager-config25: Creating local shard: member-1-shard-default-config25
06:05:30,548 PM [main] [INFO] ShardManager - shard-manager-config25: Received role changed for unknown from Candidate to Leader
06:05:30,649 PM [main] [INFO] TestActorFactory - Killing actor TestActor[akka://test/user/$$g]
06:05:30,660 PM [main] [INFO] ShardManager - Stopping ShardManager shard-manager-config25
06:05:30,662 PM [main] [INFO] ShardManagerTest - testOnReceiveFindPrimaryWaitForReadyWithUninitializedShard starting
06:05:30,668 PM [test-akka.actor.default-dispatcher-5] [INFO] ShardManager - Starting ShardManager shard-manager-config26
06:05:30,669 PM [test-akka.actor.default-dispatcher-5] [INFO] ShardManager - Recovery complete : shard-manager-config26
06:05:30,669 PM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - shard-manager-config26: Creating local shard: member-1-shard-default-config26
06:05:30,678 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1
06:05:30,678 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - Creating Shard member-1-shard-default-config26
06:05:30,679 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config26: In findPrimary: org.opendaylight.controller.cluster.datastore.messages.FindPrimary [shardName=default, waitUntilReady=true]
06:05:30,679 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config26: Scheduling 600 ms timer to wait for shard ShardInformation [shardId=member-1-shard-default-config26, leaderAvailable=false, actorInitialized=false, followerSyncStatus=false, role=null, leaderId=null, activeMember=true]
06:05:31,293 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config26: Received ShardNotInitializedTimeout message for shard default
06:05:31,293 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config26: Returning NotInitializedException for shard default
06:05:31,293 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config26: Initializing shard [default]
06:05:31,293 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardInformation - Shard member-1-shard-default-config26 is initialized
06:05:31,493 PM [main] [INFO] ShardManagerTest - testOnReceiveFindPrimaryWaitForReadyWithUninitializedShard ending
06:05:31,595 PM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/$m#-1515701440]
06:05:31,606 PM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - Stopping ShardManager shard-manager-config26
06:05:31,610 PM [test-akka.actor.default-dispatcher-5] [INFO] ShardManager - Starting ShardManager shard-manager-config27
06:05:31,610 PM [test-akka.actor.default-dispatcher-5] [INFO] ShardManager - Recovery complete : shard-manager-config27
06:05:31,610 PM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - shard-manager-config27: Creating local shard: member-1-shard-default-config27
06:05:31,620 PM [test-akka.actor.default-dispatcher-15] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1
06:05:31,620 PM [test-akka.actor.default-dispatcher-15] [DEBUG] ShardManager - Creating Shard member-1-shard-default-config27
06:05:31,620 PM [test-akka.actor.default-dispatcher-15] [DEBUG] ShardManager - shard-manager-config27: Initializing shard [default]
06:05:31,620 PM [test-akka.actor.default-dispatcher-15] [DEBUG] ShardInformation - Shard member-1-shard-default-config27 is initialized
06:05:31,620 PM [test-akka.actor.default-dispatcher-15] [DEBUG] ShardManager - shard-manager-config27: findLocalShard : default
06:05:31,722 PM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/$n#847587723]
06:05:31,733 PM [test-akka.actor.default-dispatcher-15] [INFO] ShardManager - Stopping ShardManager shard-manager-config27
06:05:31,735 PM [main] [INFO] ShardManagerTest - testRegisterForShardLeaderChanges starting
06:05:31,737 PM [test-akka.actor.default-dispatcher-15] [INFO] ShardManager - Starting ShardManager shard-manager-config28
06:05:31,738 PM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - Recovery complete : shard-manager-config28
06:05:31,738 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config28: Creating local shard: member-1-shard-default-config28
06:05:31,747 PM [test-akka.actor.default-dispatcher-15] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1
06:05:31,747 PM [test-akka.actor.default-dispatcher-15] [DEBUG] ShardManager - Creating Shard member-1-shard-default-config28
06:05:31,748 PM [test-akka.actor.default-dispatcher-15] [DEBUG] ShardManager - shard-manager-config28: Initializing shard [default]
06:05:31,748 PM [test-akka.actor.default-dispatcher-15] [DEBUG] ShardInformation - Shard member-1-shard-default-config28 is initialized
06:05:31,748 PM [test-akka.actor.default-dispatcher-15] [DEBUG] ShardManager - shard-manager-config28: onRegisterForShardAvailabilityChanges: org.opendaylight.controller.cluster.datastore.shardmanager.RegisterForShardAvailabilityChanges@21e2f11
06:05:31,749 PM [test-akka.actor.default-dispatcher-15] [INFO] ShardManager - shard-manager-config28: Received LeaderStateChanged message: LeaderStateChanged [memberId=member-1-shard-default-config28, leaderId=member-1-shard-default-config28, leaderPayloadVersion=13]
06:05:31,779 PM [test-akka.actor.default-dispatcher-15] [INFO] ShardManager - shard-manager-config28: Received LeaderStateChanged message: LeaderStateChanged [memberId=member-1-shard-default-config28, leaderId=member-1-shard-default-config28, leaderPayloadVersion=13]
06:05:32,279 PM [test-akka.actor.default-dispatcher-15] [INFO] ShardManager - shard-manager-config28: Received LeaderStateChanged message: LeaderStateChanged [memberId=member-1-shard-default-config28, leaderId=null, leaderPayloadVersion=13]
06:05:32,290 PM [test-akka.actor.default-dispatcher-15] [INFO] ShardManager - shard-manager-config28: Received LeaderStateChanged message: LeaderStateChanged [memberId=member-1-shard-default-config28, leaderId=member-2-shard-default-config28, leaderPayloadVersion=13]
06:05:32,301 PM [test-akka.actor.default-dispatcher-15] [INFO] ShardManager - shard-manager-config28: Received LeaderStateChanged message: LeaderStateChanged [memberId=member-1-shard-default-config28, leaderId=member-1-shard-default-config28, leaderPayloadVersion=13]
06:05:32,801 PM [main] [INFO] ShardManagerTest - testRegisterForShardLeaderChanges ending
06:05:32,910 PM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/$o#1294979051]
06:05:32,921 PM [test-akka.actor.default-dispatcher-15] [INFO] ShardManager - Stopping ShardManager shard-manager-config28
06:05:32,925 PM [main] [INFO] ShardManager - Starting ShardManager shard-manager-config29
06:05:32,927 PM [test-akka.actor.default-dispatcher-15] [INFO] ShardManager - Recovery complete : shard-manager-config29
06:05:32,927 PM [test-akka.actor.default-dispatcher-15] [DEBUG] ShardManager - shard-manager-config29: Creating local shard: member-1-shard-default-config29
06:05:33,127 PM [main] [INFO] TestActorFactory - Killing actor TestActor[akka://test/user/$$h]
06:05:33,138 PM [main] [INFO] ShardManager - Stopping ShardManager shard-manager-config29
06:05:33,141 PM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - Starting ShardManager shard-manager-config30
06:05:33,143 PM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - Recovery complete : shard-manager-config30
06:05:33,143 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config30: Creating local shard: member-1-shard-default-config30
06:05:33,152 PM [test-akka.actor.default-dispatcher-15] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1
06:05:33,152 PM [test-akka.actor.default-dispatcher-15] [DEBUG] ShardManager - Creating Shard member-1-shard-default-config30
06:05:33,152 PM [test-akka.actor.default-dispatcher-15] [DEBUG] ShardManager - shard-manager-config30: In findPrimary: org.opendaylight.controller.cluster.datastore.messages.FindPrimary [shardName=non-existent, waitUntilReady=false]
06:05:33,152 PM [test-akka.actor.default-dispatcher-15] [DEBUG] ShardManager - shard-manager-config30: No shard found for non-existent
06:05:33,254 PM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/$p#-843298046]
06:05:33,264 PM [test-akka.actor.default-dispatcher-15] [INFO] ShardManager - Stopping ShardManager shard-manager-config30
06:05:33,269 PM [test-akka.actor.default-dispatcher-5] [INFO] ShardManager - Starting ShardManager shard-manager-config31
06:05:33,270 PM [test-akka.actor.default-dispatcher-15] [INFO] ShardManager - Recovery complete : shard-manager-config31
06:05:33,280 PM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - shard-manager-config31: onAddShardReplica: AddShardReplica[ShardName=model-inventory]
06:05:33,280 PM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - shard-manager-config31: No module configuration exists for shard model-inventory
06:05:33,381 PM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/$q#-523988611]
06:05:33,392 PM [test-akka.actor.default-dispatcher-5] [INFO] ShardManager - Stopping ShardManager shard-manager-config31
06:05:33,394 PM [main] [INFO] ShardManagerTest - testAddShardReplicaWithPreExistingReplicaInRemoteShardLeader starting
06:05:33,396 PM [test-akka.actor.default-dispatcher-5] [INFO] ShardManager - Starting ShardManager shard-manager-config32
06:05:33,397 PM [test-akka.actor.default-dispatcher-5] [INFO] ShardManager - Recovery complete : shard-manager-config32
06:05:33,397 PM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - shard-manager-config32: Creating local shard: member-1-shard-default-config32
06:05:33,506 PM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1
06:05:33,506 PM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - Creating Shard member-1-shard-default-config32
06:05:33,506 PM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - shard-manager-config32: Initializing shard [default]
06:05:33,506 PM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardInformation - Shard member-1-shard-default-config32 is initialized
06:05:33,506 PM [test-akka.actor.default-dispatcher-5] [INFO] ShardManager - shard-manager-config32: Received MemberUp: memberName: MemberName{name=leader-member}, address: akka://test
06:05:33,506 PM [test-akka.actor.default-dispatcher-5] [INFO] ShardInformation - updatePeerAddress for peer leader-member-shard-default-config32 with address akka://test/user/shardmanager-config32/leader-member-shard-default-config32
06:05:33,506 PM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardInformation - Sending PeerAddressResolved for peer leader-member-shard-default-config32 with address akka://test/user/shardmanager-config32/leader-member-shard-default-config32 to akka://test/user/member-1-shard-default-config
06:05:33,506 PM [test-akka.actor.default-dispatcher-5] [INFO] ShardManager - shard-manager-config32: Received role changed for member-1-shard-default-config32 from Candidate to Follower
06:05:33,506 PM [test-akka.actor.default-dispatcher-5] [INFO] ShardManager - shard-manager-config32: Received LeaderStateChanged message: LeaderStateChanged [memberId=member-1-shard-default-config32, leaderId=leader-member-shard-default-config32, leaderPayloadVersion=13]
06:05:33,506 PM [test-akka.actor.default-dispatcher-5] [INFO] ShardManager - shard-manager-config32: All Shards are ready - data store config32 is ready
06:05:33,507 PM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - shard-manager-config32: onAddShardReplica: AddShardReplica[ShardName=default]
06:05:33,507 PM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - shard-manager-config32: In findPrimary: org.opendaylight.controller.cluster.datastore.messages.FindPrimary [shardName=default, waitUntilReady=true]
06:05:33,507 PM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - shard-manager-config32: Found primary for default: RemotePrimaryShardFound [primaryPath=akka://test/user/shardmanager-config32/leader-member-shard-default-config32, primaryVersion=13]
06:05:33,507 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config32: Sending AddServer message to peer akka://test/user/shardmanager-config32/leader-member-shard-default-config32 for shard member-1-shard-default-config32
06:05:33,508 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config32: Received AddServerReply{status=ALREADY_EXISTS} for shard default from leader akka://test/user/shardmanager-config32/leader-member-shard-default-config32
06:05:33,508 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config32: Local shard default already exists
06:05:33,557 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config32: findLocalShard : default
06:05:33,557 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config32: onAddShardReplica: AddShardReplica[ShardName=default]
06:05:33,557 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config32: In findPrimary: org.opendaylight.controller.cluster.datastore.messages.FindPrimary [shardName=default, waitUntilReady=true]
06:05:33,557 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config32: Found primary for default: RemotePrimaryShardFound [primaryPath=akka://test/user/shardmanager-config32/leader-member-shard-default-config32, primaryVersion=13]
06:05:33,557 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config32: Sending AddServer message to peer akka://test/user/shardmanager-config32/leader-member-shard-default-config32 for shard member-1-shard-default-config32
06:05:33,558 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config32: Received AddServerReply{status=ALREADY_EXISTS} for shard default from leader akka://test/user/shardmanager-config32/leader-member-shard-default-config32
06:05:33,558 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config32: Local shard default already exists
06:05:33,558 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardInformation - Sending new DatastoreContext to member-1-shard-default-config32
06:05:33,558 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config32: onAddShardReplica: AddShardReplica[ShardName=default]
06:05:33,559 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config32: In findPrimary: org.opendaylight.controller.cluster.datastore.messages.FindPrimary [shardName=default, waitUntilReady=true]
06:05:33,559 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config32: Found primary for default: RemotePrimaryShardFound [primaryPath=akka://test/user/shardmanager-config32/leader-member-shard-default-config32, primaryVersion=13]
06:05:33,559 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config32: Sending AddServer message to peer akka://test/user/shardmanager-config32/leader-member-shard-default-config32 for shard member-1-shard-default-config32
06:05:33,674 PM [test-akka.actor.default-dispatcher-15] [DEBUG] ShardManager - shard-manager-config32: AddServer request to akka://test/user/shardmanager-config32/leader-member-shard-default-config32 for default failed
akka.pattern.AskTimeoutException: Ask timed out on [ActorSelection[Anchor(akka://test/), Path(/user/shardmanager-config32/leader-member-shard-default-config32)]] after [100 ms]. Message of type [org.opendaylight.controller.cluster.raft.messages.AddServer]. A typical reason for `AskTimeoutException` is that the recipient actor didn't send a reply.
06:05:33,675 PM [test-akka.actor.default-dispatcher-15] [DEBUG] ShardManager - shard-manager-config32: findLocalShard : default
06:05:33,675 PM [main] [INFO] ShardManagerTest - testAddShardReplicaWithPreExistingReplicaInRemoteShardLeader ending
06:05:33,776 PM [main] [INFO] TestActorFactory - Killing actor TestActor[akka://test/user/shardmanager-config32]
06:05:33,787 PM [test-akka.actor.default-dispatcher-15] [INFO] ShardManager - Stopping ShardManager shard-manager-config32
06:05:33,789 PM [main] [INFO] ShardManagerTest - testOnReceiveFindPrimaryForRemoteShard starting
06:05:33,797 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] Slf4jLogger - Slf4jLogger started
06:05:33,802 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] ArteryTransport - Remoting started with transport [Artery tcp]; listening on address [akka://cluster-test@127.0.0.1:2558] with UID [-5084670817198374365]
06:05:33,803 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2558] - Starting up, Akka version [2.6.21] ...
06:05:33,806 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2558] - Registered cluster JMX MBean [akka:type=Cluster]
06:05:33,806 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2558] - Started up successfully
06:05:33,807 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2558] - No downing-provider-class configured, manual cluster downing required, see https://doc.akka.io/docs/akka/current/typed/cluster.html#downing
06:05:33,807 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2558] - No seed-nodes configured, manual cluster join required, see https://doc.akka.io/docs/akka/current/typed/cluster.html#joining
06:05:33,823 PM [cluster-test-akka.actor.default-dispatcher-10] [INFO] ShardManager - Starting ShardManager shard-manager-config33
06:05:33,826 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] EmptyLocalActorRef - Message [org.opendaylight.controller.cluster.common.actor.Monitor] from TestActor[akka://cluster-test/user/shardmanager-config33] to Actor[akka://cluster-test/user/termination-monitor] was not delivered. [1] dead letters encountered. If this is not an expected behavior then Actor[akka://cluster-test/user/termination-monitor] may have terminated unexpectedly. This logging can be turned off or adjusted with configuration settings 'akka.log-dead-letters' and 'akka.log-dead-letters-during-shutdown'.
06:05:33,826 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2558] - Node [akka://cluster-test@127.0.0.1:2558] is JOINING itself (with roles [member-1, dc-default], version [0.0.0]) and forming new cluster
06:05:33,826 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2558] - is the new leader among reachable nodes (more leaders may exist)
06:05:33,827 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2558] - Leader is moving node [akka://cluster-test@127.0.0.1:2558] to [Up]
06:05:33,830 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] Slf4jLogger - Slf4jLogger started
06:05:33,836 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] ShardManager - Recovery complete : shard-manager-config33
06:05:33,836 PM [cluster-test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - shard-manager-config33: Creating local shard: member-1-shard-default-config33
06:05:33,837 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] ShardManager - shard-manager-config33: Received MemberUp: memberName: MemberName{name=member-1}, address: akka://cluster-test@127.0.0.1:2558
06:05:33,837 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] ShardInformation - updatePeerAddress for peer member-1-shard-default-config33 with address akka://cluster-test@127.0.0.1:2558/user/shardmanager-config33/member-1-shard-default-config33
06:05:33,840 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] ArteryTransport - Remoting started with transport [Artery tcp]; listening on address [akka://cluster-test@127.0.0.1:2559] with UID [8883331404392572611]
06:05:33,840 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2559] - Starting up, Akka version [2.6.21] ...
06:05:33,845 PM [cluster-test-akka.actor.default-dispatcher-10] [WARN] Cluster - Could not register Cluster JMX MBean with name=akka:type=Cluster as it is already registered. If you are running multiple clusters in the same JVM, set 'akka.cluster.jmx.multi-mbeans-in-same-jvm = on' in config
06:05:33,845 PM [cluster-test-akka.actor.default-dispatcher-10] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2559] - Started up successfully
06:05:33,845 PM [cluster-test-akka.actor.default-dispatcher-10] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2559] - No downing-provider-class configured, manual cluster downing required, see https://doc.akka.io/docs/akka/current/typed/cluster.html#downing
06:05:33,845 PM [cluster-test-akka.actor.default-dispatcher-10] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2559] - No seed-nodes configured, manual cluster join required, see https://doc.akka.io/docs/akka/current/typed/cluster.html#joining
06:05:33,855 PM [cluster-test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1
06:05:33,855 PM [cluster-test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - Creating Shard member-1-shard-default-config33
06:05:33,855 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] ShardInformation - updatePeerAddress for peer member-1-shard-default-config33 with address akka://cluster-test@127.0.0.1:2558/user/shardmanager-config33/member-1-shard-default-config33
06:05:33,855 PM [cluster-test-akka.actor.default-dispatcher-5] [DEBUG] ShardInformation - Sending PeerAddressResolved for peer member-1-shard-default-config33 with address akka://cluster-test@127.0.0.1:2558/user/shardmanager-config33/member-1-shard-default-config33 to akka://test/user/member-1-shard-default-config
06:05:33,855 PM [cluster-test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - shard-manager-config33: updated peer member-1-shard-default-config33 on member MemberName{name=member-1} with address akka://cluster-test@127.0.0.1:2558/user/shardmanager-config33/member-1-shard-default-config33 on shard member-1-shard-default-config33 whose actor address is Actor[akka://test/user/member-1-shard-default-config#-107001573]
06:05:33,860 PM [cluster-test-akka.actor.default-dispatcher-10] [INFO] ShardManager - Starting ShardManager shard-manager-config33
06:05:33,860 PM [cluster-test-akka.actor.default-dispatcher-10] [INFO] EmptyLocalActorRef - Message [org.opendaylight.controller.cluster.common.actor.Monitor] from TestActor[akka://cluster-test/user/shardmanager-config33] to Actor[akka://cluster-test/user/termination-monitor] was not delivered. [1] dead letters encountered. If this is not an expected behavior then Actor[akka://cluster-test/user/termination-monitor] may have terminated unexpectedly. This logging can be turned off or adjusted with configuration settings 'akka.log-dead-letters' and 'akka.log-dead-letters-during-shutdown'.
06:05:33,865 PM [cluster-test-akka.actor.default-dispatcher-10] [INFO] ShardManager - Recovery complete : shard-manager-config33
06:05:33,865 PM [cluster-test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config33: Creating local shard: member-2-shard-default-config33
06:05:33,865 PM [cluster-test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config33: Creating local shard: member-2-shard-astronauts-config33
06:05:33,865 PM [cluster-test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1
06:05:33,865 PM [cluster-test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - Creating Shard member-2-shard-default-config33
06:05:33,865 PM [cluster-test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - Creating Shard member-2-shard-astronauts-config33
06:05:33,866 PM [cluster-test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config33: Initializing shard [astronauts]
06:05:33,866 PM [cluster-test-akka.actor.default-dispatcher-10] [DEBUG] ShardInformation - Shard member-2-shard-astronauts-config33 is initialized
06:05:33,866 PM [cluster-test-akka.actor.default-dispatcher-10] [INFO] ShardManager - shard-manager-config33: Received LeaderStateChanged message: LeaderStateChanged [memberId=member-2-shard-astronauts-config33, leaderId=member-2-shard-astronauts-config33, leaderPayloadVersion=12]
06:05:33,866 PM [cluster-test-akka.actor.default-dispatcher-10] [INFO] ShardManager - shard-manager-config33: Received role changed for member-2-shard-astronauts-config33 from Candidate to Leader
06:05:33,900 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2558] - Node [akka://cluster-test@127.0.0.1:2559] is JOINING, roles [member-2, dc-default], version [0.0.0]
06:05:33,905 PM [cluster-test-akka.actor.default-dispatcher-14] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2559] - Welcome from [akka://cluster-test@127.0.0.1:2558]
06:05:33,905 PM [cluster-test-akka.actor.default-dispatcher-14] [INFO] ShardManager - shard-manager-config33: Received MemberUp: memberName: MemberName{name=member-1}, address: akka://cluster-test@127.0.0.1:2558
06:05:33,905 PM [cluster-test-akka.actor.default-dispatcher-14] [INFO] ShardInformation - updatePeerAddress for peer member-1-shard-default-config33 with address akka://cluster-test@127.0.0.1:2558/user/shardmanager-config33/member-1-shard-default-config33
06:05:33,905 PM [cluster-test-akka.actor.default-dispatcher-14] [DEBUG] ShardInformation - Sending PeerAddressResolved for peer member-1-shard-default-config33 with address akka://cluster-test@127.0.0.1:2558/user/shardmanager-config33/member-1-shard-default-config33 to akka://cluster-test/user/member-2-shard-astronauts-config
06:05:33,905 PM [cluster-test-akka.actor.default-dispatcher-14] [INFO] ShardInformation - updatePeerAddress for peer member-1-shard-astronauts-config33 with address akka://cluster-test@127.0.0.1:2558/user/shardmanager-config33/member-1-shard-astronauts-config33
06:05:33,905 PM [cluster-test-akka.actor.default-dispatcher-14] [DEBUG] ShardInformation - Sending PeerAddressResolved for peer member-1-shard-astronauts-config33 with address akka://cluster-test@127.0.0.1:2558/user/shardmanager-config33/member-1-shard-astronauts-config33 to akka://cluster-test/user/member-2-shard-astronauts-config
06:05:34,826 PM [cluster-test-akka.actor.default-dispatcher-11] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2558] - Leader is moving node [akka://cluster-test@127.0.0.1:2559] to [Up]
06:05:34,826 PM [cluster-test-akka.actor.default-dispatcher-11] [INFO] ShardManager - shard-manager-config33: Received MemberUp: memberName: MemberName{name=member-2}, address: akka://cluster-test@127.0.0.1:2559
06:05:34,826 PM [cluster-test-akka.actor.default-dispatcher-11] [INFO] ShardInformation - updatePeerAddress for peer member-2-shard-default-config33 with address akka://cluster-test@127.0.0.1:2559/user/shardmanager-config33/member-2-shard-default-config33
06:05:34,826 PM [cluster-test-akka.actor.default-dispatcher-11] [DEBUG] ShardInformation - Sending PeerAddressResolved for peer member-2-shard-default-config33 with address akka://cluster-test@127.0.0.1:2559/user/shardmanager-config33/member-2-shard-default-config33 to akka://test/user/member-1-shard-default-config
06:05:34,826 PM [cluster-test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - shard-manager-config33: In findPrimary: org.opendaylight.controller.cluster.datastore.messages.FindPrimary [shardName=astronauts, waitUntilReady=false]
06:05:34,827 PM [cluster-test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - shard-manager-config33: findPrimary for astronauts forwarding to remote ShardManager akka://cluster-test@127.0.0.1:2559/user/shardmanager-config33, visitedAddresses: [akka://cluster-test@127.0.0.1:2558/user/shardmanager-config33]
06:05:34,835 PM [cluster-test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - shard-manager-config33: In findPrimary: org.opendaylight.controller.cluster.datastore.messages.RemoteFindPrimary [shardName=astronauts, waitUntilReady=false]
06:05:34,835 PM [cluster-test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - shard-manager-config33: Found primary for astronauts: RemotePrimaryShardFound [primaryPath=akka://cluster-test@127.0.0.1:2559/user/member-2-shard-astronauts-config#44452128, primaryVersion=12]
06:05:34,839 PM [main] [INFO] ShardManagerTest - testOnReceiveFindPrimaryForRemoteShard ending
06:05:34,863 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] ShardManager - shard-manager-config33: Received MemberUp: memberName: MemberName{name=member-2}, address: akka://cluster-test@127.0.0.1:2559
06:05:34,863 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] ShardInformation - updatePeerAddress for peer member-2-shard-default-config33 with address akka://cluster-test@127.0.0.1:2559/user/shardmanager-config33/member-2-shard-default-config33
06:05:34,863 PM [cluster-test-akka.actor.default-dispatcher-5] [DEBUG] ShardInformation - Sending PeerAddressResolved for peer member-2-shard-default-config33 with address akka://cluster-test@127.0.0.1:2559/user/shardmanager-config33/member-2-shard-default-config33 to akka://cluster-test/user/member-2-shard-astronauts-config
06:05:34,863 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] ShardInformation - updatePeerAddress for peer member-2-shard-astronauts-config33 with address akka://cluster-test@127.0.0.1:2559/user/shardmanager-config33/member-2-shard-astronauts-config33
06:05:34,863 PM [cluster-test-akka.actor.default-dispatcher-5] [DEBUG] ShardInformation - Sending PeerAddressResolved for peer member-2-shard-astronauts-config33 with address akka://cluster-test@127.0.0.1:2559/user/shardmanager-config33/member-2-shard-astronauts-config33 to akka://cluster-test/user/member-2-shard-astronauts-config
06:05:34,941 PM [cluster-test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Stopping ShardManager shard-manager-config33
06:05:34,941 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] RemoteActorRefProvider$RemotingTerminator - Shutting down remote daemon.
06:05:34,941 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] RemoteActorRefProvider$RemotingTerminator - Remote daemon shut down; proceeding with flushing remote transports.
06:05:34,952 PM [cluster-test-akka.actor.default-dispatcher-5] [WARN] Materializer - [outbound connection to [akka://cluster-test@127.0.0.1:2559], control stream] Upstream failed, cause: StreamTcpException: The connection has been aborted
06:05:34,952 PM [cluster-test-akka.actor.default-dispatcher-5] [WARN] Materializer - [outbound connection to [akka://cluster-test@127.0.0.1:2559], message stream] Upstream failed, cause: StreamTcpException: The connection has been aborted
06:05:34,955 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] RemoteActorRefProvider$RemotingTerminator - Remoting shut down.
06:05:34,965 PM [cluster-test-akka.actor.default-dispatcher-14] [INFO] ShardManager - Stopping ShardManager shard-manager-config33
06:05:34,966 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] RemoteActorRefProvider$RemotingTerminator - Shutting down remote daemon.
06:05:34,966 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] RemoteActorRefProvider$RemotingTerminator - Remote daemon shut down; proceeding with flushing remote transports.
06:05:35,984 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] RemoteActorRefProvider$RemotingTerminator - Remoting shut down.
[WARN] [01/08/2024 18:05:35.986] [cluster-test-akka.actor.internal-dispatcher-3] [Cluster(akka://cluster-test)] Could not unregister Cluster JMX MBean with name=akka:type=Cluster as it was not found. If you are running multiple clusters in the same JVM, set 'akka.cluster.jmx.multi-mbeans-in-same-jvm = on' in config
06:05:35,998 PM [test-akka.actor.default-dispatcher-5] [INFO] ShardManager - Starting ShardManager shard-manager-config34
06:05:35,999 PM [test-akka.actor.default-dispatcher-5] [INFO] ShardManager - Recovery complete : shard-manager-config34
06:05:35,999 PM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - shard-manager-config34: Creating local shard: member-1-shard-default-config34
06:05:36,9 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config34: findLocalShard : default
06:05:36,9 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config34: Returning NotInitializedException for shard default
06:05:36,110 PM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/$r#-1091178578]
06:05:36,120 PM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - Stopping ShardManager shard-manager-config34
06:05:36,126 PM [test-akka.actor.default-dispatcher-15] [INFO] ShardManager - Starting ShardManager shard-manager-config35
06:05:36,132 PM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - Recovery complete : shard-manager-config35
06:05:36,132 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config35: Creating local shard: member-1-shard-default-config35
06:05:36,134 PM [test-akka.actor.default-dispatcher-15] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1
06:05:36,134 PM [test-akka.actor.default-dispatcher-15] [DEBUG] ShardManager - Creating Shard member-1-shard-default-config35
06:05:36,134 PM [test-akka.actor.default-dispatcher-15] [DEBUG] ShardManager - shard-manager-config35: Initializing shard [default]
06:05:36,134 PM [test-akka.actor.default-dispatcher-15] [DEBUG] ShardInformation - Shard member-1-shard-default-config35 is initialized
06:05:36,134 PM [test-akka.actor.default-dispatcher-15] [INFO] ShardManager - shard-manager-config35: Received LeaderStateChanged message: LeaderStateChanged [memberId=member-1-shard-default-config35, leaderId=member-1-shard-default-config35, leaderPayloadVersion=13]
06:05:36,134 PM [test-akka.actor.default-dispatcher-15] [INFO] ShardManager - shard-manager-config35: Received role changed for member-1-shard-default-config35 from Candidate to Leader
06:05:36,134 PM [test-akka.actor.default-dispatcher-15] [INFO] ShardManager - shard-manager-config35: All Shards are ready - data store config35 is ready
06:05:36,135 PM [test-akka.actor.default-dispatcher-15] [DEBUG] ShardManager - shard-manager-config35: onChangeShardServersVotingStatus: ChangeShardMembersVotingStatus [shardName=default, meberVotingStatusMap={member-2=true}]
06:05:36,135 PM [test-akka.actor.default-dispatcher-15] [DEBUG] ShardManager - shard-manager-config35: findLocalShard : default
06:05:36,135 PM [test-akka.actor.default-dispatcher-15] [DEBUG] ShardManager - shard-manager-config35: Sending ChangeServersVotingStatus message ChangeServersVotingStatus [serverVotingStatusMap={member-2-shard-default-config35=true}, serversVisited=[]] to local shard akka://test/user/member-1-shard-default-config35
06:05:36,135 PM [test-akka.actor.default-dispatcher-15] [DEBUG] ShardManager - shard-manager-config35: Received ServerChangeReply{status=OK} from local shard akka://test/user/member-1-shard-default-config35
06:05:36,135 PM [test-akka.actor.default-dispatcher-15] [DEBUG] ShardManager - shard-manager-config35: ChangeServersVotingStatus succeeded for shard default
06:05:36,286 PM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/member-1-shard-default-config35#-1438183075]
06:05:36,299 PM [main] [INFO] ShardManagerTest - testShutDown starting
06:05:36,304 PM [test-akka.actor.default-dispatcher-15] [INFO] ShardManager - Starting ShardManager shard-manager-config36
06:05:36,305 PM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - Recovery complete : shard-manager-config36
06:05:36,305 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config36: Creating local shard: member-1-shard-shard2-config36
06:05:36,305 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config36: Creating local shard: member-1-shard-shard1-config36
06:05:36,315 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1
06:05:36,315 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - Creating Shard member-1-shard-shard2-config36
06:05:36,315 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - Creating Shard member-1-shard-shard1-config36
06:05:36,315 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config36: Initializing shard [shard1]
06:05:36,315 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardInformation - Shard member-1-shard-shard1-config36 is initialized
06:05:36,315 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config36: Initializing shard [shard2]
06:05:36,315 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardInformation - Shard member-1-shard-shard2-config36 is initialized
06:05:36,316 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config36: Issuing gracefulStop to shard member-1-shard-shard2-config36
06:05:36,316 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config36: Issuing gracefulStop to shard member-1-shard-shard1-config36
06:05:36,316 PM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - Shutting down ShardManager shard-manager-config36 - waiting on 2 shards
06:05:36,867 PM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/member-1-shard-shard1-config36#911511174]
06:05:36,867 PM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/member-1-shard-shard2-config36#1123985935]
06:05:36,868 PM [test-akka.actor.default-dispatcher-15] [DEBUG] ShardManager - shard-manager-config36: All shards shutdown - sending PoisonPill to self
06:05:36,868 PM [test-akka.actor.default-dispatcher-15] [INFO] ShardManager - Stopping ShardManager shard-manager-config36
06:05:36,869 PM [main] [INFO] ShardManagerTest - testShutDown ending
06:05:36,970 PM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/$t#-882386380]
06:05:36,982 PM [main] [INFO] ShardManagerTest - testOnReceiveFindPrimaryForNonLocalLeaderShardBeforeMemberUp starting
06:05:36,985 PM [test-akka.actor.default-dispatcher-15] [INFO] ShardManager - Starting ShardManager shard-manager-config37
06:05:36,986 PM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - Recovery complete : shard-manager-config37
06:05:36,986 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config37: Creating local shard: member-1-shard-default-config37
06:05:36,995 PM [test-akka.actor.default-dispatcher-15] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1
06:05:36,995 PM [test-akka.actor.default-dispatcher-15] [DEBUG] ShardManager - Creating Shard member-1-shard-default-config37
06:05:36,996 PM [test-akka.actor.default-dispatcher-15] [DEBUG] ShardManager - shard-manager-config37: Initializing shard [default]
06:05:36,996 PM [test-akka.actor.default-dispatcher-15] [DEBUG] ShardInformation - Shard member-1-shard-default-config37 is initialized
06:05:36,996 PM [test-akka.actor.default-dispatcher-15] [INFO] ShardManager - shard-manager-config37: Received role changed for member-1-shard-default-config37 from Candidate to Follower
06:05:36,996 PM [test-akka.actor.default-dispatcher-15] [DEBUG] ShardManagerTest$TestShardManager - Received unhandled message LeaderStateChanged [memberId=member-1-shard-default-config37, leaderId=member-2-shard-default-config37, leaderPayloadVersion=13]
06:05:36,998 PM [test-akka.actor.default-dispatcher-15] [DEBUG] ShardManager - shard-manager-config37: In findPrimary: org.opendaylight.controller.cluster.datastore.messages.FindPrimary [shardName=default, waitUntilReady=false]
06:05:36,998 PM [test-akka.actor.default-dispatcher-15] [DEBUG] ShardManager - shard-manager-config37: Returning NoShardLeaderException for shard default
06:05:36,998 PM [main] [INFO] ShardManagerTest - testOnReceiveFindPrimaryForNonLocalLeaderShardBeforeMemberUp ending
06:05:37,99 PM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/$u#-1425739326]
06:05:37,109 PM [test-akka.actor.default-dispatcher-15] [INFO] ShardManager - Stopping ShardManager shard-manager-config37
06:05:37,112 PM [main] [INFO] ShardManagerTest - testOnReceiveFindPrimaryWaitForReadyWithNoRoleShard starting
06:05:37,118 PM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - Starting ShardManager shard-manager-config38
06:05:37,119 PM [test-akka.actor.default-dispatcher-15] [INFO] ShardManager - Recovery complete : shard-manager-config38
06:05:37,120 PM [test-akka.actor.default-dispatcher-15] [DEBUG] ShardManager - shard-manager-config38: Creating local shard: member-1-shard-default-config38
06:05:37,129 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1
06:05:37,129 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - Creating Shard member-1-shard-default-config38
06:05:37,129 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config38: Initializing shard [default]
06:05:37,129 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardInformation - Shard member-1-shard-default-config38 is initialized
06:05:37,129 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config38: In findPrimary: org.opendaylight.controller.cluster.datastore.messages.FindPrimary [shardName=default, waitUntilReady=true]
06:05:37,129 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config38: Scheduling 1200 ms timer to wait for shard ShardInformation [shardId=member-1-shard-default-config38, leaderAvailable=false, actorInitialized=true, followerSyncStatus=false, role=null, leaderId=null, activeMember=true]
06:05:38,343 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config38: Received ShardNotInitializedTimeout message for shard default
06:05:38,343 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config38: Returning NoShardLeaderException for shard default
06:05:38,344 PM [main] [INFO] ShardManagerTest - testOnReceiveFindPrimaryWaitForReadyWithNoRoleShard ending
06:05:38,445 PM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/$v#543792405]
06:05:38,456 PM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - Stopping ShardManager shard-manager-config38
06:05:38,458 PM [main] [INFO] ShardManagerTest - testShardPersistenceWithRestoredData starting
06:05:38,461 PM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - Starting ShardManager shard-manager-config39
06:05:38,463 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config39: onSnapshotOffer: ShardManagerSnapshot [ShardList = [default, astronauts] ]
06:05:38,463 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config39: adding shard astronauts
06:05:38,463 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config39: removing shard people
06:05:38,464 PM [test-akka.actor.default-dispatcher-15] [INFO] ShardManager - Recovery complete : shard-manager-config39
06:05:38,464 PM [test-akka.actor.default-dispatcher-15] [DEBUG] ShardManager - shard-manager-config39: Creating local shard: member-1-shard-default-config39
06:05:38,464 PM [test-akka.actor.default-dispatcher-15] [DEBUG] ShardManager - shard-manager-config39: Creating local shard: member-1-shard-astronauts-config39
06:05:38,571 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config39: findLocalShard : people
06:05:38,572 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config39: Local shard people not found - shards present: [default, astronauts]
06:05:38,572 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config39: findLocalShard : default
06:05:38,572 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config39: Returning NotInitializedException for shard default
06:05:38,572 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config39: findLocalShard : astronauts
06:05:38,572 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config39: Returning NotInitializedException for shard astronauts
06:05:38,572 PM [main] [INFO] ShardManagerTest - testShardPersistenceWithRestoredData ending
06:05:38,673 PM [main] [INFO] TestActorFactory - Killing actor TestActor[akka://test/user/$$i]
06:05:38,684 PM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - Stopping ShardManager shard-manager-config39
06:05:38,686 PM [main] [INFO] ShardManagerTest - testOnReceiveFindPrimaryForNonLocalLeaderShard starting
06:05:38,688 PM [test-akka.actor.default-dispatcher-15] [INFO] ShardManager - Starting ShardManager shard-manager-config40
06:05:38,690 PM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - Recovery complete : shard-manager-config40
06:05:38,690 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config40: Creating local shard: member-1-shard-default-config40
06:05:38,699 PM [test-akka.actor.default-dispatcher-15] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1
06:05:38,699 PM [test-akka.actor.default-dispatcher-15] [DEBUG] ShardManager - Creating Shard member-1-shard-default-config40
06:05:38,699 PM [test-akka.actor.default-dispatcher-15] [DEBUG] ShardManager - shard-manager-config40: Initializing shard [default]
06:05:38,699 PM [test-akka.actor.default-dispatcher-15] [DEBUG] ShardInformation - Shard member-1-shard-default-config40 is initialized
06:05:38,699 PM [test-akka.actor.default-dispatcher-15] [INFO] ShardManager - shard-manager-config40: Received MemberUp: memberName: MemberName{name=member-2}, address: akka://test
06:05:38,699 PM [test-akka.actor.default-dispatcher-15] [INFO] ShardInformation - updatePeerAddress for peer member-2-shard-default-config40 with address akka://test/user/shardmanager-config40/member-2-shard-default-config40
06:05:38,699 PM [test-akka.actor.default-dispatcher-15] [DEBUG] ShardInformation - Sending PeerAddressResolved for peer member-2-shard-default-config40 with address akka://test/user/shardmanager-config40/member-2-shard-default-config40 to akka://test/user/member-1-shard-default-config
06:05:38,699 PM [test-akka.actor.default-dispatcher-15] [INFO] ShardManager - shard-manager-config40: Received role changed for member-1-shard-default-config40 from Candidate to Follower
06:05:38,699 PM [test-akka.actor.default-dispatcher-15] [INFO] ShardManager - shard-manager-config40: Received LeaderStateChanged message: LeaderStateChanged [memberId=member-1-shard-default-config40, leaderId=member-2-shard-default-config40, leaderPayloadVersion=12]
06:05:38,699 PM [test-akka.actor.default-dispatcher-15] [INFO] ShardManager - shard-manager-config40: All Shards are ready - data store config40 is ready
06:05:38,700 PM [test-akka.actor.default-dispatcher-15] [DEBUG] ShardManager - shard-manager-config40: In findPrimary: org.opendaylight.controller.cluster.datastore.messages.FindPrimary [shardName=default, waitUntilReady=false]
06:05:38,700 PM [test-akka.actor.default-dispatcher-15] [DEBUG] ShardManager - shard-manager-config40: Found primary for default: RemotePrimaryShardFound [primaryPath=akka://test/user/shardmanager-config40/member-2-shard-default-config40, primaryVersion=12]
06:05:38,700 PM [main] [INFO] ShardManagerTest - testOnReceiveFindPrimaryForNonLocalLeaderShard ending
06:05:38,801 PM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/$w#177565548]
06:05:38,812 PM [test-akka.actor.default-dispatcher-15] [INFO] ShardManager - Stopping ShardManager shard-manager-config40
06:05:38,814 PM [main] [INFO] ShardManagerTest - testShardAvailabilityOnChangeOfMemberReachability starting
06:05:38,820 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] Slf4jLogger - Slf4jLogger started
06:05:38,829 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] ArteryTransport - Remoting started with transport [Artery tcp]; listening on address [akka://cluster-test@127.0.0.1:2558] with UID [-4008573923748772659]
06:05:38,829 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2558] - Starting up, Akka version [2.6.21] ...
06:05:38,836 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2558] - Registered cluster JMX MBean [akka:type=Cluster]
06:05:38,836 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2558] - Started up successfully
06:05:38,841 PM [cluster-test-akka.actor.default-dispatcher-11] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2558] - No downing-provider-class configured, manual cluster downing required, see https://doc.akka.io/docs/akka/current/typed/cluster.html#downing
06:05:38,841 PM [cluster-test-akka.actor.default-dispatcher-11] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2558] - No seed-nodes configured, manual cluster join required, see https://doc.akka.io/docs/akka/current/typed/cluster.html#joining
06:05:38,844 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2558] - Node [akka://cluster-test@127.0.0.1:2558] is JOINING itself (with roles [member-1, dc-default], version [0.0.0]) and forming new cluster
06:05:38,844 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2558] - is the new leader among reachable nodes (more leaders may exist)
06:05:38,844 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2558] - Leader is moving node [akka://cluster-test@127.0.0.1:2558] to [Up]
06:05:38,846 PM [cluster-test-akka.actor.default-dispatcher-11] [INFO] EmptyLocalActorRef - Message [org.opendaylight.controller.cluster.common.actor.Monitor] from TestActor[akka://cluster-test/user/shardmanager-config41] to Actor[akka://cluster-test/user/termination-monitor] was not delivered. [1] dead letters encountered. If this is not an expected behavior then Actor[akka://cluster-test/user/termination-monitor] may have terminated unexpectedly. This logging can be turned off or adjusted with configuration settings 'akka.log-dead-letters' and 'akka.log-dead-letters-during-shutdown'.
06:05:38,847 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] ShardManager - Starting ShardManager shard-manager-config41
06:05:38,852 PM [cluster-test-akka.actor.default-dispatcher-6] [INFO] Slf4jLogger - Slf4jLogger started
06:05:38,857 PM [cluster-test-akka.actor.default-dispatcher-13] [INFO] ShardManager - Recovery complete : shard-manager-config41
06:05:38,857 PM [cluster-test-akka.actor.default-dispatcher-13] [DEBUG] ShardManager - shard-manager-config41: Creating local shard: member-1-shard-default-config41
06:05:38,858 PM [cluster-test-akka.actor.default-dispatcher-13] [INFO] ShardManager - shard-manager-config41: Received MemberUp: memberName: MemberName{name=member-1}, address: akka://cluster-test@127.0.0.1:2558
06:05:38,858 PM [cluster-test-akka.actor.default-dispatcher-13] [INFO] ShardInformation - updatePeerAddress for peer member-1-shard-default-config41 with address akka://cluster-test@127.0.0.1:2558/user/shardmanager-config41/member-1-shard-default-config41
06:05:38,861 PM [cluster-test-akka.actor.default-dispatcher-6] [INFO] ArteryTransport - Remoting started with transport [Artery tcp]; listening on address [akka://cluster-test@127.0.0.1:2559] with UID [1328860706870546573]
06:05:38,862 PM [cluster-test-akka.actor.default-dispatcher-6] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2559] - Starting up, Akka version [2.6.21] ...
06:05:38,863 PM [cluster-test-akka.actor.default-dispatcher-6] [WARN] Cluster - Could not register Cluster JMX MBean with name=akka:type=Cluster as it is already registered. If you are running multiple clusters in the same JVM, set 'akka.cluster.jmx.multi-mbeans-in-same-jvm = on' in config
06:05:38,863 PM [cluster-test-akka.actor.default-dispatcher-6] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2559] - Started up successfully
06:05:38,866 PM [cluster-test-akka.actor.default-dispatcher-6] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2559] - No downing-provider-class configured, manual cluster downing required, see https://doc.akka.io/docs/akka/current/typed/cluster.html#downing
06:05:38,866 PM [cluster-test-akka.actor.default-dispatcher-6] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2559] - No seed-nodes configured, manual cluster join required, see https://doc.akka.io/docs/akka/current/typed/cluster.html#joining
06:05:38,883 PM [cluster-test-akka.actor.default-dispatcher-11] [INFO] EmptyLocalActorRef - Message [org.opendaylight.controller.cluster.common.actor.Monitor] from TestActor[akka://cluster-test/user/shardmanager-config41] to Actor[akka://cluster-test/user/termination-monitor] was not delivered. [1] dead letters encountered. If this is not an expected behavior then Actor[akka://cluster-test/user/termination-monitor] may have terminated unexpectedly. This logging can be turned off or adjusted with configuration settings 'akka.log-dead-letters' and 'akka.log-dead-letters-during-shutdown'.
06:05:38,886 PM [cluster-test-akka.actor.default-dispatcher-6] [INFO] ShardManager - Starting ShardManager shard-manager-config41
06:05:38,893 PM [cluster-test-akka.actor.default-dispatcher-13] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1
06:05:38,893 PM [cluster-test-akka.actor.default-dispatcher-13] [DEBUG] ShardManager - Creating Shard member-1-shard-default-config41
06:05:38,893 PM [cluster-test-akka.actor.default-dispatcher-13] [INFO] ShardInformation - updatePeerAddress for peer member-1-shard-default-config41 with address akka://cluster-test@127.0.0.1:2558/user/shardmanager-config41/member-1-shard-default-config41
06:05:38,893 PM [cluster-test-akka.actor.default-dispatcher-13] [DEBUG] ShardInformation - Sending PeerAddressResolved for peer member-1-shard-default-config41 with address akka://cluster-test@127.0.0.1:2558/user/shardmanager-config41/member-1-shard-default-config41 to akka://cluster-test/user/member-1-shard-default-config
06:05:38,893 PM [cluster-test-akka.actor.default-dispatcher-13] [DEBUG] ShardManager - shard-manager-config41: updated peer member-1-shard-default-config41 on member MemberName{name=member-1} with address akka://cluster-test@127.0.0.1:2558/user/shardmanager-config41/member-1-shard-default-config41 on shard member-1-shard-default-config41 whose actor address is Actor[akka://cluster-test/user/member-1-shard-default-config#-221735037]
06:05:38,893 PM [cluster-test-akka.actor.default-dispatcher-13] [DEBUG] ShardManager - shard-manager-config41: Initializing shard [default]
06:05:38,893 PM [cluster-test-akka.actor.default-dispatcher-13] [DEBUG] ShardInformation - Shard member-1-shard-default-config41 is initialized
06:05:38,893 PM [cluster-test-akka.actor.default-dispatcher-13] [INFO] ShardManager - shard-manager-config41: Received LeaderStateChanged message: LeaderStateChanged [memberId=member-1-shard-default-config41, leaderId=member-2-shard-default-config41, leaderPayloadVersion=13]
06:05:38,893 PM [cluster-test-akka.actor.default-dispatcher-13] [INFO] ShardManager - shard-manager-config41: Received role changed for member-1-shard-default-config41 from Candidate to Follower
06:05:38,916 PM [cluster-test-akka.actor.default-dispatcher-10] [INFO] ShardManager - Recovery complete : shard-manager-config41
06:05:38,916 PM [cluster-test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config41: Creating local shard: member-2-shard-default-config41
06:05:38,917 PM [cluster-test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1
06:05:38,917 PM [cluster-test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - Creating Shard member-2-shard-default-config41
06:05:38,917 PM [cluster-test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config41: Initializing shard [default]
06:05:38,917 PM [cluster-test-akka.actor.default-dispatcher-10] [DEBUG] ShardInformation - Shard member-2-shard-default-config41 is initialized
06:05:38,917 PM [cluster-test-akka.actor.default-dispatcher-10] [INFO] ShardManager - shard-manager-config41: Received LeaderStateChanged message: LeaderStateChanged [memberId=member-2-shard-default-config41, leaderId=member-2-shard-default-config41, leaderPayloadVersion=13]
06:05:38,917 PM [cluster-test-akka.actor.default-dispatcher-10] [INFO] ShardManager - shard-manager-config41: Received role changed for member-2-shard-default-config41 from Candidate to Leader
06:05:38,917 PM [cluster-test-akka.actor.default-dispatcher-10] [INFO] ShardManager - shard-manager-config41: All Shards are ready - data store config41 is ready
06:05:38,942 PM [cluster-test-akka.actor.default-dispatcher-13] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2558] - Node [akka://cluster-test@127.0.0.1:2559] is JOINING, roles [member-2, dc-default], version [0.0.0]
06:05:38,948 PM [cluster-test-akka.actor.default-dispatcher-13] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2559] - Welcome from [akka://cluster-test@127.0.0.1:2558]
06:05:38,950 PM [cluster-test-akka.actor.default-dispatcher-13] [INFO] ShardManager - shard-manager-config41: Received MemberUp: memberName: MemberName{name=member-1}, address: akka://cluster-test@127.0.0.1:2558
06:05:38,950 PM [cluster-test-akka.actor.default-dispatcher-13] [INFO] ShardInformation - updatePeerAddress for peer member-1-shard-default-config41 with address akka://cluster-test@127.0.0.1:2558/user/shardmanager-config41/member-1-shard-default-config41
06:05:38,950 PM [cluster-test-akka.actor.default-dispatcher-13] [DEBUG] ShardInformation - Sending PeerAddressResolved for peer member-1-shard-default-config41 with address akka://cluster-test@127.0.0.1:2558/user/shardmanager-config41/member-1-shard-default-config41 to akka://cluster-test/user/member-2-shard-default-config
06:05:38,950 PM [cluster-test-akka.actor.default-dispatcher-13] [INFO] ShardManager - shard-manager-config41: All Shards are ready - data store config41 is ready
06:05:39,860 PM [cluster-test-akka.actor.default-dispatcher-12] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2558] - Leader is moving node [akka://cluster-test@127.0.0.1:2559] to [Up]
06:05:39,860 PM [cluster-test-akka.actor.default-dispatcher-13] [INFO] ShardManager - shard-manager-config41: Received MemberUp: memberName: MemberName{name=member-2}, address: akka://cluster-test@127.0.0.1:2559
06:05:39,860 PM [cluster-test-akka.actor.default-dispatcher-13] [INFO] ShardInformation - updatePeerAddress for peer member-2-shard-default-config41 with address akka://cluster-test@127.0.0.1:2559/user/shardmanager-config41/member-2-shard-default-config41
06:05:39,860 PM [cluster-test-akka.actor.default-dispatcher-13] [DEBUG] ShardInformation - Sending PeerAddressResolved for peer member-2-shard-default-config41 with address akka://cluster-test@127.0.0.1:2559/user/shardmanager-config41/member-2-shard-default-config41 to akka://cluster-test/user/member-1-shard-default-config
06:05:39,860 PM [cluster-test-akka.actor.default-dispatcher-13] [INFO] ShardManager - shard-manager-config41: All Shards are ready - data store config41 is ready
06:05:39,861 PM [cluster-test-akka.actor.default-dispatcher-12] [DEBUG] ShardManager - shard-manager-config41: In findPrimary: org.opendaylight.controller.cluster.datastore.messages.FindPrimary [shardName=default, waitUntilReady=true]
06:05:39,861 PM [cluster-test-akka.actor.default-dispatcher-12] [DEBUG] ShardManager - shard-manager-config41: Found primary for default: RemotePrimaryShardFound [primaryPath=akka://cluster-test@127.0.0.1:2559/user/shardmanager-config41/member-2-shard-default-config41, primaryVersion=13]
06:05:39,863 PM [cluster-test-akka.actor.default-dispatcher-12] [INFO] ShardManager - Received UnreachableMember: memberName MemberName{name=member-2}, address: akka://cluster-test@127.0.0.1:2558
06:05:39,863 PM [cluster-test-akka.actor.default-dispatcher-12] [DEBUG] ShardManager - Marking Leader member-2-shard-default-config41 as unavailable.
06:05:39,863 PM [cluster-test-akka.actor.default-dispatcher-12] [INFO] ShardManager - shard-manager-config41: Received MemberRemoved: memberName: MemberName{name=member-2}, address: akka://cluster-test@127.0.0.1:2558
06:05:39,864 PM [cluster-test-akka.actor.default-dispatcher-12] [DEBUG] ShardManager - shard-manager-config41: In findPrimary: org.opendaylight.controller.cluster.datastore.messages.FindPrimary [shardName=default, waitUntilReady=true]
06:05:39,864 PM [cluster-test-akka.actor.default-dispatcher-12] [DEBUG] ShardManager - shard-manager-config41: Scheduling 1200 ms timer to wait for shard ShardInformation [shardId=member-1-shard-default-config41, leaderAvailable=false, actorInitialized=true, followerSyncStatus=false, role=Follower, leaderId=member-2-shard-default-config41, activeMember=true]
06:05:39,883 PM [cluster-test-akka.actor.default-dispatcher-6] [INFO] ShardManager - shard-manager-config41: Received MemberUp: memberName: MemberName{name=member-2}, address: akka://cluster-test@127.0.0.1:2559
06:05:39,883 PM [cluster-test-akka.actor.default-dispatcher-6] [INFO] ShardInformation - updatePeerAddress for peer member-2-shard-default-config41 with address akka://cluster-test@127.0.0.1:2559/user/shardmanager-config41/member-2-shard-default-config41
06:05:39,883 PM [cluster-test-akka.actor.default-dispatcher-6] [DEBUG] ShardInformation - Sending PeerAddressResolved for peer member-2-shard-default-config41 with address akka://cluster-test@127.0.0.1:2559/user/shardmanager-config41/member-2-shard-default-config41 to akka://cluster-test/user/member-2-shard-default-config
06:05:39,883 PM [cluster-test-akka.actor.default-dispatcher-6] [INFO] ShardManager - shard-manager-config41: All Shards are ready - data store config41 is ready
06:05:41,77 PM [cluster-test-akka.actor.default-dispatcher-12] [DEBUG] ShardManager - shard-manager-config41: Received ShardNotInitializedTimeout message for shard default
06:05:41,77 PM [cluster-test-akka.actor.default-dispatcher-12] [DEBUG] ShardManager - shard-manager-config41: Returning NoShardLeaderException for shard default
06:05:41,79 PM [cluster-test-akka.actor.default-dispatcher-12] [INFO] ShardManager - Received ReachableMember: memberName MemberName{name=member-2}, address: akka://cluster-test@127.0.0.1:2558
06:05:41,79 PM [cluster-test-akka.actor.default-dispatcher-12] [INFO] ShardInformation - updatePeerAddress for peer member-2-shard-default-config41 with address akka://cluster-test@127.0.0.1:2558/user/shardmanager-config41/member-2-shard-default-config41
06:05:41,79 PM [cluster-test-akka.actor.default-dispatcher-12] [DEBUG] ShardInformation - Sending PeerAddressResolved for peer member-2-shard-default-config41 with address akka://cluster-test@127.0.0.1:2558/user/shardmanager-config41/member-2-shard-default-config41 to akka://cluster-test/user/member-1-shard-default-config
06:05:41,79 PM [cluster-test-akka.actor.default-dispatcher-12] [DEBUG] ShardManager - Marking Leader member-2-shard-default-config41 as available.
06:05:41,79 PM [cluster-test-akka.actor.default-dispatcher-12] [DEBUG] ShardManager - shard-manager-config41: In findPrimary: org.opendaylight.controller.cluster.datastore.messages.FindPrimary [shardName=default, waitUntilReady=true]
06:05:41,79 PM [cluster-test-akka.actor.default-dispatcher-12] [DEBUG] ShardManager - shard-manager-config41: Found primary for default: RemotePrimaryShardFound [primaryPath=akka://cluster-test@127.0.0.1:2558/user/shardmanager-config41/member-2-shard-default-config41, primaryVersion=13]
06:05:41,80 PM [cluster-test-akka.actor.default-dispatcher-12] [INFO] ShardManager - shard-manager-config41: Received MemberUp: memberName: MemberName{name=member-2}, address: akka://cluster-test@127.0.0.1:2558
06:05:41,80 PM [cluster-test-akka.actor.default-dispatcher-12] [INFO] ShardInformation - updatePeerAddress for peer member-2-shard-default-config41 with address akka://cluster-test@127.0.0.1:2558/user/shardmanager-config41/member-2-shard-default-config41
06:05:41,80 PM [cluster-test-akka.actor.default-dispatcher-12] [DEBUG] ShardInformation - Sending PeerAddressResolved for peer member-2-shard-default-config41 with address akka://cluster-test@127.0.0.1:2558/user/shardmanager-config41/member-2-shard-default-config41 to akka://cluster-test/user/member-1-shard-default-config
06:05:41,80 PM [cluster-test-akka.actor.default-dispatcher-12] [INFO] ShardManager - shard-manager-config41: All Shards are ready - data store config41 is ready
06:05:41,80 PM [cluster-test-akka.actor.default-dispatcher-12] [INFO] ShardManager - Received UnreachableMember: memberName MemberName{name=member-2}, address: akka://cluster-test@127.0.0.1:2558
06:05:41,80 PM [cluster-test-akka.actor.default-dispatcher-12] [DEBUG] ShardManager - Marking Leader member-2-shard-default-config41 as unavailable.
06:05:41,80 PM [cluster-test-akka.actor.default-dispatcher-12] [DEBUG] ShardManager - shard-manager-config41: In findPrimary: org.opendaylight.controller.cluster.datastore.messages.FindPrimary [shardName=default, waitUntilReady=true]
06:05:41,80 PM [cluster-test-akka.actor.default-dispatcher-12] [DEBUG] ShardManager - shard-manager-config41: Scheduling 1200 ms timer to wait for shard ShardInformation [shardId=member-1-shard-default-config41, leaderAvailable=false, actorInitialized=true, followerSyncStatus=false, role=Follower, leaderId=member-2-shard-default-config41, activeMember=true]
06:05:41,80 PM [cluster-test-akka.actor.default-dispatcher-12] [INFO] ShardManager - Received ReachableMember: memberName MemberName{name=member-2}, address: akka://cluster-test@127.0.0.1:2558
06:05:41,80 PM [cluster-test-akka.actor.default-dispatcher-12] [INFO] ShardInformation - updatePeerAddress for peer member-2-shard-default-config41 with address akka://cluster-test@127.0.0.1:2558/user/shardmanager-config41/member-2-shard-default-config41
06:05:41,80 PM [cluster-test-akka.actor.default-dispatcher-12] [DEBUG] ShardInformation - Sending PeerAddressResolved for peer member-2-shard-default-config41 with address akka://cluster-test@127.0.0.1:2558/user/shardmanager-config41/member-2-shard-default-config41 to akka://cluster-test/user/member-1-shard-default-config
06:05:41,80 PM [cluster-test-akka.actor.default-dispatcher-12] [DEBUG] ShardInformation - Shard member-1-shard-default-config41 is initialized - notifying 1 OnShardInitialized callbacks
06:05:41,80 PM [cluster-test-akka.actor.default-dispatcher-12] [DEBUG] ShardManager - Marking Leader member-2-shard-default-config41 as available.
06:05:41,80 PM [cluster-test-akka.actor.default-dispatcher-12] [DEBUG] ShardInformation - Shard member-1-shard-default-config41 is ready - notifying 1 OnShardInitialized callbacks
06:05:41,80 PM [cluster-test-akka.actor.default-dispatcher-12] [DEBUG] ShardManager - shard-manager-config41: Found primary for default: RemotePrimaryShardFound [primaryPath=akka://cluster-test@127.0.0.1:2558/user/shardmanager-config41/member-2-shard-default-config41, primaryVersion=13]
06:05:41,81 PM [main] [INFO] ShardManagerTest - testShardAvailabilityOnChangeOfMemberReachability ending
06:05:41,182 PM [cluster-test-akka.actor.default-dispatcher-12] [INFO] ShardManager - Stopping ShardManager shard-manager-config41
06:05:41,183 PM [cluster-test-akka.actor.default-dispatcher-13] [INFO] RemoteActorRefProvider$RemotingTerminator - Shutting down remote daemon.
06:05:41,183 PM [cluster-test-akka.actor.default-dispatcher-13] [INFO] RemoteActorRefProvider$RemotingTerminator - Remote daemon shut down; proceeding with flushing remote transports.
06:05:41,191 PM [cluster-test-akka.actor.default-dispatcher-13] [WARN] Materializer - [outbound connection to [akka://cluster-test@127.0.0.1:2559], message stream] Upstream failed, cause: StreamTcpException: The connection has been aborted
06:05:41,191 PM [cluster-test-akka.actor.default-dispatcher-13] [WARN] Materializer - [outbound connection to [akka://cluster-test@127.0.0.1:2559], control stream] Upstream failed, cause: StreamTcpException: The connection has been aborted
06:05:41,192 PM [cluster-test-akka.actor.default-dispatcher-13] [INFO] RemoteActorRefProvider$RemotingTerminator - Remoting shut down.
06:05:41,201 PM [cluster-test-akka.actor.default-dispatcher-13] [INFO] ShardManager - Stopping ShardManager shard-manager-config41
06:05:41,204 PM [cluster-test-akka.actor.default-dispatcher-10] [INFO] RemoteActorRefProvider$RemotingTerminator - Shutting down remote daemon.
06:05:41,204 PM [cluster-test-akka.actor.default-dispatcher-10] [INFO] RemoteActorRefProvider$RemotingTerminator - Remote daemon shut down; proceeding with flushing remote transports.
06:05:42,232 PM [cluster-test-akka.actor.default-dispatcher-10] [INFO] RemoteActorRefProvider$RemotingTerminator - Remoting shut down.
[WARN] [01/08/2024 18:05:42.234] [cluster-test-akka.actor.internal-dispatcher-4] [Cluster(akka://cluster-test)] Could not unregister Cluster JMX MBean with name=akka:type=Cluster as it was not found. If you are running multiple clusters in the same JVM, set 'akka.cluster.jmx.multi-mbeans-in-same-jvm = on' in config
06:05:42,248 PM [main] [INFO] ShardManagerTest - testAddShardReplica starting
06:05:42,259 PM [cluster-test-akka.actor.default-dispatcher-6] [INFO] Slf4jLogger - Slf4jLogger started
06:05:42,268 PM [cluster-test-akka.actor.default-dispatcher-6] [INFO] ArteryTransport - Remoting started with transport [Artery tcp]; listening on address [akka://cluster-test@127.0.0.1:2558] with UID [-6028845737757092886]
06:05:42,268 PM [cluster-test-akka.actor.default-dispatcher-6] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2558] - Starting up, Akka version [2.6.21] ...
06:05:42,270 PM [cluster-test-akka.actor.default-dispatcher-6] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2558] - Registered cluster JMX MBean [akka:type=Cluster]
06:05:42,270 PM [cluster-test-akka.actor.default-dispatcher-6] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2558] - Started up successfully
06:05:42,282 PM [cluster-test-akka.actor.default-dispatcher-10] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2558] - No downing-provider-class configured, manual cluster downing required, see https://doc.akka.io/docs/akka/current/typed/cluster.html#downing
06:05:42,289 PM [cluster-test-akka.actor.default-dispatcher-11] [INFO] EmptyLocalActorRef - Message [org.opendaylight.controller.cluster.common.actor.Monitor] from TestActor[akka://cluster-test/user/shardmanager-config42] to Actor[akka://cluster-test/user/termination-monitor] was not delivered. [1] dead letters encountered. If this is not an expected behavior then Actor[akka://cluster-test/user/termination-monitor] may have terminated unexpectedly. This logging can be turned off or adjusted with configuration settings 'akka.log-dead-letters' and 'akka.log-dead-letters-during-shutdown'.
06:05:42,289 PM [cluster-test-akka.actor.default-dispatcher-11] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2558] - No seed-nodes configured, manual cluster join required, see https://doc.akka.io/docs/akka/current/typed/cluster.html#joining
06:05:42,289 PM [cluster-test-akka.actor.default-dispatcher-11] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2558] - Node [akka://cluster-test@127.0.0.1:2558] is JOINING itself (with roles [member-1, dc-default], version [0.0.0]) and forming new cluster
06:05:42,289 PM [cluster-test-akka.actor.default-dispatcher-11] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2558] - is the new leader among reachable nodes (more leaders may exist)
06:05:42,289 PM [cluster-test-akka.actor.default-dispatcher-11] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2558] - Leader is moving node [akka://cluster-test@127.0.0.1:2558] to [Up]
06:05:42,291 PM [cluster-test-akka.actor.default-dispatcher-6] [INFO] ShardManager - Starting ShardManager shardmanager-config42
06:05:42,297 PM [cluster-test-akka.actor.default-dispatcher-12] [INFO] ShardManager - Recovery complete : shardmanager-config42
06:05:42,297 PM [cluster-test-akka.actor.default-dispatcher-12] [DEBUG] ShardManager - shardmanager-config42: Creating local shard: member-1-shard-default-config42
06:05:42,298 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] Slf4jLogger - Slf4jLogger started
06:05:42,298 PM [cluster-test-akka.actor.default-dispatcher-12] [INFO] ShardManager - shardmanager-config42: Received MemberUp: memberName: MemberName{name=member-1}, address: akka://cluster-test@127.0.0.1:2558
06:05:42,298 PM [cluster-test-akka.actor.default-dispatcher-12] [INFO] ShardInformation - updatePeerAddress for peer member-1-shard-default-config42 with address akka://cluster-test@127.0.0.1:2558/user/shardmanager-config42/member-1-shard-default-config42
06:05:42,309 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] ArteryTransport - Remoting started with transport [Artery tcp]; listening on address [akka://cluster-test@127.0.0.1:2559] with UID [2309678283826822156]
06:05:42,309 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2559] - Starting up, Akka version [2.6.21] ...
06:05:42,309 PM [cluster-test-akka.actor.default-dispatcher-5] [WARN] Cluster - Could not register Cluster JMX MBean with name=akka:type=Cluster as it is already registered. If you are running multiple clusters in the same JVM, set 'akka.cluster.jmx.multi-mbeans-in-same-jvm = on' in config
06:05:42,309 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2559] - Started up successfully
06:05:42,309 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2559] - No downing-provider-class configured, manual cluster downing required, see https://doc.akka.io/docs/akka/current/typed/cluster.html#downing
06:05:42,310 PM [cluster-test-akka.actor.default-dispatcher-10] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2559] - No seed-nodes configured, manual cluster join required, see https://doc.akka.io/docs/akka/current/typed/cluster.html#joining
06:05:42,326 PM [cluster-test-akka.actor.default-dispatcher-12] [INFO] ShardManager - Starting ShardManager shardmanager-config42
06:05:42,331 PM [cluster-test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1
06:05:42,331 PM [cluster-test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - Creating Shard member-1-shard-default-config42
06:05:42,331 PM [cluster-test-akka.actor.default-dispatcher-10] [INFO] ShardInformation - updatePeerAddress for peer member-1-shard-default-config42 with address akka://cluster-test@127.0.0.1:2558/user/shardmanager-config42/member-1-shard-default-config42
06:05:42,331 PM [cluster-test-akka.actor.default-dispatcher-10] [DEBUG] ShardInformation - Sending PeerAddressResolved for peer member-1-shard-default-config42 with address akka://cluster-test@127.0.0.1:2558/user/shardmanager-config42/member-1-shard-default-config42 to akka://cluster-test/user/member-1-shard-default-config
06:05:42,331 PM [cluster-test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shardmanager-config42: updated peer member-1-shard-default-config42 on member MemberName{name=member-1} with address akka://cluster-test@127.0.0.1:2558/user/shardmanager-config42/member-1-shard-default-config42 on shard member-1-shard-default-config42 whose actor address is Actor[akka://cluster-test/user/member-1-shard-default-config#-2122674506]
06:05:42,333 PM [cluster-test-akka.actor.default-dispatcher-10] [INFO] EmptyLocalActorRef - Message [org.opendaylight.controller.cluster.common.actor.Monitor] from TestActor[akka://cluster-test/user/shardmanager-config42] to Actor[akka://cluster-test/user/termination-monitor] was not delivered. [1] dead letters encountered. If this is not an expected behavior then Actor[akka://cluster-test/user/termination-monitor] may have terminated unexpectedly. This logging can be turned off or adjusted with configuration settings 'akka.log-dead-letters' and 'akka.log-dead-letters-during-shutdown'.
06:05:42,341 PM [cluster-test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Recovery complete : shardmanager-config42
06:05:42,341 PM [cluster-test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shardmanager-config42: Creating local shard: member-2-shard-default-config42
06:05:42,341 PM [cluster-test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shardmanager-config42: Creating local shard: member-2-shard-astronauts-config42
06:05:42,342 PM [cluster-test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1
06:05:42,342 PM [cluster-test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - Creating Shard member-2-shard-default-config42
06:05:42,342 PM [cluster-test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - Creating Shard member-2-shard-astronauts-config42
06:05:42,342 PM [cluster-test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shardmanager-config42: Initializing shard [astronauts]
06:05:42,342 PM [cluster-test-akka.actor.default-dispatcher-11] [DEBUG] ShardInformation - Shard member-2-shard-astronauts-config42 is initialized
06:05:42,342 PM [cluster-test-akka.actor.default-dispatcher-11] [INFO] ShardManager - shardmanager-config42: Received LeaderStateChanged message: LeaderStateChanged [memberId=member-2-shard-astronauts-config42, leaderId=member-2-shard-astronauts-config42, leaderPayloadVersion=12]
06:05:42,342 PM [cluster-test-akka.actor.default-dispatcher-11] [INFO] ShardManager - shardmanager-config42: Received role changed for member-2-shard-astronauts-config42 from Candidate to Leader
06:05:42,398 PM [cluster-test-akka.actor.default-dispatcher-10] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2558] - Node [akka://cluster-test@127.0.0.1:2559] is JOINING, roles [member-2, dc-default], version [0.0.0]
06:05:42,398 PM [cluster-test-akka.actor.default-dispatcher-11] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2559] - Welcome from [akka://cluster-test@127.0.0.1:2558]
06:05:42,398 PM [cluster-test-akka.actor.default-dispatcher-11] [INFO] ShardManager - shardmanager-config42: Received MemberUp: memberName: MemberName{name=member-1}, address: akka://cluster-test@127.0.0.1:2558
06:05:42,398 PM [cluster-test-akka.actor.default-dispatcher-11] [INFO] ShardInformation - updatePeerAddress for peer member-1-shard-default-config42 with address akka://cluster-test@127.0.0.1:2558/user/shardmanager-config42/member-1-shard-default-config42
06:05:42,399 PM [cluster-test-akka.actor.default-dispatcher-11] [DEBUG] ShardInformation - Sending PeerAddressResolved for peer member-1-shard-default-config42 with address akka://cluster-test@127.0.0.1:2558/user/shardmanager-config42/member-1-shard-default-config42 to akka://cluster-test/user/member-2-shard-astronauts-config
06:05:42,399 PM [cluster-test-akka.actor.default-dispatcher-11] [INFO] ShardInformation - updatePeerAddress for peer member-1-shard-astronauts-config42 with address akka://cluster-test@127.0.0.1:2558/user/shardmanager-config42/member-1-shard-astronauts-config42
06:05:42,399 PM [cluster-test-akka.actor.default-dispatcher-11] [DEBUG] ShardInformation - Sending PeerAddressResolved for peer member-1-shard-astronauts-config42 with address akka://cluster-test@127.0.0.1:2558/user/shardmanager-config42/member-1-shard-astronauts-config42 to akka://cluster-test/user/member-2-shard-astronauts-config
06:05:43,292 PM [cluster-test-akka.actor.default-dispatcher-6] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2558] - Leader is moving node [akka://cluster-test@127.0.0.1:2559] to [Up]
06:05:43,293 PM [cluster-test-akka.actor.default-dispatcher-6] [INFO] ShardManager - shardmanager-config42: Received MemberUp: memberName: MemberName{name=member-2}, address: akka://cluster-test@127.0.0.1:2559
06:05:43,293 PM [cluster-test-akka.actor.default-dispatcher-6] [INFO] ShardInformation - updatePeerAddress for peer member-2-shard-default-config42 with address akka://cluster-test@127.0.0.1:2559/user/shardmanager-config42/member-2-shard-default-config42
06:05:43,293 PM [cluster-test-akka.actor.default-dispatcher-6] [DEBUG] ShardInformation - Sending PeerAddressResolved for peer member-2-shard-default-config42 with address akka://cluster-test@127.0.0.1:2559/user/shardmanager-config42/member-2-shard-default-config42 to akka://cluster-test/user/member-1-shard-default-config
06:05:43,296 PM [cluster-test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shardmanager-config42: onAddShardReplica: AddShardReplica[ShardName=astronauts]
06:05:43,297 PM [cluster-test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shardmanager-config42: In findPrimary: org.opendaylight.controller.cluster.datastore.messages.FindPrimary [shardName=astronauts, waitUntilReady=true]
06:05:43,297 PM [cluster-test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shardmanager-config42: findPrimary for astronauts forwarding to remote ShardManager akka://cluster-test@127.0.0.1:2559/user/shardmanager-config42, visitedAddresses: [akka://cluster-test@127.0.0.1:2558/user/shardmanager-config42]
06:05:43,299 PM [cluster-test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shardmanager-config42: In findPrimary: org.opendaylight.controller.cluster.datastore.messages.RemoteFindPrimary [shardName=astronauts, waitUntilReady=true]
06:05:43,299 PM [cluster-test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shardmanager-config42: Found primary for astronauts: RemotePrimaryShardFound [primaryPath=akka://cluster-test@127.0.0.1:2559/user/member-2-shard-astronauts-config, primaryVersion=12]
06:05:43,301 PM [cluster-test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shardmanager-config42: Sending AddServer message to peer akka://cluster-test@127.0.0.1:2559/user/member-2-shard-astronauts-config for shard member-1-shard-astronauts-config42
06:05:43,308 PM [cluster-test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shardmanager-config42: Received AddServerReply{status=OK, leaderHint=member-2-shard-astronauts-config42} for shard astronauts from leader akka://cluster-test@127.0.0.1:2559/user/member-2-shard-astronauts-config
06:05:43,308 PM [cluster-test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shardmanager-config42: Leader shard successfully added the replica shard astronauts
06:05:43,308 PM [cluster-test-akka.actor.default-dispatcher-10] [DEBUG] ShardInformation - Sending new DatastoreContext to member-1-shard-astronauts-config42
06:05:43,308 PM [cluster-test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shardmanager-config42: persisting the shard list [default, astronauts]
06:05:43,309 PM [cluster-test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shardmanager-config42 saved ShardManager snapshot successfully. Deleting the prev snapshot if available
06:05:43,309 PM [cluster-test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shardmanager-config42: Successfully deleted prior snapshots
06:05:43,328 PM [cluster-test-akka.actor.default-dispatcher-10] [INFO] ShardManager - shardmanager-config42: Received MemberUp: memberName: MemberName{name=member-2}, address: akka://cluster-test@127.0.0.1:2559
06:05:43,328 PM [cluster-test-akka.actor.default-dispatcher-10] [INFO] ShardInformation - updatePeerAddress for peer member-2-shard-default-config42 with address akka://cluster-test@127.0.0.1:2559/user/shardmanager-config42/member-2-shard-default-config42
06:05:43,328 PM [cluster-test-akka.actor.default-dispatcher-10] [DEBUG] ShardInformation - Sending PeerAddressResolved for peer member-2-shard-default-config42 with address akka://cluster-test@127.0.0.1:2559/user/shardmanager-config42/member-2-shard-default-config42 to akka://cluster-test/user/member-2-shard-astronauts-config
06:05:43,328 PM [cluster-test-akka.actor.default-dispatcher-10] [INFO] ShardInformation - updatePeerAddress for peer member-2-shard-astronauts-config42 with address akka://cluster-test@127.0.0.1:2559/user/shardmanager-config42/member-2-shard-astronauts-config42
06:05:43,328 PM [cluster-test-akka.actor.default-dispatcher-10] [DEBUG] ShardInformation - Sending PeerAddressResolved for peer member-2-shard-astronauts-config42 with address akka://cluster-test@127.0.0.1:2559/user/shardmanager-config42/member-2-shard-astronauts-config42 to akka://cluster-test/user/member-2-shard-astronauts-config
06:05:43,348 PM [main] [INFO] ShardManagerTest - testAddShardReplica ending
06:05:43,449 PM [cluster-test-akka.actor.default-dispatcher-6] [INFO] ShardManager - Stopping ShardManager shardmanager-config42
06:05:43,450 PM [cluster-test-akka.actor.default-dispatcher-6] [INFO] RemoteActorRefProvider$RemotingTerminator - Shutting down remote daemon.
06:05:43,450 PM [cluster-test-akka.actor.default-dispatcher-6] [INFO] RemoteActorRefProvider$RemotingTerminator - Remote daemon shut down; proceeding with flushing remote transports.
06:05:43,457 PM [cluster-test-akka.actor.default-dispatcher-6] [WARN] Materializer - [outbound connection to [akka://cluster-test@127.0.0.1:2559], message stream] Upstream failed, cause: StreamTcpException: The connection has been aborted
06:05:43,458 PM [cluster-test-akka.actor.default-dispatcher-6] [WARN] Materializer - [outbound connection to [akka://cluster-test@127.0.0.1:2559], control stream] Upstream failed, cause: StreamTcpException: The connection has been aborted
06:05:43,459 PM [cluster-test-akka.actor.default-dispatcher-6] [INFO] RemoteActorRefProvider$RemotingTerminator - Remoting shut down.
06:05:43,474 PM [cluster-test-akka.actor.default-dispatcher-16] [INFO] ShardManager - Stopping ShardManager shardmanager-config42
06:05:43,474 PM [cluster-test-akka.actor.default-dispatcher-10] [INFO] RemoteActorRefProvider$RemotingTerminator - Shutting down remote daemon.
06:05:43,474 PM [cluster-test-akka.actor.default-dispatcher-10] [INFO] RemoteActorRefProvider$RemotingTerminator - Remote daemon shut down; proceeding with flushing remote transports.
06:05:44,494 PM [cluster-test-akka.actor.default-dispatcher-10] [INFO] RemoteActorRefProvider$RemotingTerminator - Remoting shut down.
[WARN] [01/08/2024 18:05:44.496] [cluster-test-akka.actor.internal-dispatcher-3] [Cluster(akka://cluster-test)] Could not unregister Cluster JMX MBean with name=akka:type=Cluster as it was not found. If you are running multiple clusters in the same JVM, set 'akka.cluster.jmx.multi-mbeans-in-same-jvm = on' in config
06:05:44,529 PM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - Starting ShardManager shard-manager-config43
06:05:44,537 PM [test-akka.actor.default-dispatcher-15] [INFO] ShardManager - Recovery complete : shard-manager-config43
06:05:44,537 PM [test-akka.actor.default-dispatcher-15] [DEBUG] ShardManager - shard-manager-config43: Creating local shard: member-1-shard-default-config43
06:05:44,537 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1
06:05:44,537 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - Creating Shard member-1-shard-default-config43
06:05:44,538 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config43: Initializing shard [default]
06:05:44,538 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardInformation - Shard member-1-shard-default-config43 is initialized
06:05:44,538 PM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - shard-manager-config43: Received LeaderStateChanged message: LeaderStateChanged [memberId=member-1-shard-default-config43, leaderId=member-1-shard-default-config43, leaderPayloadVersion=13]
06:05:44,538 PM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - shard-manager-config43: Received role changed for member-1-shard-default-config43 from Candidate to Leader
06:05:44,538 PM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - shard-manager-config43: All Shards are ready - data store config43 is ready
06:05:44,538 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config43: onRemoveShardReplica: RemoveShardReplica [shardName=default, memberName=MemberName{name=member-1}]
06:05:44,538 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config43: In findPrimary: org.opendaylight.controller.cluster.datastore.messages.FindPrimary [shardName=default, waitUntilReady=true]
06:05:44,538 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config43: Found primary for default: LocalPrimaryShardFound [primaryPath=akka://test@127.0.0.1:2565/user/member-1-shard-default-config43#-1238270427, localShardDataTree=org.opendaylight.yangtools.yang.data.tree.api.DataTree$MockitoMock$1bGo7AjM@e1c4d04]
06:05:44,538 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config43: Sending RemoveServer message to peer akka://test@127.0.0.1:2565/user/member-1-shard-default-config43#-1238270427 for shard member-1-shard-default-config43
06:05:44,539 PM [test-akka.actor.default-dispatcher-15] [DEBUG] ShardManager - shard-manager-config43: Received RemoveServerReply{status=OK} for shard default
06:05:44,539 PM [test-akka.actor.default-dispatcher-15] [DEBUG] ShardManager - shard-manager-config43: Leader shard successfully removed the replica shard default
06:05:44,689 PM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/member-1-shard-default-config43#-1238270427]
06:05:44,701 PM [main] [INFO] ShardManagerTest - testOnReceiveFindPrimaryWaitForReadyWithIsolatedLeaderShard starting
06:05:44,704 PM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - Starting ShardManager shard-manager-config44
06:05:44,705 PM [test-akka.actor.default-dispatcher-15] [INFO] ShardManager - Recovery complete : shard-manager-config44
06:05:44,705 PM [test-akka.actor.default-dispatcher-15] [DEBUG] ShardManager - shard-manager-config44: Creating local shard: member-1-shard-default-config44
06:05:44,714 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1
06:05:44,715 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - Creating Shard member-1-shard-default-config44
06:05:44,715 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config44: Initializing shard [default]
06:05:44,715 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardInformation - Shard member-1-shard-default-config44 is initialized
06:05:44,715 PM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - shard-manager-config44: Received role changed for member-1-shard-default-config44 from null to IsolatedLeader
06:05:44,715 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config44: In findPrimary: org.opendaylight.controller.cluster.datastore.messages.FindPrimary [shardName=default, waitUntilReady=true]
06:05:44,715 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config44: Scheduling 1200 ms timer to wait for shard ShardInformation [shardId=member-1-shard-default-config44, leaderAvailable=false, actorInitialized=true, followerSyncStatus=false, role=IsolatedLeader, leaderId=null, activeMember=true]
06:05:45,933 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config44: Received ShardNotInitializedTimeout message for shard default
06:05:45,933 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config44: Returning NoShardLeaderException for shard default
06:05:45,933 PM [main] [INFO] ShardManagerTest - testOnReceiveFindPrimaryWaitForReadyWithIsolatedLeaderShard ending
06:05:46,34 PM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/$y#-1998476046]
06:05:46,45 PM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Stopping ShardManager shard-manager-config44
06:05:46,49 PM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Starting ShardManager shard-manager-config45
06:05:46,50 PM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - Recovery complete : shard-manager-config45
06:05:46,50 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config45: Creating local shard: member-1-shard-default-config45
06:05:46,59 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1
06:05:46,59 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - Creating Shard member-1-shard-default-config45
06:05:46,59 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config45: findLocalShard : non-existent
06:05:46,59 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config45: Local shard non-existent not found - shards present: [default]
06:05:46,161 PM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/$z#-1419071727]
06:05:46,172 PM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - Stopping ShardManager shard-manager-config45
06:05:46,176 PM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Starting ShardManager shard-manager-config46
06:05:46,177 PM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - Recovery complete : shard-manager-config46
06:05:46,197 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1
06:05:46,197 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config46: onRemoveShardReplica: RemoveShardReplica [shardName=astronauts, memberName=MemberName{name=member-2}]
06:05:46,198 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config46: Sending RemoveServer message to peer akka://test@127.0.0.1:2565/system/testProbe-594#-515303819 for shard member-2-shard-astronauts-config46
06:05:46,209 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config46: onRemoveShardReplica: RemoveShardReplica [shardName=astronauts, memberName=MemberName{name=member-3}]
06:05:46,209 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config46: A shard replica operation for astronauts is already in progress
06:05:46,314 PM [test-akka.actor.default-dispatcher-15] [INFO] ShardManager - Starting ShardManager shard-manager-config47
06:05:46,315 PM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - Recovery complete : shard-manager-config47
06:05:46,315 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config47: Creating local shard: member-1-shard-default-config47
06:05:46,325 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config47: In findPrimary: org.opendaylight.controller.cluster.datastore.messages.FindPrimary [shardName=default, waitUntilReady=false]
06:05:46,325 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config47: Returning NotInitializedException for shard default
06:05:46,426 PM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/$A#621918209]
06:05:46,437 PM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Stopping ShardManager shard-manager-config47
06:05:46,439 PM [main] [INFO] ShardManagerTest - testServerRemovedShardActorRunning starting
06:05:46,443 PM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Starting ShardManager shard-manager-config48
06:05:46,444 PM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Recovery complete : shard-manager-config48
06:05:46,444 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config48: Creating local shard: member-1-shard-default-config48
06:05:46,444 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config48: Creating local shard: member-1-shard-people-config48
06:05:46,455 PM [test-akka.actor.default-dispatcher-15] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1
06:05:46,455 PM [test-akka.actor.default-dispatcher-15] [DEBUG] ShardManager - Creating Shard member-1-shard-default-config48
06:05:46,455 PM [test-akka.actor.default-dispatcher-15] [DEBUG] ShardManager - Creating Shard member-1-shard-people-config48
06:05:46,456 PM [test-akka.actor.default-dispatcher-15] [DEBUG] ShardManager - shard-manager-config48: Initializing shard [default]
06:05:46,456 PM [test-akka.actor.default-dispatcher-15] [DEBUG] ShardInformation - Shard member-1-shard-default-config48 is initialized
06:05:46,456 PM [test-akka.actor.default-dispatcher-15] [DEBUG] ShardManager - shard-manager-config48: findLocalShard : people
06:05:46,456 PM [test-akka.actor.default-dispatcher-15] [DEBUG] ShardManager - shard-manager-config48: Scheduling 600 ms timer to wait for shard ShardInformation [shardId=member-1-shard-people-config48, leaderAvailable=false, actorInitialized=false, followerSyncStatus=false, role=null, leaderId=null, activeMember=true]
06:05:46,458 PM [test-shard-dispatcher-18] [INFO] Shard - Shard created : member-1-shard-people-config48, persistent : true
06:05:46,461 PM [test-shard-dispatcher-18] [INFO] Shard - Starting recovery for member-1-shard-people-config48 with journal batch size 1
06:05:46,466 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardSnapshotActor - Actor created Actor[akka://test/user/$$j/member-1-shard-people-config48/shard-member-1:snapshot-read#-746620244]
06:05:46,466 PM [test-akka.actor.default-dispatcher-15] [INFO] RoleChangeNotifier - RoleChangeNotifier:akka://test@127.0.0.1:2565/user/$$j/member-1-shard-people-config48/member-1-shard-people-config48-notifier#1792846106 created and ready for shard:member-1-shard-people-config48
06:05:46,467 PM [test-shard-dispatcher-18] [DEBUG] Shard - member-1-shard-people-config48: onReceiveRecover: Received message class akka.persistence.RecoveryCompleted$ from Actor[akka://test/deadLetters]
06:05:46,467 PM [test-shard-dispatcher-18] [INFO] Shard - member-1-shard-people-config48: Recovery completed  - Switching actor to Follower - last log index = -1, last log term = -1, snapshot index = -1, snapshot term = -1, journal size = 0
06:05:46,468 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config48: Initializing shard [people]
06:05:46,468 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardInformation - Shard member-1-shard-people-config48 is initialized
06:05:46,468 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardInformation - Shard member-1-shard-people-config48 is initialized - notifying 1 OnShardInitialized callbacks
06:05:46,468 PM [test-shard-dispatcher-18] [DEBUG] DataTreeChangeListenerSupport - member-1-shard-people-config48: onLeadershipChange, isLeader: false, hasLeader : false
06:05:46,468 PM [test-shard-dispatcher-18] [DEBUG] Shard - member-1-shard-people-config48: onStateChanged: Closing all transaction chains because shard member-1-shard-people-config48 is no longer the leader
06:05:46,468 PM [test-akka.actor.default-dispatcher-10] [INFO] RoleChangeNotifier - RoleChangeNotifier for member-1-shard-people-config48 , received role change from null to Follower
06:05:46,468 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config48: findLocalShard : default
06:05:46,468 PM [test-akka.actor.default-dispatcher-10] [INFO] RoleChangeNotifier - RoleChangeNotifier for member-1-shard-people-config48 , registered listener akka://test/user/$$j
06:05:46,468 PM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - shard-manager-config48: Received role changed for member-1-shard-people-config48 from null to Follower
06:05:46,468 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config48 : Sending Shutdown to Shard actor Actor[akka://test/user/member-1-shard-default-config48#1530300723] with 10000 ms timeout
06:05:46,471 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config48 : Local Shard replica for shard default has been removed
06:05:46,471 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config48: persisting the shard list [people]
06:05:46,472 PM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - shard-manager-config48 saved ShardManager snapshot successfully. Deleting the prev snapshot if available
06:05:46,472 PM [main] [INFO] ShardManagerTest - testServerRemovedShardActorRunning ending
06:05:46,472 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config48: Successfully deleted prior snapshots
06:05:46,573 PM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/member-1-shard-default-config48#1530300723]
06:05:46,584 PM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - shard-manager-config48 : Successfully shut down Shard actor Actor[akka://test/user/member-1-shard-default-config48#1530300723]
06:05:46,584 PM [main] [INFO] TestActorFactory - Killing actor TestActor[akka://test/user/$$j]
06:05:46,585 PM [test-shard-dispatcher-18] [INFO] Shard - Stopping Shard member-1-shard-people-config48
06:05:46,585 PM [test-shard-dispatcher-18] [DEBUG] MessageAssembler - member-1-shard-people-config48 (Follower): Closing
06:05:46,585 PM [test-shard-dispatcher-18] [DEBUG] Shard - member-1-shard-people-config48: Aborting 0 pending queued transactions
06:05:46,586 PM [test-akka.actor.default-dispatcher-5] [INFO] ShardManager - Stopping ShardManager shard-manager-config48
06:05:46,589 PM [main] [INFO] ShardManager - Starting ShardManager shard-manager-config49
06:05:46,591 PM [test-akka.actor.default-dispatcher-5] [INFO] ShardManager - Recovery complete : shard-manager-config49
06:05:46,591 PM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - shard-manager-config49: Creating local shard: member-1-shard-default-config49
06:05:46,591 PM [main] [INFO] ShardManager - shard-manager-config49: Received role changed for member-1-shard-default-config49 from null to Follower
06:05:46,591 PM [main] [INFO] ShardManager - shard-manager-config49: Received LeaderStateChanged message: LeaderStateChanged [memberId=member-1-shard-default-config49, leaderId=member-2-shard-default-config49, leaderPayloadVersion=13]
06:05:46,602 PM [main] [INFO] ShardManager - shard-manager-config49: Received MemberUp: memberName: MemberName{name=member-2}, address: akka://test
06:05:46,602 PM [main] [INFO] ShardInformation - updatePeerAddress for peer member-2-shard-default-config49 with address akka://test/user/shardmanager-config49/member-2-shard-default-config49
06:05:46,602 PM [main] [INFO] ShardManager - shard-manager-config49: All Shards are ready - data store config49 is ready
06:05:46,703 PM [main] [INFO] TestActorFactory - Killing actor TestActor[akka://test/user/$$k]
06:05:46,714 PM [main] [INFO] ShardManager - Stopping ShardManager shard-manager-config49
06:05:46,716 PM [main] [INFO] ShardManagerTest - testRestoreFromSnapshot starting
06:05:46,718 PM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Starting ShardManager shard-manager-config50
06:05:46,720 PM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - Recovery complete : shard-manager-config50
06:05:46,720 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config50: Restoring from ShardManagerSnapshot: ShardManagerSnapshot [ShardList = [shard1, shard2, astronauts] ]
06:05:46,720 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config50: onSnapshotOffer: ShardManagerSnapshot [ShardList = [shard1, shard2, astronauts] ]
06:05:46,720 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config50: adding shard shard1
06:05:46,720 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config50: adding shard shard2
06:05:46,720 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config50: adding shard astronauts
06:05:46,720 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config50: Creating local shard: member-1-shard-shard2-config50
06:05:46,720 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config50: Creating local shard: member-1-shard-astronauts-config50
06:05:46,720 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config50: Creating local shard: member-1-shard-shard1-config50
06:05:46,721 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1
06:05:46,721 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - Creating Shard member-1-shard-shard2-config50
06:05:46,721 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - Creating Shard member-1-shard-astronauts-config50
06:05:46,722 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - Creating Shard member-1-shard-shard1-config50
06:05:46,725 PM [test-shard-dispatcher-18] [INFO] Shard - Shard created : member-1-shard-shard2-config50, persistent : true
06:05:46,725 PM [test-shard-dispatcher-19] [INFO] Shard - Shard created : member-1-shard-astronauts-config50, persistent : true
06:05:46,726 PM [test-shard-dispatcher-18] [INFO] Shard - Starting recovery for member-1-shard-shard2-config50 with journal batch size 1
06:05:46,726 PM [test-shard-dispatcher-19] [INFO] Shard - Starting recovery for member-1-shard-astronauts-config50 with journal batch size 1
06:05:46,726 PM [test-akka.actor.default-dispatcher-10] [INFO] RoleChangeNotifier - RoleChangeNotifier:akka://test@127.0.0.1:2565/user/$$l/member-1-shard-shard2-config50/member-1-shard-shard2-config50-notifier#816047293 created and ready for shard:member-1-shard-shard2-config50
06:05:46,726 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardSnapshotActor - Actor created Actor[akka://test/user/$$l/member-1-shard-shard2-config50/shard-member-1:snapshot-read#509377512]
06:05:46,726 PM [test-akka.actor.default-dispatcher-13] [DEBUG] ShardSnapshotActor - Actor created Actor[akka://test/user/$$l/member-1-shard-astronauts-config50/shard-member-1:snapshot-read#-114865330]
06:05:46,727 PM [test-akka.actor.default-dispatcher-10] [INFO] RoleChangeNotifier - RoleChangeNotifier:akka://test@127.0.0.1:2565/user/$$l/member-1-shard-astronauts-config50/member-1-shard-astronauts-config50-notifier#744293811 created and ready for shard:member-1-shard-astronauts-config50
06:05:46,727 PM [test-shard-dispatcher-20] [DEBUG] Shard - member-1-shard-astronauts-config50: onReceiveRecover: Received message class akka.persistence.RecoveryCompleted$ from Actor[akka://test/deadLetters]
06:05:46,727 PM [test-shard-dispatcher-20] [INFO] Shard - member-1-shard-astronauts-config50: Recovery completed  - Switching actor to Follower - last log index = -1, last log term = -1, snapshot index = -1, snapshot term = -1, journal size = 0
06:05:46,727 PM [test-shard-dispatcher-20] [DEBUG] DataTreeChangeListenerSupport - member-1-shard-astronauts-config50: onLeadershipChange, isLeader: false, hasLeader : false
06:05:46,727 PM [test-shard-dispatcher-20] [DEBUG] Shard - member-1-shard-astronauts-config50: onStateChanged: Closing all transaction chains because shard member-1-shard-astronauts-config50 is no longer the leader
06:05:46,727 PM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - shard-manager-config50: Initializing shard [astronauts]
06:05:46,727 PM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardInformation - Shard member-1-shard-astronauts-config50 is initialized
06:05:46,728 PM [test-akka.actor.default-dispatcher-5] [INFO] RoleChangeNotifier - RoleChangeNotifier for member-1-shard-astronauts-config50 , received role change from null to Follower
06:05:46,728 PM [test-shard-dispatcher-18] [INFO] Shard - Shard created : member-1-shard-shard1-config50, persistent : true
06:05:46,728 PM [test-shard-dispatcher-20] [DEBUG] Shard - member-1-shard-astronauts-config50 (Follower): Received TimeoutNow - switching to Candidate
06:05:46,729 PM [test-shard-dispatcher-18] [INFO] Shard - Starting recovery for member-1-shard-shard1-config50 with journal batch size 1
06:05:46,729 PM [test-akka.actor.default-dispatcher-11] [INFO] RoleChangeNotifier - RoleChangeNotifier:akka://test@127.0.0.1:2565/user/$$l/member-1-shard-shard1-config50/member-1-shard-shard1-config50-notifier#2045154942 created and ready for shard:member-1-shard-shard1-config50
06:05:46,729 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardSnapshotActor - Actor created Actor[akka://test/user/$$l/member-1-shard-shard1-config50/shard-member-1:snapshot-read#310071496]
06:05:46,731 PM [test-shard-dispatcher-20] [DEBUG] Shard - member-1-shard-astronauts-config50 (Candidate): Election: Candidate has following voting peers: []
06:05:46,731 PM [test-shard-dispatcher-20] [DEBUG] Shard - member-1-shard-astronauts-config50: Set currentTerm=1, votedFor=member-1-shard-astronauts-config50
06:05:46,731 PM [test-akka.actor.default-dispatcher-22] [DEBUG] ShardManager - shard-manager-config50: findLocalShard : shard1
06:05:46,731 PM [test-akka.actor.default-dispatcher-22] [DEBUG] ShardManager - shard-manager-config50: Scheduling 3000 ms timer to wait for shard ShardInformation [shardId=member-1-shard-shard1-config50, leaderAvailable=false, actorInitialized=false, followerSyncStatus=false, role=null, leaderId=null, activeMember=true]
06:05:46,732 PM [test-shard-dispatcher-23] [DEBUG] Shard - member-1-shard-shard1-config50: onReceiveRecover: Received message class akka.persistence.RecoveryCompleted$ from Actor[akka://test/deadLetters]
06:05:46,732 PM [test-shard-dispatcher-23] [INFO] Shard - member-1-shard-shard1-config50: Recovery completed  - Switching actor to Follower - last log index = -1, last log term = -1, snapshot index = -1, snapshot term = -1, journal size = 0
06:05:46,732 PM [test-akka.actor.default-dispatcher-22] [DEBUG] ShardManager - shard-manager-config50: Initializing shard [shard1]
06:05:46,732 PM [test-akka.actor.default-dispatcher-22] [DEBUG] ShardInformation - Shard member-1-shard-shard1-config50 is initialized
06:05:46,732 PM [test-akka.actor.default-dispatcher-22] [DEBUG] ShardInformation - Shard member-1-shard-shard1-config50 is initialized - notifying 1 OnShardInitialized callbacks
06:05:46,732 PM [test-shard-dispatcher-23] [DEBUG] DataTreeChangeListenerSupport - member-1-shard-shard1-config50: onLeadershipChange, isLeader: false, hasLeader : false
06:05:46,732 PM [test-shard-dispatcher-23] [DEBUG] Shard - member-1-shard-shard1-config50: onStateChanged: Closing all transaction chains because shard member-1-shard-shard1-config50 is no longer the leader
06:05:46,732 PM [test-akka.actor.default-dispatcher-22] [INFO] RoleChangeNotifier - RoleChangeNotifier for member-1-shard-shard1-config50 , received role change from null to Follower
06:05:46,732 PM [test-shard-dispatcher-23] [DEBUG] Shard - member-1-shard-shard1-config50 (Follower): Received TimeoutNow - switching to Candidate
06:05:46,732 PM [test-shard-dispatcher-23] [DEBUG] Shard - member-1-shard-shard1-config50 (Candidate): Election: Candidate has following voting peers: []
06:05:46,732 PM [test-shard-dispatcher-23] [DEBUG] Shard - member-1-shard-shard1-config50: Set currentTerm=1, votedFor=member-1-shard-shard1-config50
06:05:46,735 PM [test-shard-dispatcher-20] [INFO] Shard - member-1-shard-astronauts-config50 (Candidate): Starting new election term 1
06:05:46,735 PM [test-shard-dispatcher-20] [INFO] Shard - member-1-shard-astronauts-config50 (Follower) :- Switching from behavior Follower to Candidate, election term: 1
06:05:46,735 PM [test-shard-dispatcher-20] [DEBUG] MessageAssembler - member-1-shard-astronauts-config50 (Follower): Closing
06:05:46,735 PM [test-shard-dispatcher-20] [DEBUG] DataTreeChangeListenerSupport - member-1-shard-astronauts-config50: onLeadershipChange, isLeader: false, hasLeader : false
06:05:46,735 PM [test-shard-dispatcher-20] [DEBUG] Shard - member-1-shard-astronauts-config50: onStateChanged: Closing all transaction chains because shard member-1-shard-astronauts-config50 is no longer the leader
06:05:46,735 PM [test-shard-dispatcher-23] [INFO] Shard - member-1-shard-shard1-config50 (Candidate): Starting new election term 1
06:05:46,735 PM [test-shard-dispatcher-23] [INFO] Shard - member-1-shard-shard1-config50 (Follower) :- Switching from behavior Follower to Candidate, election term: 1
06:05:46,735 PM [test-shard-dispatcher-23] [DEBUG] MessageAssembler - member-1-shard-shard1-config50 (Follower): Closing
06:05:46,735 PM [test-akka.actor.default-dispatcher-21] [INFO] RoleChangeNotifier - RoleChangeNotifier for member-1-shard-astronauts-config50 , received role change from Follower to Candidate
06:05:46,735 PM [test-shard-dispatcher-23] [DEBUG] DataTreeChangeListenerSupport - member-1-shard-shard1-config50: onLeadershipChange, isLeader: false, hasLeader : false
06:05:46,735 PM [test-shard-dispatcher-23] [DEBUG] Shard - member-1-shard-shard1-config50: onStateChanged: Closing all transaction chains because shard member-1-shard-shard1-config50 is no longer the leader
06:05:46,735 PM [test-akka.actor.default-dispatcher-21] [INFO] RoleChangeNotifier - RoleChangeNotifier for member-1-shard-shard1-config50 , received role change from Follower to Candidate
06:05:46,735 PM [test-akka.actor.default-dispatcher-21] [DEBUG] ShardManager - shard-manager-config50: findLocalShard : shard2
06:05:46,735 PM [test-akka.actor.default-dispatcher-21] [DEBUG] ShardManager - shard-manager-config50: Scheduling 3000 ms timer to wait for shard ShardInformation [shardId=member-1-shard-shard2-config50, leaderAvailable=false, actorInitialized=false, followerSyncStatus=false, role=null, leaderId=null, activeMember=true]
06:05:46,749 PM [test-shard-dispatcher-19] [DEBUG] Shard - member-1-shard-shard2-config50: onReceiveRecover: Received message class akka.persistence.RecoveryCompleted$ from Actor[akka://test/deadLetters]
06:05:46,749 PM [test-shard-dispatcher-19] [INFO] Shard - member-1-shard-shard2-config50: Recovery completed  - Switching actor to Follower - last log index = -1, last log term = -1, snapshot index = -1, snapshot term = -1, journal size = 0
06:05:46,749 PM [test-shard-dispatcher-19] [DEBUG] DataTreeChangeListenerSupport - member-1-shard-shard2-config50: onLeadershipChange, isLeader: false, hasLeader : false
06:05:46,749 PM [test-shard-dispatcher-19] [DEBUG] Shard - member-1-shard-shard2-config50: onStateChanged: Closing all transaction chains because shard member-1-shard-shard2-config50 is no longer the leader
06:05:46,749 PM [test-shard-dispatcher-23] [DEBUG] Shard - member-1-shard-astronauts-config50 (Candidate): Received ElectionTimeout
06:05:46,749 PM [test-shard-dispatcher-19] [DEBUG] Shard - member-1-shard-shard2-config50 (Follower): Received TimeoutNow - switching to Candidate
06:05:46,749 PM [test-shard-dispatcher-19] [DEBUG] Shard - member-1-shard-shard2-config50 (Candidate): Election: Candidate has following voting peers: []
06:05:46,749 PM [test-shard-dispatcher-19] [DEBUG] Shard - member-1-shard-shard2-config50: Set currentTerm=1, votedFor=member-1-shard-shard2-config50
06:05:46,749 PM [test-shard-dispatcher-19] [INFO] Shard - member-1-shard-shard2-config50 (Candidate): Starting new election term 1
06:05:46,749 PM [test-shard-dispatcher-19] [INFO] Shard - member-1-shard-shard2-config50 (Follower) :- Switching from behavior Follower to Candidate, election term: 1
06:05:46,749 PM [test-shard-dispatcher-19] [DEBUG] MessageAssembler - member-1-shard-shard2-config50 (Follower): Closing
06:05:46,749 PM [test-shard-dispatcher-19] [DEBUG] DataTreeChangeListenerSupport - member-1-shard-shard2-config50: onLeadershipChange, isLeader: false, hasLeader : false
06:05:46,749 PM [test-shard-dispatcher-19] [DEBUG] Shard - member-1-shard-shard2-config50: onStateChanged: Closing all transaction chains because shard member-1-shard-shard2-config50 is no longer the leader
06:05:46,749 PM [test-shard-dispatcher-19] [DEBUG] Shard - member-1-shard-shard1-config50 (Candidate): Received ElectionTimeout
06:05:46,750 PM [test-akka.actor.default-dispatcher-21] [DEBUG] ShardManager - shard-manager-config50: Initializing shard [shard2]
06:05:46,750 PM [test-akka.actor.default-dispatcher-21] [DEBUG] ShardInformation - Shard member-1-shard-shard2-config50 is initialized
06:05:46,750 PM [test-shard-dispatcher-20] [DEBUG] Shard - member-1-shard-shard2-config50 (Candidate): Received ElectionTimeout
06:05:46,750 PM [test-akka.actor.default-dispatcher-21] [DEBUG] ShardInformation - Shard member-1-shard-shard2-config50 is initialized - notifying 1 OnShardInitialized callbacks
06:05:46,750 PM [test-akka.actor.default-dispatcher-21] [INFO] RoleChangeNotifier - RoleChangeNotifier for member-1-shard-shard2-config50 , received role change from null to Follower
06:05:46,750 PM [test-akka.actor.default-dispatcher-21] [INFO] RoleChangeNotifier - RoleChangeNotifier for member-1-shard-shard2-config50 , received role change from Follower to Candidate
06:05:46,750 PM [test-akka.actor.default-dispatcher-21] [DEBUG] ShardManager - shard-manager-config50: findLocalShard : astronauts
06:05:46,750 PM [test-akka.actor.default-dispatcher-22] [DEBUG] ShardManager - shard-manager-config50: onGetSnapshot
06:05:46,754 PM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManagerGetSnapshotReplyActor - shard-manager-config50: Expecting 3 shard snapshot replies
06:05:46,758 PM [test-shard-dispatcher-23] [DEBUG] Shard - member-1-shard-astronauts-config50 (Leader): Election: Leader has following peers: []
06:05:46,758 PM [test-shard-dispatcher-23] [INFO] Shard - member-1-shard-astronauts-config50 (Candidate) :- Switching from behavior Candidate to Leader, election term: 1
06:05:46,758 PM [test-shard-dispatcher-23] [DEBUG] DataTreeChangeListenerSupport - member-1-shard-astronauts-config50: onLeadershipChange, isLeader: true, hasLeader : true
06:05:46,758 PM [test-shard-dispatcher-19] [DEBUG] Shard - member-1-shard-shard1-config50 (Leader): Election: Leader has following peers: []
06:05:46,758 PM [test-shard-dispatcher-19] [INFO] Shard - member-1-shard-shard1-config50 (Candidate) :- Switching from behavior Candidate to Leader, election term: 1
06:05:46,758 PM [test-shard-dispatcher-19] [DEBUG] DataTreeChangeListenerSupport - member-1-shard-shard1-config50: onLeadershipChange, isLeader: true, hasLeader : true
06:05:46,759 PM [test-shard-dispatcher-20] [DEBUG] Shard - member-1-shard-shard2-config50 (Leader): Election: Leader has following peers: []
06:05:46,759 PM [test-shard-dispatcher-20] [INFO] Shard - member-1-shard-shard2-config50 (Candidate) :- Switching from behavior Candidate to Leader, election term: 1
06:05:46,759 PM [test-shard-dispatcher-20] [DEBUG] DataTreeChangeListenerSupport - member-1-shard-shard2-config50: onLeadershipChange, isLeader: true, hasLeader : true
06:05:46,760 PM [test-shard-dispatcher-23] [DEBUG] Shard - member-1-shard-astronauts-config50: became leader with frontend state for []
06:05:46,760 PM [test-shard-dispatcher-19] [DEBUG] Shard - member-1-shard-shard1-config50: became leader with frontend state for []
06:05:46,760 PM [test-akka.actor.default-dispatcher-22] [INFO] RoleChangeNotifier - RoleChangeNotifier for member-1-shard-astronauts-config50 , received role change from Candidate to Leader
06:05:46,760 PM [test-akka.actor.default-dispatcher-5] [INFO] RoleChangeNotifier - RoleChangeNotifier for member-1-shard-shard1-config50 , received role change from Candidate to Leader
06:05:46,760 PM [test-shard-dispatcher-20] [DEBUG] Shard - member-1-shard-shard2-config50: became leader with frontend state for []
06:05:46,760 PM [test-akka.actor.default-dispatcher-22] [INFO] RoleChangeNotifier - RoleChangeNotifier for member-1-shard-shard2-config50 , received role change from Candidate to Leader
06:05:46,764 PM [test-shard-dispatcher-23] [DEBUG] Shard - member-1-shard-astronauts-config50: onGetSnapshot
06:05:46,764 PM [test-shard-dispatcher-20] [DEBUG] Shard - member-1-shard-shard2-config50: onGetSnapshot
06:05:46,764 PM [test-shard-dispatcher-23] [DEBUG] Shard - member-1-shard-astronauts-config50: Capturing Snapshot : lastLogEntry is null. Using snapshot values lastAppliedIndex -1 and lastAppliedTerm -1 instead.
06:05:46,764 PM [test-akka.actor.default-dispatcher-22] [INFO] RoleChangeNotifier - RoleChangeNotifier for member-1-shard-astronauts-config50 , registered listener akka://test/user/$$l
06:05:46,764 PM [test-shard-dispatcher-20] [DEBUG] Shard - member-1-shard-shard2-config50: Capturing Snapshot : lastLogEntry is null. Using snapshot values lastAppliedIndex -1 and lastAppliedTerm -1 instead.
06:05:46,764 PM [test-akka.actor.default-dispatcher-5] [INFO] RoleChangeNotifier - RoleChangeNotifier for member-1-shard-shard2-config50 , registered listener akka://test/user/$$l
06:05:46,764 PM [test-akka.actor.default-dispatcher-22] [INFO] ShardManager - shard-manager-config50: Received LeaderStateChanged message: LeaderStateChanged [memberId=member-1-shard-astronauts-config50, leaderId=member-1-shard-astronauts-config50, leaderPayloadVersion=13]
06:05:46,764 PM [test-akka.actor.default-dispatcher-22] [INFO] ShardManager - shard-manager-config50: Received role changed for member-1-shard-astronauts-config50 from Candidate to Leader
06:05:46,764 PM [test-shard-dispatcher-19] [DEBUG] Shard - member-1-shard-shard1-config50: onGetSnapshot
06:05:46,764 PM [test-shard-dispatcher-19] [DEBUG] Shard - member-1-shard-shard1-config50: Capturing Snapshot : lastLogEntry is null. Using snapshot values lastAppliedIndex -1 and lastAppliedTerm -1 instead.
06:05:46,764 PM [test-akka.actor.default-dispatcher-22] [INFO] ShardManager - shard-manager-config50: Received LeaderStateChanged message: LeaderStateChanged [memberId=member-1-shard-shard2-config50, leaderId=member-1-shard-shard2-config50, leaderPayloadVersion=13]
06:05:46,764 PM [test-akka.actor.default-dispatcher-22] [INFO] ShardManager - shard-manager-config50: Received role changed for member-1-shard-shard2-config50 from Candidate to Leader
06:05:46,764 PM [test-akka.actor.default-dispatcher-22] [INFO] RoleChangeNotifier - RoleChangeNotifier for member-1-shard-shard1-config50 , registered listener akka://test/user/$$l
06:05:46,764 PM [test-akka.actor.default-dispatcher-22] [INFO] ShardManager - shard-manager-config50: Received LeaderStateChanged message: LeaderStateChanged [memberId=member-1-shard-shard1-config50, leaderId=member-1-shard-shard1-config50, leaderPayloadVersion=13]
06:05:46,764 PM [test-akka.actor.default-dispatcher-22] [INFO] ShardManager - shard-manager-config50: Received role changed for member-1-shard-shard1-config50 from Candidate to Leader
06:05:46,765 PM [test-akka.actor.default-dispatcher-22] [INFO] ShardManager - shard-manager-config50: All Shards are ready - data store config50 is ready
06:05:46,768 PM [test-shard-dispatcher-23] [DEBUG] Shard - member-1-shard-astronauts-config50: requesting serialization of snapshot MetadataShardDataTreeSnapshot{metadata={class org.opendaylight.controller.cluster.datastore.persisted.FrontendShardDataTreeSnapshotMetadata=FrontendShardDataTreeSnapshotMetadata{clients=[]}}}
06:05:46,768 PM [test-shard-dispatcher-19] [DEBUG] Shard - member-1-shard-shard1-config50: requesting serialization of snapshot MetadataShardDataTreeSnapshot{metadata={class org.opendaylight.controller.cluster.datastore.persisted.FrontendShardDataTreeSnapshotMetadata=FrontendShardDataTreeSnapshotMetadata{clients=[]}}}
06:05:46,768 PM [test-shard-dispatcher-20] [DEBUG] Shard - member-1-shard-shard2-config50: requesting serialization of snapshot MetadataShardDataTreeSnapshot{metadata={class org.opendaylight.controller.cluster.datastore.persisted.FrontendShardDataTreeSnapshotMetadata=FrontendShardDataTreeSnapshotMetadata{clients=[]}}}
06:05:46,774 PM [test-akka.actor.default-dispatcher-15] [DEBUG] ShardManagerGetSnapshotReplyActor - shard-manager-config50: Received GetSnapshotReply [id=member-1-shard-shard1-config50, snapshot=Snapshot [lastIndex=-1, lastTerm=-1, lastAppliedIndex=-1, lastAppliedTerm=-1, unAppliedEntries size=0, state=org.opendaylight.controller.cluster.datastore.persisted.ShardSnapshotState@7e76e24d, electionTerm=1, electionVotedFor=member-1-shard-shard1-config50, ServerConfigPayload=null]]
06:05:46,775 PM [test-akka.actor.default-dispatcher-15] [DEBUG] ShardManagerGetSnapshotReplyActor - shard-manager-config50: Received GetSnapshotReply [id=member-1-shard-shard2-config50, snapshot=Snapshot [lastIndex=-1, lastTerm=-1, lastAppliedIndex=-1, lastAppliedTerm=-1, unAppliedEntries size=0, state=org.opendaylight.controller.cluster.datastore.persisted.ShardSnapshotState@2c28a20e, electionTerm=1, electionVotedFor=member-1-shard-shard2-config50, ServerConfigPayload=null]]
06:05:46,775 PM [test-akka.actor.default-dispatcher-15] [DEBUG] ShardManagerGetSnapshotReplyActor - shard-manager-config50: Received GetSnapshotReply [id=member-1-shard-astronauts-config50, snapshot=Snapshot [lastIndex=-1, lastTerm=-1, lastAppliedIndex=-1, lastAppliedTerm=-1, unAppliedEntries size=0, state=org.opendaylight.controller.cluster.datastore.persisted.ShardSnapshotState@6505494c, electionTerm=1, electionVotedFor=member-1-shard-astronauts-config50, ServerConfigPayload=null]]
06:05:46,775 PM [test-akka.actor.default-dispatcher-15] [DEBUG] ShardManagerGetSnapshotReplyActor - shard-manager-config50: All shard snapshots received
06:05:46,776 PM [main] [INFO] ShardManagerTest - testRestoreFromSnapshot ending
06:05:46,877 PM [main] [INFO] TestActorFactory - Killing actor TestActor[akka://test/user/$$l]
06:05:46,888 PM [test-shard-dispatcher-23] [INFO] Shard - Stopping Shard member-1-shard-shard1-config50
06:05:46,888 PM [test-shard-dispatcher-20] [INFO] Shard - Stopping Shard member-1-shard-astronauts-config50
06:05:46,888 PM [test-shard-dispatcher-23] [DEBUG] MessageSlicer - member-1-shard-shard1-config50 (Leader)_slicer-id-215: Closing
06:05:46,888 PM [test-shard-dispatcher-20] [DEBUG] MessageSlicer - member-1-shard-astronauts-config50 (Leader)_slicer-id-214: Closing
06:05:46,888 PM [test-shard-dispatcher-23] [DEBUG] Shard - member-1-shard-shard1-config50: Aborting 0 pending queued transactions
06:05:46,888 PM [test-shard-dispatcher-20] [DEBUG] Shard - member-1-shard-astronauts-config50: Aborting 0 pending queued transactions
06:05:46,889 PM [test-shard-dispatcher-19] [INFO] Shard - Stopping Shard member-1-shard-shard2-config50
06:05:46,889 PM [test-shard-dispatcher-19] [DEBUG] MessageSlicer - member-1-shard-shard2-config50 (Leader)_slicer-id-216: Closing
06:05:46,889 PM [test-shard-dispatcher-19] [DEBUG] Shard - member-1-shard-shard2-config50: Aborting 0 pending queued transactions
06:05:46,889 PM [test-akka.actor.default-dispatcher-15] [INFO] ShardManager - Stopping ShardManager shard-manager-config50
06:05:46,891 PM [main] [INFO] ShardManagerTest - testOnCreateShardWithNoInitialSchemaContext starting
06:05:46,893 PM [test-akka.actor.default-dispatcher-15] [INFO] ShardManager - Starting ShardManager shard-manager-config51
06:05:46,895 PM [test-akka.actor.default-dispatcher-21] [INFO] ShardManager - Recovery complete : shard-manager-config51
06:05:46,904 PM [test-akka.actor.default-dispatcher-15] [DEBUG] ShardManager - shard-manager-config51: onCreateShard: CreateShard [moduleShardConfig=ModuleShardConfiguration [namespace=foo-ns, moduleName=foo-module, shardName=foo, shardMemberNames=[MemberName{name=member-1}], shardStrategyName=null], shardPropsCreator=org.opendaylight.controller.cluster.datastore.Shard$Builder@7e73f450]
06:05:46,905 PM [test-akka.actor.default-dispatcher-15] [DEBUG] ShardManager - shard-manager-config51 doCreateShard: shardId: member-1-shard-foo-config51, memberNames: [MemberName{name=member-1}], peerAddresses: {}, isActiveMember: true
06:05:46,905 PM [test-akka.actor.default-dispatcher-15] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1
06:05:46,905 PM [test-akka.actor.default-dispatcher-15] [DEBUG] ShardManager - Creating Shard member-1-shard-foo-config51
06:05:46,905 PM [test-akka.actor.default-dispatcher-15] [DEBUG] ShardManager - shard-manager-config51: findLocalShard : foo
06:05:46,905 PM [test-akka.actor.default-dispatcher-15] [DEBUG] ShardManager - shard-manager-config51: Scheduling 600 ms timer to wait for shard ShardInformation [shardId=member-1-shard-foo-config51, leaderAvailable=false, actorInitialized=false, followerSyncStatus=false, role=null, leaderId=null, activeMember=true]
06:05:46,906 PM [test-shard-dispatcher-19] [INFO] Shard - Shard created : member-1-shard-foo-config51, persistent : true
06:05:46,906 PM [test-shard-dispatcher-19] [INFO] Shard - Starting recovery for member-1-shard-foo-config51 with journal batch size 1
06:05:46,907 PM [test-akka.actor.default-dispatcher-21] [DEBUG] ShardSnapshotActor - Actor created Actor[akka://test/user/$B/member-1-shard-foo-config51/shard-member-1:snapshot-read#-1571839389]
06:05:46,907 PM [test-akka.actor.default-dispatcher-15] [INFO] RoleChangeNotifier - RoleChangeNotifier:akka://test@127.0.0.1:2565/user/$B/member-1-shard-foo-config51/member-1-shard-foo-config51-notifier#301079702 created and ready for shard:member-1-shard-foo-config51
06:05:46,911 PM [test-shard-dispatcher-19] [DEBUG] Shard - member-1-shard-foo-config51: onReceiveRecover: Received message class akka.persistence.RecoveryCompleted$ from Actor[akka://test/deadLetters]
06:05:46,911 PM [test-shard-dispatcher-19] [INFO] Shard - member-1-shard-foo-config51: Recovery completed  - Switching actor to Follower - last log index = -1, last log term = -1, snapshot index = -1, snapshot term = -1, journal size = 0
06:05:46,911 PM [test-akka.actor.default-dispatcher-22] [DEBUG] ShardManager - shard-manager-config51: Initializing shard [foo]
06:05:46,911 PM [test-akka.actor.default-dispatcher-22] [DEBUG] ShardInformation - Shard member-1-shard-foo-config51 is initialized
06:05:46,911 PM [test-shard-dispatcher-19] [DEBUG] DataTreeChangeListenerSupport - member-1-shard-foo-config51: onLeadershipChange, isLeader: false, hasLeader : false
06:05:46,911 PM [test-akka.actor.default-dispatcher-22] [DEBUG] ShardInformation - Shard member-1-shard-foo-config51 is initialized - notifying 1 OnShardInitialized callbacks
06:05:46,911 PM [test-shard-dispatcher-19] [DEBUG] Shard - member-1-shard-foo-config51: onStateChanged: Closing all transaction chains because shard member-1-shard-foo-config51 is no longer the leader
06:05:46,911 PM [test-akka.actor.default-dispatcher-22] [INFO] RoleChangeNotifier - RoleChangeNotifier for member-1-shard-foo-config51 , received role change from null to Follower
06:05:46,911 PM [test-shard-dispatcher-19] [DEBUG] Shard - member-1-shard-foo-config51 (Follower): Received TimeoutNow - switching to Candidate
06:05:46,911 PM [test-shard-dispatcher-19] [DEBUG] Shard - member-1-shard-foo-config51 (Candidate): Election: Candidate has following voting peers: []
06:05:46,911 PM [test-shard-dispatcher-19] [DEBUG] Shard - member-1-shard-foo-config51: Set currentTerm=1, votedFor=member-1-shard-foo-config51
06:05:46,911 PM [test-shard-dispatcher-19] [INFO] Shard - member-1-shard-foo-config51 (Candidate): Starting new election term 1
06:05:46,911 PM [test-shard-dispatcher-19] [INFO] Shard - member-1-shard-foo-config51 (Follower) :- Switching from behavior Follower to Candidate, election term: 1
06:05:46,911 PM [test-shard-dispatcher-19] [DEBUG] MessageAssembler - member-1-shard-foo-config51 (Follower): Closing
06:05:46,911 PM [test-shard-dispatcher-19] [DEBUG] DataTreeChangeListenerSupport - member-1-shard-foo-config51: onLeadershipChange, isLeader: false, hasLeader : false
06:05:46,911 PM [test-shard-dispatcher-19] [DEBUG] Shard - member-1-shard-foo-config51: onStateChanged: Closing all transaction chains because shard member-1-shard-foo-config51 is no longer the leader
06:05:46,911 PM [test-akka.actor.default-dispatcher-11] [INFO] RoleChangeNotifier - RoleChangeNotifier for member-1-shard-foo-config51 , received role change from Follower to Candidate
06:05:46,911 PM [main] [INFO] ShardManagerTest - testOnCreateShardWithNoInitialSchemaContext ending
06:05:46,912 PM [test-shard-dispatcher-19] [DEBUG] Shard - member-1-shard-foo-config51 (Candidate): Received ElectionTimeout
06:05:46,912 PM [test-shard-dispatcher-19] [DEBUG] Shard - member-1-shard-foo-config51 (Leader): Election: Leader has following peers: []
06:05:46,912 PM [test-shard-dispatcher-19] [INFO] Shard - member-1-shard-foo-config51 (Candidate) :- Switching from behavior Candidate to Leader, election term: 1
06:05:46,912 PM [test-shard-dispatcher-19] [DEBUG] DataTreeChangeListenerSupport - member-1-shard-foo-config51: onLeadershipChange, isLeader: true, hasLeader : true
06:05:46,912 PM [test-shard-dispatcher-19] [DEBUG] Shard - member-1-shard-foo-config51: became leader with frontend state for []
06:05:46,912 PM [test-akka.actor.default-dispatcher-22] [INFO] RoleChangeNotifier - RoleChangeNotifier for member-1-shard-foo-config51 , received role change from Candidate to Leader
06:05:46,913 PM [test-akka.actor.default-dispatcher-22] [INFO] RoleChangeNotifier - RoleChangeNotifier for member-1-shard-foo-config51 , registered listener akka://test/user/$B
06:05:46,913 PM [test-akka.actor.default-dispatcher-22] [INFO] ShardManager - shard-manager-config51: Received LeaderStateChanged message: LeaderStateChanged [memberId=member-1-shard-foo-config51, leaderId=member-1-shard-foo-config51, leaderPayloadVersion=13]
06:05:46,913 PM [test-akka.actor.default-dispatcher-22] [INFO] ShardManager - shard-manager-config51: Received role changed for member-1-shard-foo-config51 from Candidate to Leader
06:05:46,913 PM [test-akka.actor.default-dispatcher-22] [INFO] ShardManager - shard-manager-config51: All Shards are ready - data store config51 is ready
06:05:47,13 PM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/$B#-1672616]
06:05:47,24 PM [test-shard-dispatcher-19] [INFO] Shard - Stopping Shard member-1-shard-foo-config51
06:05:47,24 PM [test-shard-dispatcher-19] [DEBUG] MessageSlicer - member-1-shard-foo-config51 (Leader)_slicer-id-218: Closing
06:05:47,24 PM [test-shard-dispatcher-19] [DEBUG] Shard - member-1-shard-foo-config51: Aborting 0 pending queued transactions
06:05:47,29 PM [test-akka.actor.default-dispatcher-22] [INFO] ShardManager - Stopping ShardManager shard-manager-config51
06:05:47,31 PM [main] [INFO] ShardManagerTest - testGetSnapshot starting
06:05:47,34 PM [test-akka.actor.default-dispatcher-22] [INFO] ShardManager - Starting ShardManager shard-manager-config52
06:05:47,36 PM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Recovery complete : shard-manager-config52
06:05:47,36 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config52: Creating local shard: member-1-shard-shard2-config52
06:05:47,36 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config52: Creating local shard: member-1-shard-shard1-config52
06:05:47,144 PM [test-akka.actor.default-dispatcher-22] [DEBUG] ShardManager - shard-manager-config52: onGetSnapshot
06:05:47,145 PM [test-akka.actor.default-dispatcher-22] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1
06:05:47,145 PM [test-akka.actor.default-dispatcher-22] [DEBUG] ShardManager - Creating Shard member-1-shard-shard2-config52
06:05:47,145 PM [test-akka.actor.default-dispatcher-22] [DEBUG] ShardManager - Creating Shard member-1-shard-shard1-config52
06:05:47,146 PM [test-akka.actor.default-dispatcher-22] [DEBUG] ShardManager - shard-manager-config52: findLocalShard : shard1
06:05:47,146 PM [test-akka.actor.default-dispatcher-22] [DEBUG] ShardManager - shard-manager-config52: Scheduling 600 ms timer to wait for shard ShardInformation [shardId=member-1-shard-shard1-config52, leaderAvailable=false, actorInitialized=false, followerSyncStatus=false, role=null, leaderId=null, activeMember=true]
06:05:47,146 PM [test-shard-dispatcher-19] [INFO] Shard - Shard created : member-1-shard-shard2-config52, persistent : true
06:05:47,147 PM [test-shard-dispatcher-20] [INFO] Shard - Shard created : member-1-shard-shard1-config52, persistent : true
06:05:47,147 PM [test-shard-dispatcher-19] [INFO] Shard - Starting recovery for member-1-shard-shard2-config52 with journal batch size 1
06:05:47,148 PM [test-akka.actor.default-dispatcher-21] [INFO] RoleChangeNotifier - RoleChangeNotifier:akka://test@127.0.0.1:2565/user/$$m/member-1-shard-shard2-config52/member-1-shard-shard2-config52-notifier#893250387 created and ready for shard:member-1-shard-shard2-config52
06:05:47,148 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardSnapshotActor - Actor created Actor[akka://test/user/$$m/member-1-shard-shard2-config52/shard-member-1:snapshot-read#1017868447]
06:05:47,148 PM [test-akka.actor.default-dispatcher-21] [INFO] RoleChangeNotifier - RoleChangeNotifier:akka://test@127.0.0.1:2565/user/$$m/member-1-shard-shard1-config52/member-1-shard-shard1-config52-notifier#-1102981930 created and ready for shard:member-1-shard-shard1-config52
06:05:47,148 PM [test-shard-dispatcher-20] [INFO] Shard - Starting recovery for member-1-shard-shard1-config52 with journal batch size 1
06:05:47,148 PM [test-akka.actor.default-dispatcher-21] [DEBUG] ShardSnapshotActor - Actor created Actor[akka://test/user/$$m/member-1-shard-shard1-config52/shard-member-1:snapshot-read#-2078236069]
06:05:47,150 PM [test-shard-dispatcher-19] [DEBUG] Shard - member-1-shard-shard2-config52: onReceiveRecover: Received message class akka.persistence.RecoveryCompleted$ from Actor[akka://test/deadLetters]
06:05:47,150 PM [test-shard-dispatcher-19] [INFO] Shard - member-1-shard-shard2-config52: Recovery completed  - Switching actor to Follower - last log index = -1, last log term = -1, snapshot index = -1, snapshot term = -1, journal size = 0
06:05:47,150 PM [test-akka.actor.default-dispatcher-16] [DEBUG] ShardManager - shard-manager-config52: Initializing shard [shard2]
06:05:47,150 PM [test-shard-dispatcher-19] [DEBUG] DataTreeChangeListenerSupport - member-1-shard-shard2-config52: onLeadershipChange, isLeader: false, hasLeader : false
06:05:47,150 PM [test-akka.actor.default-dispatcher-16] [DEBUG] ShardInformation - Shard member-1-shard-shard2-config52 is initialized
06:05:47,150 PM [test-shard-dispatcher-19] [DEBUG] Shard - member-1-shard-shard2-config52: onStateChanged: Closing all transaction chains because shard member-1-shard-shard2-config52 is no longer the leader
06:05:47,150 PM [test-akka.actor.default-dispatcher-16] [INFO] RoleChangeNotifier - RoleChangeNotifier for member-1-shard-shard2-config52 , received role change from null to Follower
06:05:47,150 PM [test-shard-dispatcher-19] [DEBUG] Shard - member-1-shard-shard2-config52 (Follower): Received TimeoutNow - switching to Candidate
06:05:47,150 PM [test-shard-dispatcher-19] [DEBUG] Shard - member-1-shard-shard2-config52 (Candidate): Election: Candidate has following voting peers: []
06:05:47,150 PM [test-shard-dispatcher-19] [DEBUG] Shard - member-1-shard-shard2-config52: Set currentTerm=1, votedFor=member-1-shard-shard2-config52
06:05:47,150 PM [test-shard-dispatcher-19] [INFO] Shard - member-1-shard-shard2-config52 (Candidate): Starting new election term 1
06:05:47,150 PM [test-shard-dispatcher-19] [INFO] Shard - member-1-shard-shard2-config52 (Follower) :- Switching from behavior Follower to Candidate, election term: 1
06:05:47,150 PM [test-shard-dispatcher-19] [DEBUG] MessageAssembler - member-1-shard-shard2-config52 (Follower): Closing
06:05:47,150 PM [test-shard-dispatcher-19] [DEBUG] DataTreeChangeListenerSupport - member-1-shard-shard2-config52: onLeadershipChange, isLeader: false, hasLeader : false
06:05:47,150 PM [test-shard-dispatcher-19] [DEBUG] Shard - member-1-shard-shard2-config52: onStateChanged: Closing all transaction chains because shard member-1-shard-shard2-config52 is no longer the leader
06:05:47,151 PM [test-akka.actor.default-dispatcher-15] [INFO] RoleChangeNotifier - RoleChangeNotifier for member-1-shard-shard2-config52 , received role change from Follower to Candidate
06:05:47,151 PM [test-shard-dispatcher-19] [DEBUG] Shard - member-1-shard-shard1-config52: onReceiveRecover: Received message class akka.persistence.RecoveryCompleted$ from Actor[akka://test/deadLetters]
06:05:47,151 PM [test-shard-dispatcher-19] [INFO] Shard - member-1-shard-shard1-config52: Recovery completed  - Switching actor to Follower - last log index = -1, last log term = -1, snapshot index = -1, snapshot term = -1, journal size = 0
06:05:47,151 PM [test-akka.actor.default-dispatcher-15] [DEBUG] ShardManager - shard-manager-config52: Initializing shard [shard1]
06:05:47,151 PM [test-akka.actor.default-dispatcher-15] [DEBUG] ShardInformation - Shard member-1-shard-shard1-config52 is initialized
06:05:47,151 PM [test-shard-dispatcher-19] [DEBUG] DataTreeChangeListenerSupport - member-1-shard-shard1-config52: onLeadershipChange, isLeader: false, hasLeader : false
06:05:47,151 PM [test-akka.actor.default-dispatcher-15] [DEBUG] ShardInformation - Shard member-1-shard-shard1-config52 is initialized - notifying 1 OnShardInitialized callbacks
06:05:47,151 PM [test-shard-dispatcher-19] [DEBUG] Shard - member-1-shard-shard1-config52: onStateChanged: Closing all transaction chains because shard member-1-shard-shard1-config52 is no longer the leader
06:05:47,151 PM [test-akka.actor.default-dispatcher-15] [INFO] RoleChangeNotifier - RoleChangeNotifier for member-1-shard-shard1-config52 , received role change from null to Follower
06:05:47,151 PM [test-shard-dispatcher-19] [DEBUG] Shard - member-1-shard-shard1-config52 (Follower): Received TimeoutNow - switching to Candidate
06:05:47,151 PM [test-shard-dispatcher-19] [DEBUG] Shard - member-1-shard-shard1-config52 (Candidate): Election: Candidate has following voting peers: []
06:05:47,151 PM [test-shard-dispatcher-19] [DEBUG] Shard - member-1-shard-shard1-config52: Set currentTerm=1, votedFor=member-1-shard-shard1-config52
06:05:47,151 PM [test-shard-dispatcher-19] [INFO] Shard - member-1-shard-shard1-config52 (Candidate): Starting new election term 1
06:05:47,151 PM [test-shard-dispatcher-19] [INFO] Shard - member-1-shard-shard1-config52 (Follower) :- Switching from behavior Follower to Candidate, election term: 1
06:05:47,151 PM [test-shard-dispatcher-19] [DEBUG] MessageAssembler - member-1-shard-shard1-config52 (Follower): Closing
06:05:47,151 PM [test-shard-dispatcher-19] [DEBUG] DataTreeChangeListenerSupport - member-1-shard-shard1-config52: onLeadershipChange, isLeader: false, hasLeader : false
06:05:47,151 PM [test-shard-dispatcher-19] [DEBUG] Shard - member-1-shard-shard1-config52: onStateChanged: Closing all transaction chains because shard member-1-shard-shard1-config52 is no longer the leader
06:05:47,152 PM [test-akka.actor.default-dispatcher-13] [INFO] RoleChangeNotifier - RoleChangeNotifier for member-1-shard-shard1-config52 , received role change from Follower to Candidate
06:05:47,152 PM [test-akka.actor.default-dispatcher-13] [DEBUG] ShardManager - shard-manager-config52: findLocalShard : shard2
06:05:47,152 PM [test-akka.actor.default-dispatcher-13] [DEBUG] ShardManager - shard-manager-config52: onGetSnapshot
06:05:47,152 PM [test-akka.actor.default-dispatcher-13] [DEBUG] ShardManagerGetSnapshotReplyActor - shard-manager-config52: Expecting 2 shard snapshot replies
06:05:47,153 PM [test-shard-dispatcher-23] [DEBUG] Shard - member-1-shard-shard2-config52 (Candidate): Received ElectionTimeout
06:05:47,153 PM [test-shard-dispatcher-20] [DEBUG] Shard - member-1-shard-shard1-config52 (Candidate): Received ElectionTimeout
06:05:47,153 PM [test-shard-dispatcher-23] [DEBUG] Shard - member-1-shard-shard2-config52 (Leader): Election: Leader has following peers: []
06:05:47,153 PM [test-shard-dispatcher-23] [INFO] Shard - member-1-shard-shard2-config52 (Candidate) :- Switching from behavior Candidate to Leader, election term: 1
06:05:47,153 PM [test-shard-dispatcher-23] [DEBUG] DataTreeChangeListenerSupport - member-1-shard-shard2-config52: onLeadershipChange, isLeader: true, hasLeader : true
06:05:47,153 PM [test-shard-dispatcher-20] [DEBUG] Shard - member-1-shard-shard1-config52 (Leader): Election: Leader has following peers: []
06:05:47,153 PM [test-shard-dispatcher-20] [INFO] Shard - member-1-shard-shard1-config52 (Candidate) :- Switching from behavior Candidate to Leader, election term: 1
06:05:47,153 PM [test-shard-dispatcher-23] [DEBUG] Shard - member-1-shard-shard2-config52: became leader with frontend state for []
06:05:47,153 PM [test-shard-dispatcher-20] [DEBUG] DataTreeChangeListenerSupport - member-1-shard-shard1-config52: onLeadershipChange, isLeader: true, hasLeader : true
06:05:47,153 PM [test-shard-dispatcher-20] [DEBUG] Shard - member-1-shard-shard1-config52: became leader with frontend state for []
06:05:47,153 PM [test-shard-dispatcher-23] [DEBUG] Shard - member-1-shard-shard2-config52: onGetSnapshot
06:05:47,153 PM [test-shard-dispatcher-23] [DEBUG] Shard - member-1-shard-shard2-config52: Capturing Snapshot : lastLogEntry is null. Using snapshot values lastAppliedIndex -1 and lastAppliedTerm -1 instead.
06:05:47,153 PM [test-shard-dispatcher-20] [DEBUG] Shard - member-1-shard-shard1-config52: onGetSnapshot
06:05:47,153 PM [test-shard-dispatcher-20] [DEBUG] Shard - member-1-shard-shard1-config52: Capturing Snapshot : lastLogEntry is null. Using snapshot values lastAppliedIndex -1 and lastAppliedTerm -1 instead.
06:05:47,153 PM [test-shard-dispatcher-23] [DEBUG] Shard - member-1-shard-shard2-config52: requesting serialization of snapshot MetadataShardDataTreeSnapshot{metadata={class org.opendaylight.controller.cluster.datastore.persisted.FrontendShardDataTreeSnapshotMetadata=FrontendShardDataTreeSnapshotMetadata{clients=[]}}}
06:05:47,153 PM [test-shard-dispatcher-20] [DEBUG] Shard - member-1-shard-shard1-config52: requesting serialization of snapshot MetadataShardDataTreeSnapshot{metadata={class org.opendaylight.controller.cluster.datastore.persisted.FrontendShardDataTreeSnapshotMetadata=FrontendShardDataTreeSnapshotMetadata{clients=[]}}}
06:05:47,153 PM [test-akka.actor.default-dispatcher-16] [INFO] RoleChangeNotifier - RoleChangeNotifier for member-1-shard-shard1-config52 , received role change from Candidate to Leader
06:05:47,153 PM [test-akka.actor.default-dispatcher-16] [INFO] RoleChangeNotifier - RoleChangeNotifier for member-1-shard-shard1-config52 , registered listener akka://test/user/$$m
06:05:47,153 PM [test-akka.actor.default-dispatcher-16] [INFO] ShardManager - shard-manager-config52: Received LeaderStateChanged message: LeaderStateChanged [memberId=member-1-shard-shard1-config52, leaderId=member-1-shard-shard1-config52, leaderPayloadVersion=13]
06:05:47,154 PM [test-akka.actor.default-dispatcher-16] [INFO] ShardManager - shard-manager-config52: Received role changed for member-1-shard-shard1-config52 from Candidate to Leader
06:05:47,154 PM [test-akka.actor.default-dispatcher-16] [DEBUG] ShardManagerGetSnapshotReplyActor - shard-manager-config52: Received GetSnapshotReply [id=member-1-shard-shard1-config52, snapshot=Snapshot [lastIndex=-1, lastTerm=-1, lastAppliedIndex=-1, lastAppliedTerm=-1, unAppliedEntries size=0, state=org.opendaylight.controller.cluster.datastore.persisted.ShardSnapshotState@4f5eed46, electionTerm=1, electionVotedFor=member-1-shard-shard1-config52, ServerConfigPayload=null]]
06:05:47,154 PM [test-akka.actor.default-dispatcher-16] [INFO] RoleChangeNotifier - RoleChangeNotifier for member-1-shard-shard2-config52 , received role change from Candidate to Leader
06:05:47,154 PM [test-akka.actor.default-dispatcher-16] [INFO] RoleChangeNotifier - RoleChangeNotifier for member-1-shard-shard2-config52 , registered listener akka://test/user/$$m
06:05:47,154 PM [test-akka.actor.default-dispatcher-16] [INFO] ShardManager - shard-manager-config52: Received LeaderStateChanged message: LeaderStateChanged [memberId=member-1-shard-shard2-config52, leaderId=member-1-shard-shard2-config52, leaderPayloadVersion=13]
06:05:47,154 PM [test-akka.actor.default-dispatcher-16] [INFO] ShardManager - shard-manager-config52: Received role changed for member-1-shard-shard2-config52 from Candidate to Leader
06:05:47,154 PM [test-akka.actor.default-dispatcher-16] [INFO] ShardManager - shard-manager-config52: All Shards are ready - data store config52 is ready
06:05:47,154 PM [test-akka.actor.default-dispatcher-16] [DEBUG] ShardManagerGetSnapshotReplyActor - shard-manager-config52: Received GetSnapshotReply [id=member-1-shard-shard2-config52, snapshot=Snapshot [lastIndex=-1, lastTerm=-1, lastAppliedIndex=-1, lastAppliedTerm=-1, unAppliedEntries size=0, state=org.opendaylight.controller.cluster.datastore.persisted.ShardSnapshotState@5ea7f75, electionTerm=1, electionVotedFor=member-1-shard-shard2-config52, ServerConfigPayload=null]]
06:05:47,154 PM [test-akka.actor.default-dispatcher-16] [DEBUG] ShardManagerGetSnapshotReplyActor - shard-manager-config52: All shard snapshots received
06:05:47,170 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config52: onAddShardReplica: AddShardReplica[ShardName=astronauts]
06:05:47,171 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config52: Sending AddServer message to peer akka://test@127.0.0.1:2565/system/testProbe-608#188536134 for shard member-1-shard-astronauts-config52
06:05:47,172 PM [test-shard-dispatcher-19] [INFO] Shard - Shard created : member-1-shard-astronauts-config52, persistent : true
06:05:47,172 PM [test-akka.actor.default-dispatcher-21] [DEBUG] ShardManager - shard-manager-config52: Received AddServerReply{status=OK, leaderHint=} for shard astronauts from leader akka://test@127.0.0.1:2565/system/testProbe-608#188536134
06:05:47,172 PM [test-akka.actor.default-dispatcher-21] [DEBUG] ShardManager - shard-manager-config52: Leader shard successfully added the replica shard astronauts
06:05:47,172 PM [test-akka.actor.default-dispatcher-21] [DEBUG] ShardInformation - Sending new DatastoreContext to member-1-shard-astronauts-config52
06:05:47,172 PM [test-akka.actor.default-dispatcher-21] [DEBUG] ShardManager - shard-manager-config52: persisting the shard list [shard2, astronauts, shard1]
06:05:47,173 PM [test-akka.actor.default-dispatcher-21] [INFO] RoleChangeNotifier - RoleChangeNotifier:akka://test@127.0.0.1:2565/user/$$m/member-1-shard-astronauts-config52/member-1-shard-astronauts-config52-notifier#1558896740 created and ready for shard:member-1-shard-astronauts-config52
06:05:47,173 PM [test-akka.actor.default-dispatcher-21] [DEBUG] ShardSnapshotActor - Actor created Actor[akka://test/user/$$m/member-1-shard-astronauts-config52/shard-member-1:snapshot-read#1667286749]
06:05:47,173 PM [test-shard-dispatcher-19] [INFO] Shard - Starting recovery for member-1-shard-astronauts-config52 with journal batch size 1
06:05:47,173 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config52: findLocalShard : astronauts
06:05:47,173 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config52: Scheduling 600 ms timer to wait for shard ShardInformation [shardId=member-1-shard-astronauts-config52, leaderAvailable=false, actorInitialized=false, followerSyncStatus=false, role=null, leaderId=null, activeMember=true]
06:05:47,173 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config52 saved ShardManager snapshot successfully. Deleting the prev snapshot if available
06:05:47,174 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config52: Successfully deleted prior snapshots
06:05:47,175 PM [test-shard-dispatcher-19] [DEBUG] Shard - member-1-shard-astronauts-config52: onReceiveRecover: Received message class akka.persistence.RecoveryCompleted$ from Actor[akka://test/deadLetters]
06:05:47,175 PM [test-shard-dispatcher-19] [INFO] Shard - member-1-shard-astronauts-config52: Recovery completed  - Switching actor to Follower - last log index = -1, last log term = -1, snapshot index = -1, snapshot term = -1, journal size = 0
06:05:47,175 PM [test-shard-dispatcher-19] [DEBUG] DataTreeChangeListenerSupport - member-1-shard-astronauts-config52: onLeadershipChange, isLeader: false, hasLeader : false
06:05:47,175 PM [test-shard-dispatcher-19] [DEBUG] Shard - member-1-shard-astronauts-config52: onStateChanged: Closing all transaction chains because shard member-1-shard-astronauts-config52 is no longer the leader
06:05:47,175 PM [test-shard-dispatcher-19] [INFO] DefaultConfigParamsImpl - Trying to use custom RaftPolicy org.opendaylight.controller.cluster.raft.policy.DisableElectionsRaftPolicy
06:05:47,175 PM [test-shard-dispatcher-19] [DEBUG] Shard - member-1-shard-astronauts-config52: RaftPolicy used with prev.config org.opendaylight.controller.cluster.raft.policy.DisableElectionsRaftPolicy, RaftPolicy used with newConfig null
06:05:47,175 PM [test-shard-dispatcher-19] [DEBUG] Shard - member-1-shard-astronauts-config52: Re-initializing to Follower with previous leaderId null
06:05:47,175 PM [test-shard-dispatcher-19] [DEBUG] MessageAssembler - member-1-shard-astronauts-config52 (Follower): Closing
06:05:47,175 PM [test-shard-dispatcher-19] [DEBUG] DataTreeChangeListenerSupport - member-1-shard-astronauts-config52: onLeadershipChange, isLeader: false, hasLeader : false
06:05:47,175 PM [test-shard-dispatcher-19] [DEBUG] Shard - member-1-shard-astronauts-config52: onStateChanged: Closing all transaction chains because shard member-1-shard-astronauts-config52 is no longer the leader
06:05:47,175 PM [test-shard-dispatcher-19] [DEBUG] Shard - member-1-shard-astronauts-config52 (Follower): Received TimeoutNow - switching to Candidate
06:05:47,175 PM [test-shard-dispatcher-19] [DEBUG] Shard - member-1-shard-astronauts-config52 (Candidate): Election: Candidate has following voting peers: []
06:05:47,175 PM [test-shard-dispatcher-19] [DEBUG] Shard - member-1-shard-astronauts-config52: Set currentTerm=1, votedFor=member-1-shard-astronauts-config52
06:05:47,175 PM [test-shard-dispatcher-19] [INFO] Shard - member-1-shard-astronauts-config52 (Candidate): Starting new election term 1
06:05:47,175 PM [test-shard-dispatcher-19] [INFO] Shard - member-1-shard-astronauts-config52 (Follower) :- Switching from behavior Follower to Candidate, election term: 1
06:05:47,175 PM [test-shard-dispatcher-19] [DEBUG] MessageAssembler - member-1-shard-astronauts-config52 (Follower): Closing
06:05:47,176 PM [test-shard-dispatcher-19] [DEBUG] DataTreeChangeListenerSupport - member-1-shard-astronauts-config52: onLeadershipChange, isLeader: false, hasLeader : false
06:05:47,176 PM [test-shard-dispatcher-19] [DEBUG] Shard - member-1-shard-astronauts-config52: onStateChanged: Closing all transaction chains because shard member-1-shard-astronauts-config52 is no longer the leader
06:05:47,176 PM [test-akka.actor.default-dispatcher-22] [DEBUG] ShardManager - shard-manager-config52: Initializing shard [astronauts]
06:05:47,176 PM [test-akka.actor.default-dispatcher-22] [DEBUG] ShardInformation - Shard member-1-shard-astronauts-config52 is initialized
06:05:47,176 PM [test-akka.actor.default-dispatcher-22] [DEBUG] ShardInformation - Shard member-1-shard-astronauts-config52 is initialized - notifying 1 OnShardInitialized callbacks
06:05:47,176 PM [test-akka.actor.default-dispatcher-22] [INFO] RoleChangeNotifier - RoleChangeNotifier for member-1-shard-astronauts-config52 , received role change from null to Follower
06:05:47,176 PM [test-akka.actor.default-dispatcher-22] [INFO] RoleChangeNotifier - RoleChangeNotifier for member-1-shard-astronauts-config52 , received role change from Follower to Candidate
06:05:47,176 PM [test-akka.actor.default-dispatcher-22] [DEBUG] ShardManager - shard-manager-config52: onGetSnapshot
06:05:47,176 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManagerGetSnapshotReplyActor - shard-manager-config52: Expecting 3 shard snapshot replies
06:05:47,177 PM [test-shard-dispatcher-19] [DEBUG] Shard - member-1-shard-astronauts-config52 (Candidate): Received ElectionTimeout
06:05:47,177 PM [test-shard-dispatcher-19] [DEBUG] Shard - member-1-shard-astronauts-config52 (Leader): Election: Leader has following peers: []
06:05:47,177 PM [test-shard-dispatcher-19] [INFO] Shard - member-1-shard-astronauts-config52 (Candidate) :- Switching from behavior Candidate to Leader, election term: 1
06:05:47,177 PM [test-shard-dispatcher-19] [DEBUG] DataTreeChangeListenerSupport - member-1-shard-astronauts-config52: onLeadershipChange, isLeader: true, hasLeader : true
06:05:47,177 PM [test-shard-dispatcher-19] [DEBUG] Shard - member-1-shard-astronauts-config52: became leader with frontend state for []
06:05:47,177 PM [test-akka.actor.default-dispatcher-11] [INFO] RoleChangeNotifier - RoleChangeNotifier for member-1-shard-astronauts-config52 , received role change from Candidate to Leader
06:05:47,177 PM [test-shard-dispatcher-19] [DEBUG] Shard - member-1-shard-astronauts-config52: onGetSnapshot
06:05:47,177 PM [test-akka.actor.default-dispatcher-11] [INFO] RoleChangeNotifier - RoleChangeNotifier for member-1-shard-astronauts-config52 , registered listener akka://test/user/$$m
06:05:47,177 PM [test-shard-dispatcher-19] [DEBUG] Shard - member-1-shard-astronauts-config52: Capturing Snapshot : lastLogEntry is null. Using snapshot values lastAppliedIndex -1 and lastAppliedTerm -1 instead.
06:05:47,177 PM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - shard-manager-config52: Received LeaderStateChanged message: LeaderStateChanged [memberId=member-1-shard-astronauts-config52, leaderId=member-1-shard-astronauts-config52, leaderPayloadVersion=13]
06:05:47,177 PM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - shard-manager-config52: Received role changed for member-1-shard-astronauts-config52 from Candidate to Leader
06:05:47,177 PM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - shard-manager-config52: All Shards are ready - data store config52 is ready
06:05:47,177 PM [test-shard-dispatcher-19] [DEBUG] Shard - member-1-shard-astronauts-config52: requesting serialization of snapshot MetadataShardDataTreeSnapshot{metadata={class org.opendaylight.controller.cluster.datastore.persisted.FrontendShardDataTreeSnapshotMetadata=FrontendShardDataTreeSnapshotMetadata{clients=[]}}}
06:05:47,177 PM [test-shard-dispatcher-19] [DEBUG] Shard - member-1-shard-shard2-config52: onGetSnapshot
06:05:47,177 PM [test-shard-dispatcher-19] [DEBUG] Shard - member-1-shard-shard2-config52: Capturing Snapshot : lastLogEntry is null. Using snapshot values lastAppliedIndex -1 and lastAppliedTerm -1 instead.
06:05:47,178 PM [test-shard-dispatcher-19] [DEBUG] Shard - member-1-shard-shard2-config52: requesting serialization of snapshot MetadataShardDataTreeSnapshot{metadata={class org.opendaylight.controller.cluster.datastore.persisted.FrontendShardDataTreeSnapshotMetadata=FrontendShardDataTreeSnapshotMetadata{clients=[]}}}
06:05:47,178 PM [test-shard-dispatcher-19] [DEBUG] Shard - member-1-shard-shard1-config52: onGetSnapshot
06:05:47,178 PM [test-shard-dispatcher-19] [DEBUG] Shard - member-1-shard-shard1-config52: Capturing Snapshot : lastLogEntry is null. Using snapshot values lastAppliedIndex -1 and lastAppliedTerm -1 instead.
06:05:47,178 PM [test-shard-dispatcher-19] [DEBUG] Shard - member-1-shard-shard1-config52: requesting serialization of snapshot MetadataShardDataTreeSnapshot{metadata={class org.opendaylight.controller.cluster.datastore.persisted.FrontendShardDataTreeSnapshotMetadata=FrontendShardDataTreeSnapshotMetadata{clients=[]}}}
06:05:47,178 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManagerGetSnapshotReplyActor - shard-manager-config52: Received GetSnapshotReply [id=member-1-shard-astronauts-config52, snapshot=Snapshot [lastIndex=-1, lastTerm=-1, lastAppliedIndex=-1, lastAppliedTerm=-1, unAppliedEntries size=0, state=org.opendaylight.controller.cluster.datastore.persisted.ShardSnapshotState@31fded1, electionTerm=1, electionVotedFor=member-1-shard-astronauts-config52, ServerConfigPayload=null]]
06:05:47,178 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManagerGetSnapshotReplyActor - shard-manager-config52: Received GetSnapshotReply [id=member-1-shard-shard1-config52, snapshot=Snapshot [lastIndex=-1, lastTerm=-1, lastAppliedIndex=-1, lastAppliedTerm=-1, unAppliedEntries size=0, state=org.opendaylight.controller.cluster.datastore.persisted.ShardSnapshotState@68cc5812, electionTerm=1, electionVotedFor=member-1-shard-shard1-config52, ServerConfigPayload=null]]
06:05:47,178 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManagerGetSnapshotReplyActor - shard-manager-config52: Received GetSnapshotReply [id=member-1-shard-shard2-config52, snapshot=Snapshot [lastIndex=-1, lastTerm=-1, lastAppliedIndex=-1, lastAppliedTerm=-1, unAppliedEntries size=0, state=org.opendaylight.controller.cluster.datastore.persisted.ShardSnapshotState@4086c8d7, electionTerm=1, electionVotedFor=member-1-shard-shard2-config52, ServerConfigPayload=null]]
06:05:47,178 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManagerGetSnapshotReplyActor - shard-manager-config52: All shard snapshots received
06:05:47,179 PM [main] [INFO] ShardManagerTest - testGetSnapshot ending
06:05:47,280 PM [main] [INFO] TestActorFactory - Killing actor TestActor[akka://test/user/$$m]
06:05:47,291 PM [test-shard-dispatcher-18] [INFO] Shard - Stopping Shard member-1-shard-shard1-config52
06:05:47,291 PM [test-shard-dispatcher-18] [DEBUG] MessageSlicer - member-1-shard-shard1-config52 (Leader)_slicer-id-222: Closing
06:05:47,291 PM [test-shard-dispatcher-23] [INFO] Shard - Stopping Shard member-1-shard-astronauts-config52
06:05:47,291 PM [test-shard-dispatcher-18] [DEBUG] Shard - member-1-shard-shard1-config52: Aborting 0 pending queued transactions
06:05:47,291 PM [test-shard-dispatcher-23] [DEBUG] MessageSlicer - member-1-shard-astronauts-config52 (Leader)_slicer-id-224: Closing
06:05:47,291 PM [test-shard-dispatcher-19] [INFO] Shard - Stopping Shard member-1-shard-shard2-config52
06:05:47,291 PM [test-shard-dispatcher-19] [DEBUG] MessageSlicer - member-1-shard-shard2-config52 (Leader)_slicer-id-221: Closing
06:05:47,291 PM [test-shard-dispatcher-23] [DEBUG] Shard - member-1-shard-astronauts-config52: Aborting 0 pending queued transactions
06:05:47,292 PM [test-shard-dispatcher-19] [DEBUG] Shard - member-1-shard-shard2-config52: Aborting 0 pending queued transactions
06:05:47,292 PM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Stopping ShardManager shard-manager-config52
06:05:47,294 PM [main] [INFO] ShardManagerTest - testWhenMultipleShardsPresentSyncStatusMustBeTrueForAllShards starting
06:05:47,297 PM [main] [INFO] ShardManager - Starting ShardManager shard-manager-config53
06:05:47,299 PM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Recovery complete : shard-manager-config53
06:05:47,299 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config53: Creating local shard: member-1-shard-default-config53
06:05:47,299 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config53: Creating local shard: member-1-shard-astronauts-config53
06:05:47,398 PM [main] [INFO] ShardManager - shard-manager-config53: Received role changed for member-1-shard-default-config53 from Follower to Leader
06:05:47,398 PM [main] [INFO] ShardManager - shard-manager-config53: Received role changed for member-1-shard-astronauts-config53 from Follower to Leader
06:05:47,398 PM [main] [INFO] ShardManager - shard-manager-config53: Received role changed for member-1-shard-astronauts-config53 from Leader to Follower
06:05:47,398 PM [main] [INFO] ShardManager - shard-manager-config53 Received follower initial sync status for member-1-shard-astronauts-config53 status sync done true
06:05:47,398 PM [main] [INFO] ShardManagerTest - testWhenMultipleShardsPresentSyncStatusMustBeTrueForAllShards ending
06:05:47,499 PM [main] [INFO] TestActorFactory - Killing actor TestActor[akka://test/user/$$n]
06:05:47,510 PM [main] [INFO] ShardManager - Stopping ShardManager shard-manager-config53
06:05:47,511 PM [main] [INFO] ShardManagerTest - testAddShardReplicaWithFindPrimaryTimeout starting
06:05:47,514 PM [test-akka.actor.default-dispatcher-22] [INFO] ShardManager - Starting ShardManager shard-manager-config54
06:05:47,516 PM [test-akka.actor.default-dispatcher-21] [INFO] ShardManager - Recovery complete : shard-manager-config54
06:05:47,524 PM [test-akka.actor.default-dispatcher-22] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1
06:05:47,524 PM [test-akka.actor.default-dispatcher-22] [INFO] ShardManager - shard-manager-config54: Received MemberUp: memberName: MemberName{name=member-2}, address: akka://non-existent@127.0.0.1:5
06:05:47,524 PM [test-akka.actor.default-dispatcher-22] [INFO] ShardManager - shard-manager-config54: All Shards are ready - data store config54 is ready
06:05:47,524 PM [test-akka.actor.default-dispatcher-22] [DEBUG] ShardManager - shard-manager-config54: onAddShardReplica: AddShardReplica[ShardName=astronauts]
06:05:47,525 PM [test-akka.actor.default-dispatcher-22] [DEBUG] ShardManager - shard-manager-config54: In findPrimary: org.opendaylight.controller.cluster.datastore.messages.FindPrimary [shardName=astronauts, waitUntilReady=true]
06:05:47,525 PM [test-akka.actor.default-dispatcher-22] [DEBUG] ShardManager - shard-manager-config54: findPrimary for astronauts forwarding to remote ShardManager akka://non-existent@127.0.0.1:5/user/shardmanager-config54, visitedAddresses: [akka://test@127.0.0.1:2550/user/shardmanager-config54]
06:05:47,550 PM [test-akka.actor.default-dispatcher-22] [WARN] Materializer - [outbound connection to [akka://non-existent@127.0.0.1:5], control stream] Upstream failed, cause: StreamTcpException: Tcp command [Connect(127.0.0.1/<unresolved>:5,None,List(),Some(5000 milliseconds),true)] failed because of java.net.ConnectException: Connection refused
06:05:47,550 PM [test-akka.actor.default-dispatcher-22] [WARN] Materializer - [outbound connection to [akka://non-existent@127.0.0.1:5], message stream] Upstream failed, cause: StreamTcpException: Tcp command [Connect(127.0.0.1/<unresolved>:5,None,List(),Some(5000 milliseconds),true)] failed because of java.net.ConnectException: Connection refused
06:05:47,743 PM [test-akka.actor.default-dispatcher-22] [DEBUG] ShardManager - shard-manager-config54: Received failure from FindPrimary for shard astronauts
akka.pattern.AskTimeoutException: Ask timed out on [Actor[akka://test/user/shardmanager-config54#1368288848]] after [200 ms]. Message of type [org.opendaylight.controller.cluster.datastore.messages.FindPrimary]. A typical reason for `AskTimeoutException` is that the recipient actor didn't send a reply.
06:05:47,744 PM [main] [INFO] ShardManagerTest - testAddShardReplicaWithFindPrimaryTimeout ending
06:05:47,845 PM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/shardmanager-config54#1368288848]
06:05:47,856 PM [test-akka.actor.default-dispatcher-22] [INFO] ShardManager - Stopping ShardManager shard-manager-config54
06:05:47,858 PM [main] [INFO] ShardManagerTest - testOnCreateShard starting
06:05:47,860 PM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Starting ShardManager shard-manager-config55
06:05:47,861 PM [test-akka.actor.default-dispatcher-22] [INFO] ShardManager - Recovery complete : shard-manager-config55
06:05:47,861 PM [test-akka.actor.default-dispatcher-22] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1
06:05:47,872 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config55: onCreateShard: CreateShard [moduleShardConfig=ModuleShardConfiguration [namespace=foo-ns, moduleName=foo-module, shardName=foo, shardMemberNames=[MemberName{name=member-1}, MemberName{name=member-5}, MemberName{name=member-6}], shardStrategyName=null], shardPropsCreator=org.opendaylight.controller.cluster.datastore.Shard$Builder@1b6b0c43]
06:05:47,872 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config55 doCreateShard: shardId: member-1-shard-foo-config55, memberNames: [MemberName{name=member-1}, MemberName{name=member-5}, MemberName{name=member-6}], peerAddresses: {member-6-shard-foo-config55=null, member-5-shard-foo-config55=null}, isActiveMember: true
06:05:47,872 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config55: findLocalShard : foo
06:05:47,872 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config55: Scheduling 300000 ms timer to wait for shard ShardInformation [shardId=member-1-shard-foo-config55, leaderAvailable=false, actorInitialized=false, followerSyncStatus=false, role=null, leaderId=null, activeMember=true]
06:05:47,875 PM [test-shard-dispatcher-20] [INFO] Shard - Shard created : member-1-shard-foo-config55, persistent : false
06:05:47,878 PM [test-shard-dispatcher-20] [INFO] Shard - Starting recovery for member-1-shard-foo-config55 with journal batch size 1
06:05:47,878 PM [test-akka.actor.default-dispatcher-21] [DEBUG] ShardSnapshotActor - Actor created Actor[akka://test/user/$C/member-1-shard-foo-config55/shard-member-1:snapshot-read#686105385]
06:05:47,879 PM [test-akka.actor.default-dispatcher-11] [INFO] RoleChangeNotifier - RoleChangeNotifier:akka://test@127.0.0.1:2565/user/$C/member-1-shard-foo-config55/member-1-shard-foo-config55-notifier#860942541 created and ready for shard:member-1-shard-foo-config55
06:05:47,887 PM [test-shard-dispatcher-20] [DEBUG] Shard - member-1-shard-foo-config55: onReceiveRecover: Received message class akka.persistence.RecoveryCompleted$ from Actor[akka://test/deadLetters]
06:05:47,887 PM [test-shard-dispatcher-20] [INFO] Shard - member-1-shard-foo-config55: Recovery completed  - Switching actor to Follower - last log index = -1, last log term = -1, snapshot index = -1, snapshot term = -1, journal size = 0
06:05:47,887 PM [test-akka.actor.default-dispatcher-22] [DEBUG] ShardManager - shard-manager-config55: Initializing shard [foo]
06:05:47,887 PM [test-shard-dispatcher-20] [DEBUG] DataTreeChangeListenerSupport - member-1-shard-foo-config55: onLeadershipChange, isLeader: false, hasLeader : false
06:05:47,887 PM [test-akka.actor.default-dispatcher-22] [DEBUG] ShardInformation - Shard member-1-shard-foo-config55 is initialized
06:05:47,887 PM [test-shard-dispatcher-20] [DEBUG] Shard - member-1-shard-foo-config55: onStateChanged: Closing all transaction chains because shard member-1-shard-foo-config55 is no longer the leader
06:05:47,887 PM [test-akka.actor.default-dispatcher-22] [DEBUG] ShardInformation - Shard member-1-shard-foo-config55 is initialized - notifying 1 OnShardInitialized callbacks
06:05:47,887 PM [test-akka.actor.default-dispatcher-15] [INFO] RoleChangeNotifier - RoleChangeNotifier for member-1-shard-foo-config55 , received role change from null to Follower
06:05:47,888 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config55: onCreateShard: CreateShard [moduleShardConfig=ModuleShardConfiguration [namespace=foo-ns, moduleName=foo-module, shardName=foo, shardMemberNames=[MemberName{name=member-1}, MemberName{name=member-5}, MemberName{name=member-6}], shardStrategyName=null], shardPropsCreator=org.opendaylight.controller.cluster.datastore.Shard$Builder@1b6b0c43]
06:05:47,888 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config55: Shard foo already exists
06:05:47,888 PM [main] [INFO] ShardManagerTest - testOnCreateShard ending
06:05:47,888 PM [test-akka.actor.default-dispatcher-11] [INFO] RoleChangeNotifier - RoleChangeNotifier for member-1-shard-foo-config55 , registered listener akka://test/user/$C
06:05:47,888 PM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - shard-manager-config55: Received role changed for member-1-shard-foo-config55 from null to Follower
06:05:47,989 PM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/$C#-1319225712]
06:05:48,0 PM [test-shard-dispatcher-20] [INFO] Shard - Stopping Shard member-1-shard-foo-config55
06:05:48,0 PM [test-shard-dispatcher-20] [DEBUG] MessageAssembler - member-1-shard-foo-config55 (Follower): Closing
06:05:48,0 PM [test-shard-dispatcher-20] [DEBUG] Shard - member-1-shard-foo-config55: Aborting 0 pending queued transactions
06:05:48,1 PM [test-akka.actor.default-dispatcher-21] [INFO] ShardManager - Stopping ShardManager shard-manager-config55
06:05:48,2 PM [test-akka.actor.default-dispatcher-21] [INFO] ShardManager - Stopping ShardManager shard-manager-config35
06:05:48,2 PM [test-akka.actor.default-dispatcher-22] [INFO] ShardManager - Stopping ShardManager shard-manager-config1
06:05:48,2 PM [test-akka.actor.default-dispatcher-21] [INFO] ShardManager - Stopping ShardManager shard-manager-config43
06:05:48,2 PM [test-akka.actor.default-dispatcher-21] [INFO] ShardManager - Stopping ShardManager shard-manager-config11
06:05:48,2 PM [test-akka.actor.default-dispatcher-21] [INFO] ShardManager - Stopping ShardManager shard-manager-config21
06:05:48,2 PM [test-akka.actor.default-dispatcher-22] [INFO] ShardManager - Stopping ShardManager shard-manager-config46
06:05:48,3 PM [test-akka.actor.default-dispatcher-22] [INFO] RemoteActorRefProvider$RemotingTerminator - Shutting down remote daemon.
06:05:48,3 PM [test-akka.actor.default-dispatcher-22] [INFO] RemoteActorRefProvider$RemotingTerminator - Remote daemon shut down; proceeding with flushing remote transports.
[WARN] [01/08/2024 18:05:48.013] [test-akka.actor.internal-dispatcher-2] [Cluster(akka://test)] Could not unregister Cluster JMX MBean with name=akka:type=Cluster as it was not found. If you are running multiple clusters in the same JVM, set 'akka.cluster.jmx.multi-mbeans-in-same-jvm = on' in config