01:51:39,503 PM [test-akka.actor.default-dispatcher-6] [INFO] Slf4jLogger - Slf4jLogger started 01:51:39,537 PM [test-akka.actor.default-dispatcher-6] [INFO] ArteryTransport - Remoting started with transport [Artery tcp]; listening on address [akka://test@127.0.0.1:2565] with UID [7831136831904681292] 01:51:39,537 PM [test-akka.actor.default-dispatcher-6] [INFO] Cluster - Cluster Node [akka://test@127.0.0.1:2565] - Starting up, Akka version [2.6.21] ... 01:51:39,539 PM [test-akka.actor.default-dispatcher-6] [INFO] Cluster - Cluster Node [akka://test@127.0.0.1:2565] - Registered cluster JMX MBean [akka:type=Cluster] 01:51:39,539 PM [test-akka.actor.default-dispatcher-6] [INFO] Cluster - Cluster Node [akka://test@127.0.0.1:2565] - Started up successfully 01:51:39,540 PM [test-akka.actor.default-dispatcher-6] [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 01:51:39,541 PM [test-akka.actor.default-dispatcher-6] [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 01:51:40,292 PM [test-akka.actor.default-dispatcher-11] [INFO] EmptyLocalActorRef - Message [org.opendaylight.controller.cluster.common.actor.Monitor] from Actor[akka://test/user/$a#-352570958] 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'. 01:51:40,310 PM [test-akka.actor.default-dispatcher-6] [INFO] ShardManager - Starting ShardManager shard-manager-config1 01:51:40,376 PM [test-akka.actor.default-dispatcher-6] [INFO] ShardManager - Recovery complete : shard-manager-config1 01:51:40,377 PM [test-akka.actor.default-dispatcher-6] [DEBUG] ShardManager - shard-manager-config1: Creating local shard: member-1-shard-default-config1 01:51:40,393 PM [test-akka.actor.default-dispatcher-6] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1 01:51:40,394 PM [test-akka.actor.default-dispatcher-6] [DEBUG] ShardManager - Creating Shard member-1-shard-default-config1 01:51:40,394 PM [test-akka.actor.default-dispatcher-6] [DEBUG] ShardManager - shard-manager-config1: Initializing shard [default] 01:51:40,394 PM [test-akka.actor.default-dispatcher-6] [DEBUG] ShardInformation - Shard member-1-shard-default-config1 is initialized 01:51:40,395 PM [test-akka.actor.default-dispatcher-6] [INFO] ShardManager - shard-manager-config1: Received role changed for member-1-shard-default-config1 from null to Follower 01:51:40,396 PM [test-akka.actor.default-dispatcher-6] [DEBUG] ShardManager - shard-manager-config1: onChangeShardServersVotingStatus: ChangeShardMembersVotingStatus [shardName=default, meberVotingStatusMap={member-2=true}] 01:51:40,398 PM [test-akka.actor.default-dispatcher-6] [DEBUG] ShardManager - shard-manager-config1: findLocalShard : default 01:51:40,402 PM [test-akka.actor.default-dispatcher-6] [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 01:51:40,405 PM [test-akka.actor.default-dispatcher-6] [DEBUG] ShardManager - shard-manager-config1: Received ServerChangeReply{status=NO_LEADER} from local shard akka://test/user/member-1-shard-default-config1 01:51:40,405 PM [test-akka.actor.default-dispatcher-6] [WARN] ShardManager - shard-manager-config1: ChangeServersVotingStatus failed for shard default with status NO_LEADER 01:51:40,562 PM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/member-1-shard-default-config1#2062027126] 01:51:40,593 PM [main] [INFO] ShardManagerTest - testOnReceiveFindPrimaryWaitForShardLeader starting 01:51:40,600 PM [test-akka.actor.default-dispatcher-6] [INFO] ShardManager - Starting ShardManager shard-manager-config2 01:51:40,601 PM [test-akka.actor.default-dispatcher-6] [INFO] EmptyLocalActorRef - Message [org.opendaylight.controller.cluster.common.actor.Monitor] from Actor[akka://test/user/$b#2067750673] 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'. 01:51:40,605 PM [test-akka.actor.default-dispatcher-6] [INFO] ShardManager - Recovery complete : shard-manager-config2 01:51:40,605 PM [test-akka.actor.default-dispatcher-6] [DEBUG] ShardManager - shard-manager-config2: Creating local shard: member-1-shard-default-config2 01:51:40,613 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1 01:51:40,613 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - Creating Shard member-1-shard-default-config2 01:51:40,618 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config2: In findPrimary: org.opendaylight.controller.cluster.datastore.messages.FindPrimary [shardName=default, waitUntilReady=true] 01:51:40,627 PM [test-akka.actor.default-dispatcher-10] [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] 01:51:40,764 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config2: Initializing shard [default] 01:51:40,764 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardInformation - Shard member-1-shard-default-config2 is initialized 01:51:40,764 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardInformation - Shard member-1-shard-default-config2 is initialized - notifying 1 OnShardInitialized callbacks 01:51:40,914 PM [test-akka.actor.default-dispatcher-16] [INFO] ShardManager - shard-manager-config2: Received role changed for member-1-shard-default-config2 from Candidate to Leader 01:51:40,914 PM [test-akka.actor.default-dispatcher-16] [DEBUG] ShardInformation - Shard member-1-shard-default-config2 is initialized - notifying 1 OnShardInitialized callbacks 01:51:41,146 PM [test-akka.actor.default-dispatcher-16] [INFO] ShardManager - shard-manager-config2: Received LeaderStateChanged message: LeaderStateChanged [memberId=member-1-shard-default-config2, leaderId=member-1-shard-default-config2, leaderPayloadVersion=13] 01:51:41,147 PM [test-akka.actor.default-dispatcher-16] [DEBUG] ShardInformation - Shard member-1-shard-default-config2 is ready - notifying 1 OnShardInitialized callbacks 01:51:41,149 PM [test-akka.actor.default-dispatcher-16] [DEBUG] ShardManager - shard-manager-config2: Found primary for default: LocalPrimaryShardFound [primaryPath=akka://test@127.0.0.1:2565/user/member-1-shard-default-config#-213851760, localShardDataTree=org.opendaylight.yangtools.yang.data.tree.api.DataTree$MockitoMock$Kbwo7KiD@721e04f1] 01:51:41,150 PM [test-akka.actor.default-dispatcher-16] [INFO] ShardManager - shard-manager-config2: All Shards are ready - data store config2 is ready 01:51:41,350 PM [main] [INFO] ShardManagerTest - testOnReceiveFindPrimaryWaitForShardLeader ending 01:51:41,451 PM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/$b#2067750673] 01:51:41,464 PM [test-akka.actor.default-dispatcher-16] [INFO] ShardManager - Stopping ShardManager shard-manager-config2 01:51:41,483 PM [main] [INFO] ShardManager - Starting ShardManager shard-manager-config3 01:51:41,486 PM [test-akka.actor.default-dispatcher-14] [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'. 01:51:41,489 PM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - Recovery complete : shard-manager-config3 01:51:41,489 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config3: Creating local shard: member-1-shard-default-config3 01:51:41,586 PM [main] [INFO] ShardManager - shard-manager-config3: Received role changed for member-1-shard-default-config3 from Follower to Candidate 01:51:41,587 PM [main] [INFO] ShardManager - shard-manager-config3 Received follower initial sync status for member-1-shard-default-config3 status sync done true 01:51:41,689 PM [main] [INFO] TestActorFactory - Killing actor TestActor[akka://test/user/$$a] 01:51:41,702 PM [main] [INFO] ShardManager - Stopping ShardManager shard-manager-config3 01:51:41,745 PM [cluster-test-akka.actor.default-dispatcher-4] [INFO] Slf4jLogger - Slf4jLogger started 01:51:41,785 PM [cluster-test-akka.actor.default-dispatcher-4] [INFO] ArteryTransport - Remoting started with transport [Artery tcp]; listening on address [akka://cluster-test@127.0.0.1:2558] with UID [1189843755475515946] 01:51:41,786 PM [cluster-test-akka.actor.default-dispatcher-4] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2558] - Starting up, Akka version [2.6.21] ... 01:51:41,799 PM [cluster-test-akka.actor.default-dispatcher-4] [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 01:51:41,799 PM [cluster-test-akka.actor.default-dispatcher-4] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2558] - Started up successfully 01:51:41,819 PM [cluster-test-akka.actor.default-dispatcher-4] [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 01:51:41,820 PM [cluster-test-akka.actor.default-dispatcher-4] [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 01:51:41,870 PM [cluster-test-akka.actor.default-dispatcher-10] [INFO] ShardManager - Starting ShardManager shard-manager-config4 01:51:41,870 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'. 01:51:41,887 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 01:51:41,888 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) 01:51:41,910 PM [cluster-test-akka.actor.default-dispatcher-4] [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] 01:51:41,933 PM [cluster-test-akka.actor.default-dispatcher-13] [INFO] ShardManager - Recovery complete : shard-manager-config4 01:51:41,933 PM [cluster-test-akka.actor.default-dispatcher-13] [DEBUG] ShardManager - shard-manager-config4: Creating local shard: member-1-shard-default-config4 01:51:41,934 PM [cluster-test-akka.actor.default-dispatcher-13] [DEBUG] ShardManager - shard-manager-config4: Creating local shard: member-1-shard-astronauts-config4 01:51:41,935 PM [cluster-test-akka.actor.default-dispatcher-4] [INFO] ShardManager - shard-manager-config4: Received MemberUp: memberName: MemberName{name=member-1}, address: akka://cluster-test@127.0.0.1:2558 01:51:41,935 PM [cluster-test-akka.actor.default-dispatcher-4] [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 01:51:41,935 PM [cluster-test-akka.actor.default-dispatcher-4] [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 01:51:41,941 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] Slf4jLogger - Slf4jLogger started 01:51:41,978 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 [-4517126803626714297] 01:51:41,980 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] ... 01:51:41,993 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 01:51:41,993 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2559] - Started up successfully 01:51:42,7 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 01:51:42,7 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 01:51:42,18 PM [main] [ERROR] ShardManagerTest - Mock Shard Leader Actor : TestActor[akka://cluster-test/user/member-2-shard-default-config4] 01:51:42,43 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'. 01:51:42,57 PM [cluster-test-akka.actor.default-dispatcher-10] [INFO] ShardManager - Starting ShardManager shard-manager-config4 01:51:42,68 PM [main] [ERROR] ShardManagerTest - Forwarding actor : Actor[akka://cluster-test/user/shardmanager-config4/member-2-shard-default-config4#-138760396] 01:51:42,102 PM [cluster-test-akka.actor.default-dispatcher-13] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1 01:51:42,103 PM [cluster-test-akka.actor.default-dispatcher-13] [DEBUG] ShardManager - Creating Shard member-1-shard-default-config4 01:51:42,103 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 01:51:42,103 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-1-shard-default-config 01:51:42,104 PM [cluster-test-akka.actor.default-dispatcher-13] [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#-954367046] 01:51:42,104 PM [cluster-test-akka.actor.default-dispatcher-13] [DEBUG] ShardManager - Creating Shard member-1-shard-astronauts-config4 01:51:42,104 PM [cluster-test-akka.actor.default-dispatcher-13] [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 01:51:42,104 PM [cluster-test-akka.actor.default-dispatcher-13] [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 01:51:42,104 PM [cluster-test-akka.actor.default-dispatcher-13] [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#-954367046] 01:51:42,104 PM [cluster-test-akka.actor.default-dispatcher-13] [DEBUG] ShardManager - shard-manager-config4: Initializing shard [default] 01:51:42,104 PM [cluster-test-akka.actor.default-dispatcher-13] [DEBUG] ShardInformation - Shard member-1-shard-default-config4 is initialized 01:51:42,105 PM [cluster-test-akka.actor.default-dispatcher-13] [INFO] ShardManager - shard-manager-config4: Received LeaderStateChanged message: LeaderStateChanged [memberId=member-1-shard-default-config4, leaderId=member-2-shard-default-config4, leaderPayloadVersion=12] 01:51:42,115 PM [cluster-test-akka.actor.default-dispatcher-13] [INFO] ShardManager - shard-manager-config4: Received role changed for member-1-shard-default-config4 from Candidate to Follower 01:51:42,125 PM [cluster-test-akka.actor.default-dispatcher-13] [INFO] ShardManager - Recovery complete : shard-manager-config4 01:51:42,125 PM [cluster-test-akka.actor.default-dispatcher-13] [DEBUG] ShardManager - shard-manager-config4: Creating local shard: member-2-shard-default-config4 01:51:42,126 PM [cluster-test-akka.actor.default-dispatcher-13] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1 01:51:42,127 PM [cluster-test-akka.actor.default-dispatcher-13] [DEBUG] ShardManager - Creating Shard member-2-shard-default-config4 01:51:42,127 PM [cluster-test-akka.actor.default-dispatcher-13] [DEBUG] ShardManager - shard-manager-config4: Initializing shard [default] 01:51:42,127 PM [cluster-test-akka.actor.default-dispatcher-13] [DEBUG] ShardInformation - Shard member-2-shard-default-config4 is initialized 01:51:42,127 PM [cluster-test-akka.actor.default-dispatcher-13] [INFO] ShardManager - shard-manager-config4: Received LeaderStateChanged message: LeaderStateChanged [memberId=member-2-shard-default-config4, leaderId=member-2-shard-default-config4, leaderPayloadVersion=12] 01:51:42,127 PM [cluster-test-akka.actor.default-dispatcher-13] [INFO] ShardManager - shard-manager-config4: Received role changed for member-2-shard-default-config4 from Candidate to Leader 01:51:42,127 PM [cluster-test-akka.actor.default-dispatcher-13] [INFO] ShardManager - shard-manager-config4: All Shards are ready - data store config4 is ready 01:51:42,526 PM [cluster-test-akka.actor.default-dispatcher-4] [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] 01:51:42,605 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 01:51:42,606 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 01:51:42,606 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 01:51:42,606 PM [cluster-test-akka.actor.default-dispatcher-13] [INFO] ShardManager - shard-manager-config4: All Shards are ready - data store config4 is ready 01:51:42,606 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] 01:51:42,827 PM [cluster-test-akka.actor.default-dispatcher-4] [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] 01:51:42,828 PM [cluster-test-akka.actor.default-dispatcher-4] [INFO] ShardManager - shard-manager-config4: Received MemberUp: memberName: MemberName{name=member-2}, address: akka://cluster-test@127.0.0.1:2559 01:51:42,828 PM [cluster-test-akka.actor.default-dispatcher-4] [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 01:51:42,828 PM [cluster-test-akka.actor.default-dispatcher-4] [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 01:51:42,828 PM [cluster-test-akka.actor.default-dispatcher-4] [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 01:51:42,828 PM [cluster-test-akka.actor.default-dispatcher-4] [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 01:51:42,839 PM [cluster-test-akka.actor.default-dispatcher-12] [DEBUG] ShardManager - shard-manager-config4: onRemoveShardReplica: RemoveShardReplica [shardName=default, memberName=MemberName{name=member-1}] 01:51:42,849 PM [cluster-test-akka.actor.default-dispatcher-12] [DEBUG] ShardManager - shard-manager-config4: In findPrimary: org.opendaylight.controller.cluster.datastore.messages.FindPrimary [shardName=default, waitUntilReady=true] 01:51:42,853 PM [cluster-test-akka.actor.default-dispatcher-12] [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] 01:51:42,855 PM [cluster-test-akka.actor.default-dispatcher-12] [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 01:51:42,876 PM [cluster-test-akka.actor.default-dispatcher-4] [DEBUG] ShardManager - shard-manager-config4: Received RemoveServerReply{status=OK, leaderHint=member-2-shard-default-config4} for shard default 01:51:42,876 PM [cluster-test-akka.actor.default-dispatcher-4] [DEBUG] ShardManager - shard-manager-config4: Leader shard successfully removed the replica shard default 01:51:42,983 PM [cluster-test-akka.actor.default-dispatcher-4] [INFO] ShardManager - Stopping ShardManager shard-manager-config4 01:51:42,986 PM [cluster-test-akka.actor.default-dispatcher-13] [INFO] RemoteActorRefProvider$RemotingTerminator - Shutting down remote daemon. 01:51:42,987 PM [cluster-test-akka.actor.default-dispatcher-13] [INFO] RemoteActorRefProvider$RemotingTerminator - Remote daemon shut down; proceeding with flushing remote transports. 01:51:43,32 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 01:51:43,32 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 01:51:43,39 PM [cluster-test-akka.actor.default-dispatcher-13] [INFO] RemoteActorRefProvider$RemotingTerminator - Remoting shut down. 01:51:43,88 PM [cluster-test-akka.actor.default-dispatcher-13] [INFO] ShardManager - Stopping ShardManager shard-manager-config4 01:51:43,91 PM [cluster-test-akka.actor.default-dispatcher-10] [INFO] RemoteActorRefProvider$RemotingTerminator - Shutting down remote daemon. 01:51:43,91 PM [cluster-test-akka.actor.default-dispatcher-10] [INFO] RemoteActorRefProvider$RemotingTerminator - Remote daemon shut down; proceeding with flushing remote transports. 01:51:44,115 PM [cluster-test-akka.actor.default-dispatcher-10] [INFO] RemoteActorRefProvider$RemotingTerminator - Remoting shut down. [WARN] [04/29/2024 13:51:44.122] [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 01:51:44,167 PM [test-akka.actor.default-dispatcher-14] [INFO] EmptyLocalActorRef - Message [org.opendaylight.controller.cluster.common.actor.Monitor] from Actor[akka://test/user/$c#1753077345] 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'. 01:51:44,169 PM [test-akka.actor.default-dispatcher-16] [INFO] ShardManager - Starting ShardManager shard-manager-config5 01:51:44,174 PM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - Recovery complete : shard-manager-config5 01:51:44,174 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config5: Creating local shard: member-1-shard-default-config5 01:51:44,180 PM [test-akka.actor.default-dispatcher-16] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1 01:51:44,180 PM [test-akka.actor.default-dispatcher-16] [DEBUG] ShardManager - Creating Shard member-1-shard-default-config5 01:51:44,180 PM [test-akka.actor.default-dispatcher-16] [DEBUG] ShardManager - shard-manager-config5: Initializing shard [default] 01:51:44,180 PM [test-akka.actor.default-dispatcher-16] [DEBUG] ShardInformation - Shard member-1-shard-default-config5 is initialized 01:51:44,332 PM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/$c#1753077345] 01:51:44,345 PM [test-akka.actor.default-dispatcher-16] [INFO] ShardManager - Stopping ShardManager shard-manager-config5 01:51:44,355 PM [main] [INFO] ShardManager - Starting ShardManager shard-manager-config6 01:51:44,356 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'. 01:51:44,358 PM [test-akka.actor.default-dispatcher-14] [INFO] ShardManager - Recovery complete : shard-manager-config6 01:51:44,358 PM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - shard-manager-config6: Creating local shard: member-1-shard-default-config6 01:51:44,359 PM [main] [INFO] ShardManager - shard-manager-config6: Received role changed for member-1-shard-default-config6 from null to Follower 01:51:44,370 PM [main] [INFO] ShardManager - shard-manager-config6: Received MemberUp: memberName: MemberName{name=member-2}, address: akka://test 01:51:44,370 PM [main] [INFO] ShardInformation - updatePeerAddress for peer member-2-shard-default-config6 with address akka://test/user/shardmanager-config6/member-2-shard-default-config6 01:51:44,370 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] 01:51:44,370 PM [main] [INFO] ShardManager - shard-manager-config6: All Shards are ready - data store config6 is ready 01:51:44,473 PM [main] [INFO] TestActorFactory - Killing actor TestActor[akka://test/user/$$b] 01:51:44,485 PM [main] [INFO] ShardManager - Stopping ShardManager shard-manager-config6 01:51:44,506 PM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - Starting ShardManager shard-manager-config7 01:51:44,507 PM [test-akka.actor.default-dispatcher-10] [INFO] EmptyLocalActorRef - Message [org.opendaylight.controller.cluster.common.actor.Monitor] from Actor[akka://test/user/$d#969452447] 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'. 01:51:44,508 PM [test-akka.actor.default-dispatcher-14] [INFO] ShardManager - Recovery complete : shard-manager-config7 01:51:44,518 PM [test-akka.actor.default-dispatcher-16] [DEBUG] ShardManager - shard-manager-config7: onRemoveShardReplica: RemoveShardReplica [shardName=model-inventory, memberName=MemberName{name=member-1}] 01:51:44,519 PM [test-akka.actor.default-dispatcher-16] [DEBUG] ShardManager - shard-manager-config7: In findPrimary: org.opendaylight.controller.cluster.datastore.messages.FindPrimary [shardName=model-inventory, waitUntilReady=true] 01:51:44,519 PM [test-akka.actor.default-dispatcher-16] [DEBUG] ShardManager - shard-manager-config7: No shard found for model-inventory 01:51:44,520 PM [test-akka.actor.default-dispatcher-10] [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:1056) 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) 01:51:44,624 PM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/$d#969452447] 01:51:44,635 PM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - Stopping ShardManager shard-manager-config7 01:51:44,639 PM [main] [INFO] ShardManagerTest - testAddShardReplicaWithPreExistingLocalReplicaLeader starting 01:51:44,646 PM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - Starting ShardManager shard-manager-config8 01:51:44,647 PM [test-akka.actor.default-dispatcher-10] [INFO] EmptyLocalActorRef - Message [org.opendaylight.controller.cluster.common.actor.Monitor] from Actor[akka://test/user/$e#1653958583] 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'. 01:51:44,648 PM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - Recovery complete : shard-manager-config8 01:51:44,648 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config8: Creating local shard: member-1-shard-default-config8 01:51:44,657 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1 01:51:44,657 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - Creating Shard member-1-shard-default-config8 01:51:44,658 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config8: Initializing shard [default] 01:51:44,658 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardInformation - Shard member-1-shard-default-config8 is initialized 01:51:44,658 PM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - shard-manager-config8: Received LeaderStateChanged message: LeaderStateChanged [memberId=member-1-shard-default-config8, leaderId=member-1-shard-default-config8, leaderPayloadVersion=13] 01:51:44,658 PM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - shard-manager-config8: Received role changed for member-1-shard-default-config8 from Candidate to Leader 01:51:44,658 PM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - shard-manager-config8: All Shards are ready - data store config8 is ready 01:51:44,659 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config8: onAddShardReplica: AddShardReplica[ShardName=default] 01:51:44,663 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config8: In findPrimary: org.opendaylight.controller.cluster.datastore.messages.FindPrimary [shardName=default, waitUntilReady=true] 01:51:44,663 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config8: Found primary for default: LocalPrimaryShardFound [primaryPath=akka://test@127.0.0.1:2565/user/member-1-shard-default-config#-660791370, localShardDataTree=org.opendaylight.yangtools.yang.data.tree.api.DataTree$MockitoMock$Kbwo7KiD@2b80fadc] 01:51:44,664 PM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - shard-manager-config8: Local shard default already exists 01:51:44,664 PM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - shard-manager-config8: findLocalShard : default 01:51:44,664 PM [main] [INFO] ShardManagerTest - testAddShardReplicaWithPreExistingLocalReplicaLeader ending 01:51:44,767 PM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/$e#1653958583] 01:51:44,779 PM [test-akka.actor.default-dispatcher-14] [INFO] ShardManager - Stopping ShardManager shard-manager-config8 01:51:44,783 PM [main] [INFO] ShardManagerTest - testOnReceiveFindLocalShardWaitForShardInitialized starting 01:51:44,787 PM [test-akka.actor.default-dispatcher-14] [INFO] EmptyLocalActorRef - Message [org.opendaylight.controller.cluster.common.actor.Monitor] from Actor[akka://test/user/$f#-1714263087] 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'. 01:51:44,788 PM [test-akka.actor.default-dispatcher-16] [INFO] ShardManager - Starting ShardManager shard-manager-config9 01:51:44,792 PM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Recovery complete : shard-manager-config9 01:51:44,792 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config9: Creating local shard: member-1-shard-default-config9 01:51:44,799 PM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1 01:51:44,799 PM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - Creating Shard member-1-shard-default-config9 01:51:44,800 PM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - shard-manager-config9: findLocalShard : default 01:51:44,800 PM [test-akka.actor.default-dispatcher-14] [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] 01:51:44,800 PM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - shard-manager-config9: Initializing shard [default] 01:51:44,800 PM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardInformation - Shard member-1-shard-default-config9 is initialized 01:51:44,801 PM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardInformation - Shard member-1-shard-default-config9 is initialized - notifying 1 OnShardInitialized callbacks 01:51:44,805 PM [main] [INFO] ShardManagerTest - testOnReceiveFindLocalShardWaitForShardInitialized starting 01:51:44,908 PM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/$f#-1714263087] 01:51:44,919 PM [test-akka.actor.default-dispatcher-16] [INFO] ShardManager - Stopping ShardManager shard-manager-config9 01:51:44,923 PM [main] [INFO] ShardManagerTest - testShardAvailabilityChangeOnMemberUnreachableAndLeadershipChange starting 01:51:44,943 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] Slf4jLogger - Slf4jLogger started 01:51:44,972 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 [-6782191843238029569] 01:51:44,973 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] ... 01:51:44,983 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] 01:51:44,983 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2558] - Started up successfully 01:51:44,986 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 01:51:44,986 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 01:51:45,13 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'. 01:51:45,13 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 01:51:45,13 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) 01:51:45,13 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] 01:51:45,59 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] ShardManager - Starting ShardManager shard-manager-config10 01:51:45,73 PM [cluster-test-akka.actor.default-dispatcher-14] [INFO] ShardManager - Recovery complete : shard-manager-config10 01:51:45,73 PM [cluster-test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - shard-manager-config10: Creating local shard: member-1-shard-default-config10 01:51:45,75 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 01:51:45,75 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 01:51:45,78 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] Slf4jLogger - Slf4jLogger started 01:51:45,116 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 [-3759009408853079084] 01:51:45,118 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] ... 01:51:45,121 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 01:51:45,121 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2559] - Started up successfully 01:51:45,134 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 01:51:45,134 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 01:51:45,144 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-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'. 01:51:45,154 PM [cluster-test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1 01:51:45,154 PM [cluster-test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - Creating Shard member-1-shard-default-config10 01:51:45,154 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 01:51:45,154 PM [cluster-test-akka.actor.default-dispatcher-14] [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 01:51:45,154 PM [cluster-test-akka.actor.default-dispatcher-14] [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#-1508238936] 01:51:45,155 PM [cluster-test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - shard-manager-config10: Initializing shard [default] 01:51:45,155 PM [cluster-test-akka.actor.default-dispatcher-14] [DEBUG] ShardInformation - Shard member-1-shard-default-config10 is initialized 01:51:45,155 PM [cluster-test-akka.actor.default-dispatcher-14] [INFO] ShardManager - shard-manager-config10: Received LeaderStateChanged message: LeaderStateChanged [memberId=member-1-shard-default-config10, leaderId=member-2-shard-default-config10, leaderPayloadVersion=13] 01:51:45,155 PM [cluster-test-akka.actor.default-dispatcher-14] [INFO] ShardManager - shard-manager-config10: Received role changed for member-1-shard-default-config10 from Candidate to Follower 01:51:45,157 PM [cluster-test-akka.actor.default-dispatcher-10] [INFO] ShardManager - Starting ShardManager shard-manager-config10 01:51:45,186 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] ShardManager - Recovery complete : shard-manager-config10 01:51:45,186 PM [cluster-test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - shard-manager-config10: Creating local shard: member-2-shard-default-config10 01:51:45,187 PM [cluster-test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1 01:51:45,187 PM [cluster-test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - Creating Shard member-2-shard-default-config10 01:51:45,188 PM [cluster-test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - shard-manager-config10: Initializing shard [default] 01:51:45,188 PM [cluster-test-akka.actor.default-dispatcher-5] [DEBUG] ShardInformation - Shard member-2-shard-default-config10 is initialized 01:51:45,188 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] ShardManager - shard-manager-config10: Received LeaderStateChanged message: LeaderStateChanged [memberId=member-2-shard-default-config10, leaderId=member-2-shard-default-config10, leaderPayloadVersion=13] 01:51:45,188 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] ShardManager - shard-manager-config10: Received role changed for member-2-shard-default-config10 from Candidate to Leader 01:51:45,188 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] ShardManager - shard-manager-config10: All Shards are ready - data store config10 is ready 01:51:45,257 PM [cluster-test-akka.actor.default-dispatcher-14] [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] 01:51:45,263 PM [cluster-test-akka.actor.default-dispatcher-10] [INFO] ShardManager - shard-manager-config10: Received MemberUp: memberName: MemberName{name=member-1}, address: akka://cluster-test@127.0.0.1:2558 01:51:45,263 PM [cluster-test-akka.actor.default-dispatcher-10] [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 01:51:45,263 PM [cluster-test-akka.actor.default-dispatcher-10] [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 01:51:45,264 PM [cluster-test-akka.actor.default-dispatcher-10] [INFO] ShardManager - shard-manager-config10: All Shards are ready - data store config10 is ready 01:51:45,264 PM [cluster-test-akka.actor.default-dispatcher-10] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2559] - Welcome from [akka://cluster-test@127.0.0.1:2558] 01:51:46,7 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:2559] to [Up] 01:51:46,10 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] ShardManager - shard-manager-config10: Received MemberUp: memberName: MemberName{name=member-2}, address: akka://cluster-test@127.0.0.1:2559 01:51:46,10 PM [cluster-test-akka.actor.default-dispatcher-5] [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 01:51:46,10 PM [cluster-test-akka.actor.default-dispatcher-5] [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 01:51:46,10 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] ShardManager - shard-manager-config10: All Shards are ready - data store config10 is ready 01:51:46,11 PM [cluster-test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - shard-manager-config10: In findPrimary: org.opendaylight.controller.cluster.datastore.messages.FindPrimary [shardName=default, waitUntilReady=true] 01:51:46,11 PM [cluster-test-akka.actor.default-dispatcher-14] [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] 01:51:46,13 PM [cluster-test-akka.actor.default-dispatcher-14] [INFO] ShardManager - Received UnreachableMember: memberName MemberName{name=member-2}, address: akka://cluster-test@127.0.0.1:2558 01:51:46,13 PM [cluster-test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - Marking Leader member-2-shard-default-config10 as unavailable. 01:51:46,13 PM [cluster-test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - shard-manager-config10: In findPrimary: org.opendaylight.controller.cluster.datastore.messages.FindPrimary [shardName=default, waitUntilReady=true] 01:51:46,13 PM [cluster-test-akka.actor.default-dispatcher-14] [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] 01:51:46,157 PM [cluster-test-akka.actor.default-dispatcher-11] [INFO] ShardManager - shard-manager-config10: Received MemberUp: memberName: MemberName{name=member-2}, address: akka://cluster-test@127.0.0.1:2559 01:51:46,157 PM [cluster-test-akka.actor.default-dispatcher-11] [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 01:51:46,157 PM [cluster-test-akka.actor.default-dispatcher-11] [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 01:51:46,159 PM [cluster-test-akka.actor.default-dispatcher-11] [INFO] ShardManager - shard-manager-config10: All Shards are ready - data store config10 is ready 01:51:47,232 PM [cluster-test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - shard-manager-config10: Received ShardNotInitializedTimeout message for shard default 01:51:47,232 PM [cluster-test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - shard-manager-config10: Returning NoShardLeaderException for shard default 01:51:47,233 PM [cluster-test-akka.actor.default-dispatcher-14] [INFO] ShardManager - shard-manager-config10: Received LeaderStateChanged message: LeaderStateChanged [memberId=member-1-shard-default-config10, leaderId=member-1-shard-default-config10, leaderPayloadVersion=13] 01:51:47,234 PM [cluster-test-akka.actor.default-dispatcher-14] [INFO] ShardManager - shard-manager-config10: All Shards are ready - data store config10 is ready 01:51:47,234 PM [cluster-test-akka.actor.default-dispatcher-14] [INFO] ShardManager - shard-manager-config10: Received role changed for member-1-shard-default-config10 from Follower to Leader 01:51:47,234 PM [cluster-test-akka.actor.default-dispatcher-14] [INFO] ShardManager - shard-manager-config10: All Shards are ready - data store config10 is ready 01:51:47,234 PM [cluster-test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - shard-manager-config10: In findPrimary: org.opendaylight.controller.cluster.datastore.messages.FindPrimary [shardName=default, waitUntilReady=true] 01:51:47,234 PM [cluster-test-akka.actor.default-dispatcher-14] [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#-1508238936, localShardDataTree=org.opendaylight.yangtools.yang.data.tree.api.DataTree$MockitoMock$Kbwo7KiD@3b4971c4] 01:51:47,234 PM [main] [INFO] ShardManagerTest - testShardAvailabilityChangeOnMemberUnreachableAndLeadershipChange ending 01:51:47,337 PM [cluster-test-akka.actor.default-dispatcher-13] [INFO] ShardManager - Stopping ShardManager shard-manager-config10 01:51:47,340 PM [cluster-test-akka.actor.default-dispatcher-14] [INFO] RemoteActorRefProvider$RemotingTerminator - Shutting down remote daemon. 01:51:47,340 PM [cluster-test-akka.actor.default-dispatcher-14] [INFO] RemoteActorRefProvider$RemotingTerminator - Remote daemon shut down; proceeding with flushing remote transports. 01:51:47,354 PM [cluster-test-akka.actor.default-dispatcher-14] [WARN] Materializer - [outbound connection to [akka://cluster-test@127.0.0.1:2559], message stream] Upstream failed, cause: StreamTcpException: The connection has been aborted 01:51:47,354 PM [cluster-test-akka.actor.default-dispatcher-14] [WARN] Materializer - [outbound connection to [akka://cluster-test@127.0.0.1:2559], control stream] Upstream failed, cause: StreamTcpException: The connection has been aborted 01:51:47,376 PM [cluster-test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Stopping ShardManager shard-manager-config10 01:51:47,381 PM [cluster-test-akka.actor.default-dispatcher-10] [INFO] RemoteActorRefProvider$RemotingTerminator - Shutting down remote daemon. 01:51:47,381 PM [cluster-test-akka.actor.default-dispatcher-10] [INFO] RemoteActorRefProvider$RemotingTerminator - Remote daemon shut down; proceeding with flushing remote transports. 01:51:48,424 PM [cluster-test-akka.actor.default-dispatcher-10] [INFO] RemoteActorRefProvider$RemotingTerminator - Remoting shut down. [WARN] [04/29/2024 13:51:48.429] [cluster-test-akka.actor.internal-dispatcher-9] [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 01:51:48,452 PM [test-akka.actor.default-dispatcher-14] [INFO] ShardManager - Starting ShardManager shard-manager-config11 01:51:48,452 PM [test-akka.actor.default-dispatcher-14] [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'. 01:51:48,454 PM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Recovery complete : shard-manager-config11 01:51:48,478 PM [test-akka.actor.default-dispatcher-16] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1 01:51:48,478 PM [test-akka.actor.default-dispatcher-16] [DEBUG] ShardManager - shard-manager-config11: onAddShardReplica: AddShardReplica[ShardName=astronauts] 01:51:48,482 PM [test-akka.actor.default-dispatcher-16] [DEBUG] ShardManager - shard-manager-config11: Sending AddServer message to peer akka://test@127.0.0.1:2565/system/testProbe-21#383075573 for shard member-1-shard-astronauts-config11 01:51:48,495 PM [test-akka.actor.default-dispatcher-16] [DEBUG] ShardManager - shard-manager-config11: onRemoveShardReplica: RemoveShardReplica [shardName=astronauts, memberName=MemberName{name=member-2}] 01:51:48,496 PM [test-akka.actor.default-dispatcher-16] [DEBUG] ShardManager - shard-manager-config11: A shard replica operation for astronauts is already in progress 01:51:48,602 PM [main] [INFO] ShardManagerTest - testPerShardDatastoreContext starting 01:51:48,628 PM [test-akka.actor.default-dispatcher-14] [INFO] ShardManager - Starting ShardManager shard-manager-config12 01:51:48,631 PM [test-akka.actor.default-dispatcher-14] [INFO] EmptyLocalActorRef - Message [org.opendaylight.controller.cluster.common.actor.Monitor] from Actor[akka://test/user/$g#1531204773] 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'. 01:51:48,634 PM [test-akka.actor.default-dispatcher-16] [INFO] ShardManager - Recovery complete : shard-manager-config12 01:51:48,634 PM [test-akka.actor.default-dispatcher-16] [DEBUG] ShardManager - shard-manager-config12: Creating local shard: member-1-shard-default-config12 01:51:48,636 PM [test-akka.actor.default-dispatcher-16] [DEBUG] ShardManager - shard-manager-config12: Creating local shard: member-1-shard-topology-config12 01:51:48,644 PM [test-akka.actor.default-dispatcher-6] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1 01:51:48,645 PM [test-akka.actor.default-dispatcher-6] [DEBUG] ShardManager - Creating Shard member-1-shard-default-config12 01:51:48,645 PM [test-akka.actor.default-dispatcher-6] [DEBUG] ShardManager - Creating Shard member-1-shard-topology-config12 01:51:48,647 PM [test-akka.actor.default-dispatcher-6] [DEBUG] ShardInformation - Sending new DatastoreContext to member-1-shard-default-config12 01:51:48,648 PM [test-akka.actor.default-dispatcher-6] [DEBUG] ShardInformation - Sending new DatastoreContext to member-1-shard-topology-config12 01:51:48,698 PM [main] [INFO] ShardManagerTest - testPerShardDatastoreContext ending 01:51:48,800 PM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/default1#1028816399] 01:51:48,813 PM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/topology2#1504055316] 01:51:48,814 PM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/$g#1531204773] 01:51:48,814 PM [test-akka.actor.default-dispatcher-16] [INFO] ShardManager - Stopping ShardManager shard-manager-config12 01:51:48,818 PM [main] [INFO] ShardManagerTest - testOnReceiveFindPrimaryForLocalLeaderShard starting 01:51:48,822 PM [test-akka.actor.default-dispatcher-16] [INFO] ShardManager - Starting ShardManager shard-manager-config13 01:51:48,823 PM [test-akka.actor.default-dispatcher-6] [INFO] ShardManager - Recovery complete : shard-manager-config13 01:51:48,824 PM [test-akka.actor.default-dispatcher-6] [DEBUG] ShardManager - shard-manager-config13: Creating local shard: member-1-shard-default-config13 01:51:48,833 PM [test-akka.actor.default-dispatcher-6] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1 01:51:48,833 PM [test-akka.actor.default-dispatcher-6] [DEBUG] ShardManager - Creating Shard member-1-shard-default-config13 01:51:48,833 PM [test-akka.actor.default-dispatcher-6] [DEBUG] ShardManager - shard-manager-config13: Initializing shard [default] 01:51:48,834 PM [test-akka.actor.default-dispatcher-6] [DEBUG] ShardInformation - Shard member-1-shard-default-config13 is initialized 01:51:48,834 PM [test-akka.actor.default-dispatcher-6] [INFO] ShardManager - shard-manager-config13: Received LeaderStateChanged message: LeaderStateChanged [memberId=member-1-shard-default-config13, leaderId=member-1-shard-default-config13, leaderPayloadVersion=13] 01:51:48,884 PM [test-akka.actor.default-dispatcher-6] [INFO] ShardManager - shard-manager-config13: Received role changed for member-1-shard-default-config13 from Candidate to Leader 01:51:48,884 PM [test-akka.actor.default-dispatcher-6] [INFO] ShardManager - shard-manager-config13: All Shards are ready - data store config13 is ready 01:51:48,884 PM [test-akka.actor.default-dispatcher-6] [DEBUG] ShardManager - shard-manager-config13: In findPrimary: org.opendaylight.controller.cluster.datastore.messages.FindPrimary [shardName=default, waitUntilReady=false] 01:51:48,884 PM [test-akka.actor.default-dispatcher-6] [DEBUG] ShardManager - shard-manager-config13: Found primary for default: LocalPrimaryShardFound [primaryPath=akka://test@127.0.0.1:2565/user/member-1-shard-default-config#671428038, localShardDataTree=org.opendaylight.yangtools.yang.data.tree.api.DataTree$MockitoMock$Kbwo7KiD@4fd727d7] 01:51:48,885 PM [main] [INFO] ShardManagerTest - testOnReceiveFindPrimaryForLocalLeaderShard ending 01:51:48,986 PM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/$h#-112510649] 01:51:48,998 PM [test-akka.actor.default-dispatcher-6] [INFO] ShardManager - Stopping ShardManager shard-manager-config13 01:51:49,3 PM [main] [INFO] ShardManagerTest - testShardAvailabilityChangeOnMemberWithNameContainedInLeaderIdUnreachable starting 01:51:49,15 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] Slf4jLogger - Slf4jLogger started 01:51:49,30 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 [8498899296227838315] 01:51:49,30 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] ... 01:51:49,45 PM [cluster-test-akka.actor.default-dispatcher-10] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2562] - Registered cluster JMX MBean [akka:type=Cluster] 01:51:49,45 PM [cluster-test-akka.actor.default-dispatcher-10] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2562] - Started up successfully 01:51:49,56 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 01:51:49,56 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 01:51:49,71 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] ShardManager - Starting ShardManager shard-manager-config14 01:51:49,72 PM [cluster-test-akka.actor.default-dispatcher-5] [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 01:51:49,72 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2562] - is the new leader among reachable nodes (more leaders may exist) 01:51:49,72 PM [cluster-test-akka.actor.default-dispatcher-5] [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] 01:51:49,72 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'. 01:51:49,80 PM [cluster-test-akka.actor.default-dispatcher-12] [INFO] ShardManager - Recovery complete : shard-manager-config14 01:51:49,81 PM [cluster-test-akka.actor.default-dispatcher-12] [DEBUG] ShardManager - shard-manager-config14: Creating local shard: member-256-shard-default-config14 01:51:49,81 PM [cluster-test-akka.actor.default-dispatcher-12] [INFO] ShardManager - shard-manager-config14: Received MemberUp: memberName: MemberName{name=member-256}, address: akka://cluster-test@127.0.0.1:2562 01:51:49,82 PM [cluster-test-akka.actor.default-dispatcher-12] [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 01:51:49,87 PM [cluster-test-akka.actor.default-dispatcher-4] [INFO] Slf4jLogger - Slf4jLogger started 01:51:49,104 PM [cluster-test-akka.actor.default-dispatcher-4] [INFO] ArteryTransport - Remoting started with transport [Artery tcp]; listening on address [akka://cluster-test@127.0.0.1:2559] with UID [7608265391695818050] 01:51:49,104 PM [cluster-test-akka.actor.default-dispatcher-4] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2559] - Starting up, Akka version [2.6.21] ... 01:51:49,108 PM [cluster-test-akka.actor.default-dispatcher-4] [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 01:51:49,108 PM [cluster-test-akka.actor.default-dispatcher-4] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2559] - Started up successfully 01:51:49,121 PM [cluster-test-akka.actor.default-dispatcher-4] [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 01:51:49,121 PM [cluster-test-akka.actor.default-dispatcher-4] [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 01:51:49,140 PM [cluster-test-akka.actor.default-dispatcher-4] [INFO] ShardManager - Starting ShardManager shard-manager-config14 01:51:49,150 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'. 01:51:49,151 PM [cluster-test-akka.actor.default-dispatcher-13] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1 01:51:49,151 PM [cluster-test-akka.actor.default-dispatcher-13] [DEBUG] ShardManager - Creating Shard member-256-shard-default-config14 01:51:49,151 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 01:51:49,151 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 01:51:49,151 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#569797227] 01:51:49,151 PM [cluster-test-akka.actor.default-dispatcher-13] [DEBUG] ShardManager - shard-manager-config14: Initializing shard [default] 01:51:49,151 PM [cluster-test-akka.actor.default-dispatcher-13] [DEBUG] ShardInformation - Shard member-256-shard-default-config14 is initialized 01:51:49,152 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] 01:51:49,152 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 01:51:49,152 PM [cluster-test-akka.actor.default-dispatcher-13] [INFO] ShardManager - shard-manager-config14: All Shards are ready - data store config14 is ready 01:51:49,156 PM [cluster-test-akka.actor.default-dispatcher-10] [INFO] ShardManager - Recovery complete : shard-manager-config14 01:51:49,156 PM [cluster-test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config14: Creating local shard: member-2-shard-default-config14 01:51:49,157 PM [cluster-test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1 01:51:49,157 PM [cluster-test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - Creating Shard member-2-shard-default-config14 01:51:49,157 PM [cluster-test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config14: Initializing shard [default] 01:51:49,157 PM [cluster-test-akka.actor.default-dispatcher-10] [DEBUG] ShardInformation - Shard member-2-shard-default-config14 is initialized 01:51:49,157 PM [cluster-test-akka.actor.default-dispatcher-10] [INFO] ShardManager - shard-manager-config14: Received LeaderStateChanged message: LeaderStateChanged [memberId=member-2-shard-default-config14, leaderId=member-256-shard-default-config14, leaderPayloadVersion=13] 01:51:49,157 PM [cluster-test-akka.actor.default-dispatcher-10] [INFO] ShardManager - shard-manager-config14: Received role changed for member-2-shard-default-config14 from Candidate to Follower 01:51:49,210 PM [cluster-test-akka.actor.default-dispatcher-10] [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] 01:51:49,221 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:2562] 01:51:49,221 PM [cluster-test-akka.actor.default-dispatcher-11] [INFO] ShardManager - shard-manager-config14: Received MemberUp: memberName: MemberName{name=member-256}, address: akka://cluster-test@127.0.0.1:2562 01:51:49,221 PM [cluster-test-akka.actor.default-dispatcher-11] [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 01:51:49,221 PM [cluster-test-akka.actor.default-dispatcher-11] [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 01:51:49,221 PM [cluster-test-akka.actor.default-dispatcher-11] [INFO] ShardManager - shard-manager-config14: All Shards are ready - data store config14 is ready 01:51:50,72 PM [cluster-test-akka.actor.default-dispatcher-10] [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] 01:51:50,73 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 01:51:50,73 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 01:51:50,73 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-256-shard-default-config 01:51:50,73 PM [cluster-test-akka.actor.default-dispatcher-10] [INFO] ShardManager - shard-manager-config14: All Shards are ready - data store config14 is ready 01:51:50,74 PM [cluster-test-akka.actor.default-dispatcher-13] [DEBUG] ShardManager - shard-manager-config14: In findPrimary: org.opendaylight.controller.cluster.datastore.messages.FindPrimary [shardName=default, waitUntilReady=true] 01:51:50,74 PM [cluster-test-akka.actor.default-dispatcher-13] [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#569797227, localShardDataTree=org.opendaylight.yangtools.yang.data.tree.api.DataTree$MockitoMock$Kbwo7KiD@789b3a77] 01:51:50,76 PM [cluster-test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Received UnreachableMember: memberName MemberName{name=member-2}, address: akka://cluster-test@127.0.0.1:2558 01:51:50,76 PM [cluster-test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config14: In findPrimary: org.opendaylight.controller.cluster.datastore.messages.FindPrimary [shardName=default, waitUntilReady=true] 01:51:50,76 PM [cluster-test-akka.actor.default-dispatcher-11] [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#569797227, localShardDataTree=org.opendaylight.yangtools.yang.data.tree.api.DataTree$MockitoMock$Kbwo7KiD@789b3a77] 01:51:50,78 PM [main] [INFO] ShardManagerTest - testShardAvailabilityChangeOnMemberWithNameContainedInLeaderIdUnreachable ending 01:51:50,130 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 01:51:50,130 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 01:51:50,130 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 01:51:50,130 PM [cluster-test-akka.actor.default-dispatcher-10] [INFO] ShardManager - shard-manager-config14: All Shards are ready - data store config14 is ready 01:51:50,181 PM [cluster-test-akka.actor.default-dispatcher-10] [INFO] ShardManager - Stopping ShardManager shard-manager-config14 01:51:50,183 PM [cluster-test-akka.actor.default-dispatcher-10] [INFO] RemoteActorRefProvider$RemotingTerminator - Shutting down remote daemon. 01:51:50,184 PM [cluster-test-akka.actor.default-dispatcher-10] [INFO] RemoteActorRefProvider$RemotingTerminator - Remote daemon shut down; proceeding with flushing remote transports. 01:51:50,196 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 01:51:50,196 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 01:51:50,199 PM [cluster-test-akka.actor.default-dispatcher-10] [INFO] RemoteActorRefProvider$RemotingTerminator - Remoting shut down. 01:51:50,222 PM [cluster-test-akka.actor.default-dispatcher-10] [INFO] ShardManager - Stopping ShardManager shard-manager-config14 01:51:50,226 PM [cluster-test-akka.actor.default-dispatcher-10] [INFO] RemoteActorRefProvider$RemotingTerminator - Shutting down remote daemon. 01:51:50,226 PM [cluster-test-akka.actor.default-dispatcher-10] [INFO] RemoteActorRefProvider$RemotingTerminator - Remote daemon shut down; proceeding with flushing remote transports. 01:51:51,141 PM [cluster-test-akka.actor.default-dispatcher-12] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2559] - is the new leader among reachable nodes (more leaders may exist) 01:51:51,242 PM [cluster-test-akka.actor.default-dispatcher-12] [INFO] RemoteActorRefProvider$RemotingTerminator - Remoting shut down. [WARN] [04/29/2024 13:51:51.246] [cluster-test-akka.actor.internal-dispatcher-6] [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 01:51:51,274 PM [main] [INFO] ShardManager - Starting ShardManager shard-manager-config15 01:51:51,280 PM [test-akka.actor.default-dispatcher-6] [INFO] ShardManager - Recovery complete : shard-manager-config15 01:51:51,280 PM [test-akka.actor.default-dispatcher-6] [DEBUG] ShardManager - shard-manager-config15: Creating local shard: member-1-shard-default-config15 01:51:51,281 PM [main] [INFO] ShardManager - shard-manager-config15: Received role changed for member-1-shard-default-config15 from Follower to Leader 01:51:51,382 PM [main] [INFO] TestActorFactory - Killing actor TestActor[akka://test/user/$$c] 01:51:51,394 PM [main] [INFO] ShardManager - Stopping ShardManager shard-manager-config15 01:51:51,403 PM [main] [INFO] ShardManager - Starting ShardManager shard-manager-config16 01:51:51,406 PM [test-akka.actor.default-dispatcher-16] [INFO] ShardManager - Recovery complete : shard-manager-config16 01:51:51,406 PM [test-akka.actor.default-dispatcher-16] [DEBUG] ShardManager - shard-manager-config16: Creating local shard: member-1-shard-default-config16 01:51:51,407 PM [main] [INFO] ShardManager - shard-manager-config16: Received role changed for member-1-shard-default-config16 from Candidate to Leader 01:51:51,407 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] 01:51:51,407 PM [main] [INFO] ShardManager - shard-manager-config16: All Shards are ready - data store config16 is ready 01:51:51,508 PM [main] [INFO] TestActorFactory - Killing actor TestActor[akka://test/user/$$d] 01:51:51,510 PM [main] [INFO] ShardManager - Stopping ShardManager shard-manager-config16 01:51:51,515 PM [main] [INFO] ShardManagerTest - testOnCreateShardWithLocalMemberNotInShardConfig starting 01:51:51,524 PM [test-akka.actor.default-dispatcher-6] [INFO] ShardManager - Starting ShardManager shard-manager-config17 01:51:51,526 PM [test-akka.actor.default-dispatcher-16] [INFO] ShardManager - Recovery complete : shard-manager-config17 01:51:51,526 PM [test-akka.actor.default-dispatcher-16] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1 01:51:51,542 PM [test-akka.actor.default-dispatcher-6] [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@cde70e8] 01:51:51,545 PM [test-akka.actor.default-dispatcher-6] [DEBUG] ShardManager - shard-manager-config17 doCreateShard: shardId: member-1-shard-foo-config17, memberNames: [MemberName{name=member-5}, MemberName{name=member-6}], peerAddresses: {}, isActiveMember: false 01:51:51,549 PM [test-akka.actor.default-dispatcher-16] [DEBUG] ShardManager - shard-manager-config17: findLocalShard : foo 01:51:51,549 PM [test-akka.actor.default-dispatcher-16] [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] 01:51:51,560 PM [test-shard-dispatcher-17] [INFO] Shard - Shard created : member-1-shard-foo-config17, persistent : true 01:51:51,577 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#941281985 created and ready for shard:member-1-shard-foo-config17 01:51:51,590 PM [test-akka.actor.default-dispatcher-16] [DEBUG] ShardSnapshotActor - Actor created Actor[akka://test/user/$i/member-1-shard-foo-config17/shard-member-1:snapshot-read#-73418864] 01:51:51,597 PM [test-shard-dispatcher-17] [INFO] Shard - Starting recovery for member-1-shard-foo-config17 with journal batch size 1 01:51:51,610 PM [test-shard-dispatcher-17] [DEBUG] Shard - member-1-shard-foo-config17: onReceiveRecover: Received message class akka.persistence.RecoveryCompleted$ from Actor[akka://test/deadLetters] 01:51:51,613 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 01:51:51,615 PM [test-akka.actor.default-dispatcher-6] [DEBUG] ShardManager - shard-manager-config17: Initializing shard [foo] 01:51:51,615 PM [test-akka.actor.default-dispatcher-6] [DEBUG] ShardInformation - Shard member-1-shard-foo-config17 is initialized 01:51:51,615 PM [test-akka.actor.default-dispatcher-6] [DEBUG] ShardInformation - Shard member-1-shard-foo-config17 is initialized - notifying 1 OnShardInitialized callbacks 01:51:51,627 PM [main] [INFO] ShardManagerTest - testOnCreateShardWithLocalMemberNotInShardConfig ending 01:51:51,628 PM [test-shard-dispatcher-17] [DEBUG] DataTreeChangeListenerSupport - member-1-shard-foo-config17: onLeadershipChange, isLeader: false, hasLeader : false 01:51:51,629 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 01:51:51,633 PM [test-shard-dispatcher-17] [INFO] DefaultConfigParamsImpl - Trying to use custom RaftPolicy org.opendaylight.controller.cluster.raft.policy.DisableElectionsRaftPolicy 01:51:51,635 PM [test-akka.actor.default-dispatcher-6] [INFO] RoleChangeNotifier - RoleChangeNotifier for member-1-shard-foo-config17 , received role change from null to Follower 01:51:51,635 PM [test-akka.actor.default-dispatcher-6] [INFO] RoleChangeNotifier - RoleChangeNotifier for member-1-shard-foo-config17 , registered listener akka://test/user/$i 01:51:51,635 PM [test-akka.actor.default-dispatcher-6] [INFO] ShardManager - shard-manager-config17: Received role changed for member-1-shard-foo-config17 from null to Follower 01:51:51,737 PM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/$i#-82561593] 01:51:51,749 PM [test-shard-dispatcher-17] [INFO] Shard - Stopping Shard member-1-shard-foo-config17 01:51:51,749 PM [test-shard-dispatcher-17] [DEBUG] MessageAssembler - member-1-shard-foo-config17 (Follower): Closing 01:51:51,750 PM [test-shard-dispatcher-17] [DEBUG] Shard - member-1-shard-foo-config17: Aborting 0 pending queued transactions 01:51:51,750 PM [test-akka.actor.default-dispatcher-6] [INFO] ShardManager - Stopping ShardManager shard-manager-config17 01:51:51,753 PM [main] [INFO] ShardManagerTest - testServerRemovedShardActorNotRunning starting 01:51:51,757 PM [test-akka.actor.default-dispatcher-16] [INFO] ShardManager - Starting ShardManager shard-manager-config18 01:51:51,758 PM [test-akka.actor.default-dispatcher-6] [INFO] ShardManager - Recovery complete : shard-manager-config18 01:51:51,758 PM [test-akka.actor.default-dispatcher-6] [DEBUG] ShardManager - shard-manager-config18: Creating local shard: member-1-shard-default-config18 01:51:51,758 PM [test-akka.actor.default-dispatcher-6] [DEBUG] ShardManager - shard-manager-config18: Creating local shard: member-1-shard-people-config18 01:51:51,867 PM [test-akka.actor.default-dispatcher-16] [DEBUG] ShardManager - shard-manager-config18: findLocalShard : people 01:51:51,867 PM [test-akka.actor.default-dispatcher-16] [DEBUG] ShardManager - shard-manager-config18: Returning NotInitializedException for shard people 01:51:51,868 PM [test-akka.actor.default-dispatcher-16] [DEBUG] ShardManager - shard-manager-config18: findLocalShard : default 01:51:51,868 PM [test-akka.actor.default-dispatcher-16] [DEBUG] ShardManager - shard-manager-config18: Returning NotInitializedException for shard default 01:51:51,871 PM [test-akka.actor.default-dispatcher-16] [DEBUG] ShardManager - shard-manager-config18 : Local Shard replica for shard default has been removed 01:51:51,871 PM [test-akka.actor.default-dispatcher-16] [DEBUG] ShardManager - shard-manager-config18: persisting the shard list [people] 01:51:51,876 PM [main] [INFO] ShardManagerTest - testServerRemovedShardActorNotRunning ending 01:51:51,880 PM [test-akka.actor.default-dispatcher-16] [DEBUG] ShardManager - shard-manager-config18 saved ShardManager snapshot successfully. Deleting the prev snapshot if available 01:51:51,887 PM [test-akka.actor.default-dispatcher-16] [DEBUG] ShardManager - shard-manager-config18: Successfully deleted prior snapshots 01:51:51,978 PM [main] [INFO] TestActorFactory - Killing actor TestActor[akka://test/user/$$e] 01:51:51,989 PM [test-akka.actor.default-dispatcher-16] [INFO] ShardManager - Stopping ShardManager shard-manager-config18 01:51:51,998 PM [test-akka.actor.default-dispatcher-16] [INFO] ShardManager - Starting ShardManager shard-manager-config19 01:51:52,0 PM [test-akka.actor.default-dispatcher-16] [INFO] ShardManager - Recovery complete : shard-manager-config19 01:51:52,0 PM [test-akka.actor.default-dispatcher-16] [DEBUG] ShardManager - shard-manager-config19: Creating local shard: member-1-shard-default-config19 01:51:52,9 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1 01:51:52,9 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - Creating Shard member-1-shard-default-config19 01:51:52,9 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config19: Initializing shard [default] 01:51:52,9 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardInformation - Shard member-1-shard-default-config19 is initialized 01:51:52,9 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config19: In findPrimary: org.opendaylight.controller.cluster.datastore.messages.FindPrimary [shardName=default, waitUntilReady=false] 01:51:52,9 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config19: Returning NoShardLeaderException for shard default 01:51:52,112 PM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/$j#2082235311] 01:51:52,123 PM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Stopping ShardManager shard-manager-config19 01:51:52,128 PM [main] [INFO] ShardManagerTest - testOnReceiveFindPrimaryForFollowerShardWithNoInitialLeaderId starting 01:51:52,131 PM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Starting ShardManager shard-manager-config20 01:51:52,133 PM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Recovery complete : shard-manager-config20 01:51:52,133 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config20: Creating local shard: member-1-shard-default-config20 01:51:52,143 PM [test-akka.actor.default-dispatcher-6] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1 01:51:52,143 PM [test-akka.actor.default-dispatcher-6] [DEBUG] ShardManager - Creating Shard member-1-shard-default-config20 01:51:52,144 PM [test-akka.actor.default-dispatcher-6] [DEBUG] ShardManager - shard-manager-config20: Initializing shard [default] 01:51:52,144 PM [test-akka.actor.default-dispatcher-6] [DEBUG] ShardInformation - Shard member-1-shard-default-config20 is initialized 01:51:52,144 PM [test-akka.actor.default-dispatcher-6] [INFO] ShardManager - shard-manager-config20: Received role changed for member-1-shard-default-config20 from Candidate to Follower 01:51:52,144 PM [test-akka.actor.default-dispatcher-6] [DEBUG] ShardManager - shard-manager-config20: In findPrimary: org.opendaylight.controller.cluster.datastore.messages.FindPrimary [shardName=default, waitUntilReady=false] 01:51:52,144 PM [test-akka.actor.default-dispatcher-6] [DEBUG] ShardManager - shard-manager-config20: Returning NoShardLeaderException for shard default 01:51:52,145 PM [test-akka.actor.default-dispatcher-6] [INFO] ShardManager - shard-manager-config20: Received LeaderStateChanged message: LeaderStateChanged [memberId=member-1-shard-default-config20, leaderId=member-1-shard-default-config20, leaderPayloadVersion=13] 01:51:52,146 PM [test-akka.actor.default-dispatcher-6] [INFO] ShardManager - shard-manager-config20: All Shards are ready - data store config20 is ready 01:51:52,146 PM [test-akka.actor.default-dispatcher-6] [DEBUG] ShardManager - shard-manager-config20: In findPrimary: org.opendaylight.controller.cluster.datastore.messages.FindPrimary [shardName=default, waitUntilReady=false] 01:51:52,146 PM [test-akka.actor.default-dispatcher-6] [DEBUG] ShardManager - shard-manager-config20: Found primary for default: LocalPrimaryShardFound [primaryPath=akka://test@127.0.0.1:2565/user/member-1-shard-default-config#1194397424, localShardDataTree=org.opendaylight.yangtools.yang.data.tree.api.DataTree$MockitoMock$Kbwo7KiD@5b30b332] 01:51:52,146 PM [main] [INFO] ShardManagerTest - testOnReceiveFindPrimaryForFollowerShardWithNoInitialLeaderId starting 01:51:52,248 PM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/$k#-1559177950] 01:51:52,259 PM [test-akka.actor.default-dispatcher-6] [INFO] ShardManager - Stopping ShardManager shard-manager-config20 01:51:52,268 PM [test-akka.actor.default-dispatcher-6] [INFO] ShardManager - Starting ShardManager shard-manager-config21 01:51:52,270 PM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Recovery complete : shard-manager-config21 01:51:52,289 PM [test-akka.actor.default-dispatcher-6] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1 01:51:52,289 PM [test-akka.actor.default-dispatcher-6] [DEBUG] ShardManager - shard-manager-config21: onAddShardReplica: AddShardReplica[ShardName=astronauts] 01:51:52,290 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config21: Sending AddServer message to peer akka://test@127.0.0.1:2565/system/testProbe-39#-1325341250 for shard member-1-shard-astronauts-config21 01:51:52,302 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config21: onAddShardReplica: AddShardReplica[ShardName=astronauts] 01:51:52,303 PM [test-akka.actor.default-dispatcher-6] [DEBUG] ShardManager - shard-manager-config21: A shard replica operation for astronauts is already in progress 01:51:52,407 PM [main] [INFO] ShardManagerTest - testOnReceiveFindPrimaryWaitForReadyWithCandidateShard starting 01:51:52,412 PM [test-akka.actor.default-dispatcher-6] [INFO] ShardManager - Starting ShardManager shard-manager-config22 01:51:52,413 PM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Recovery complete : shard-manager-config22 01:51:52,413 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config22: Creating local shard: member-1-shard-default-config22 01:51:52,423 PM [test-akka.actor.default-dispatcher-6] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1 01:51:52,423 PM [test-akka.actor.default-dispatcher-6] [DEBUG] ShardManager - Creating Shard member-1-shard-default-config22 01:51:52,424 PM [test-akka.actor.default-dispatcher-6] [DEBUG] ShardManager - shard-manager-config22: Initializing shard [default] 01:51:52,424 PM [test-akka.actor.default-dispatcher-6] [DEBUG] ShardInformation - Shard member-1-shard-default-config22 is initialized 01:51:52,424 PM [test-akka.actor.default-dispatcher-6] [INFO] ShardManager - shard-manager-config22: Received role changed for member-1-shard-default-config22 from null to Candidate 01:51:52,424 PM [test-akka.actor.default-dispatcher-6] [DEBUG] ShardManager - shard-manager-config22: In findPrimary: org.opendaylight.controller.cluster.datastore.messages.FindPrimary [shardName=default, waitUntilReady=true] 01:51:52,424 PM [test-akka.actor.default-dispatcher-6] [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] 01:51:53,643 PM [test-akka.actor.default-dispatcher-6] [DEBUG] ShardManager - shard-manager-config22: Received ShardNotInitializedTimeout message for shard default 01:51:53,643 PM [test-akka.actor.default-dispatcher-6] [DEBUG] ShardManager - shard-manager-config22: Returning NoShardLeaderException for shard default 01:51:53,644 PM [main] [INFO] ShardManagerTest - testOnReceiveFindPrimaryWaitForReadyWithCandidateShard ending 01:51:53,746 PM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/$l#-2116439252] 01:51:53,758 PM [test-akka.actor.default-dispatcher-6] [INFO] ShardManager - Stopping ShardManager shard-manager-config22 01:51:53,762 PM [main] [INFO] ShardManagerTest - testAddShardReplicaWithAddServerReplyFailure starting 01:51:53,768 PM [test-akka.actor.default-dispatcher-6] [INFO] ShardManager - Starting ShardManager shard-manager-config23 01:51:53,770 PM [test-akka.actor.default-dispatcher-16] [INFO] ShardManager - Recovery complete : shard-manager-config23 01:51:53,789 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1 01:51:53,800 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config23: onAddShardReplica: AddShardReplica[ShardName=astronauts] 01:51:53,801 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config23: Sending AddServer message to peer akka://test@127.0.0.1:2565/system/testProbe-44#842940970 for shard member-1-shard-astronauts-config23 01:51:53,803 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config23: Received AddServerReply{status=TIMEOUT} for shard astronauts from leader akka://test@127.0.0.1:2565/system/testProbe-44#842940970 01:51:53,803 PM [test-akka.actor.default-dispatcher-11] [WARN] ShardManager - shard-manager-config23: Leader failed to add shard replica astronauts with status TIMEOUT 01:51:53,804 PM [test-akka.actor.default-dispatcher-6] [DEBUG] ShardManager - shard-manager-config23: findLocalShard : astronauts 01:51:53,804 PM [test-akka.actor.default-dispatcher-6] [DEBUG] ShardManager - shard-manager-config23: Local shard astronauts not found - shards present: [] 01:51:53,805 PM [test-akka.actor.default-dispatcher-6] [DEBUG] ShardManager - shard-manager-config23: onAddShardReplica: AddShardReplica[ShardName=astronauts] 01:51:53,806 PM [test-akka.actor.default-dispatcher-16] [DEBUG] ShardManager - shard-manager-config23: Sending AddServer message to peer akka://test@127.0.0.1:2565/system/testProbe-44#842940970 for shard member-1-shard-astronauts-config23 01:51:53,807 PM [test-akka.actor.default-dispatcher-16] [DEBUG] ShardManager - shard-manager-config23: Received AddServerReply{status=NO_LEADER} for shard astronauts from leader akka://test@127.0.0.1:2565/system/testProbe-44#842940970 01:51:53,807 PM [test-akka.actor.default-dispatcher-16] [WARN] ShardManager - shard-manager-config23: Leader failed to add shard replica astronauts with status NO_LEADER 01:51:53,809 PM [main] [INFO] ShardManagerTest - testAddShardReplicaWithAddServerReplyFailure ending 01:51:53,911 PM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/member-1-shard-astronauts-config#1336909941] 01:51:53,922 PM [main] [INFO] TestActorFactory - Killing actor TestActor[akka://test/user/shardmanager-config23] 01:51:53,923 PM [test-akka.actor.default-dispatcher-16] [INFO] ShardManager - Stopping ShardManager shard-manager-config23 01:51:53,930 PM [main] [INFO] ShardManager - Starting ShardManager shard-manager-config24 01:51:53,932 PM [test-akka.actor.default-dispatcher-6] [INFO] ShardManager - Recovery complete : shard-manager-config24 01:51:53,932 PM [test-akka.actor.default-dispatcher-6] [DEBUG] ShardManager - shard-manager-config24: Creating local shard: member-1-shard-default-config24 01:51:53,933 PM [main] [INFO] ShardManager - shard-manager-config24: Received role changed for member-1-shard-default-config24 from Candidate to Follower 01:51:53,934 PM [main] [INFO] ShardManager - shard-manager-config24 Received follower initial sync status for member-1-shard-default-config24 status sync done true 01:51:53,934 PM [main] [INFO] ShardManager - shard-manager-config24 Received follower initial sync status for member-1-shard-default-config24 status sync done false 01:51:54,36 PM [main] [INFO] TestActorFactory - Killing actor TestActor[akka://test/user/$$f] 01:51:54,47 PM [main] [INFO] ShardManager - Stopping ShardManager shard-manager-config24 01:51:54,54 PM [main] [INFO] ShardManager - Starting ShardManager shard-manager-config25 01:51:54,59 PM [test-akka.actor.default-dispatcher-16] [INFO] ShardManager - Recovery complete : shard-manager-config25 01:51:54,60 PM [test-akka.actor.default-dispatcher-16] [DEBUG] ShardManager - shard-manager-config25: Creating local shard: member-1-shard-default-config25 01:51:54,61 PM [main] [INFO] ShardManager - shard-manager-config25: Received role changed for unknown from Candidate to Leader 01:51:54,162 PM [main] [INFO] TestActorFactory - Killing actor TestActor[akka://test/user/$$g] 01:51:54,174 PM [main] [INFO] ShardManager - Stopping ShardManager shard-manager-config25 01:51:54,177 PM [main] [INFO] ShardManagerTest - testOnReceiveFindPrimaryWaitForReadyWithUninitializedShard starting 01:51:54,188 PM [test-akka.actor.default-dispatcher-6] [INFO] ShardManager - Starting ShardManager shard-manager-config26 01:51:54,190 PM [test-akka.actor.default-dispatcher-6] [INFO] ShardManager - Recovery complete : shard-manager-config26 01:51:54,190 PM [test-akka.actor.default-dispatcher-6] [DEBUG] ShardManager - shard-manager-config26: Creating local shard: member-1-shard-default-config26 01:51:54,199 PM [test-akka.actor.default-dispatcher-16] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1 01:51:54,199 PM [test-akka.actor.default-dispatcher-16] [DEBUG] ShardManager - Creating Shard member-1-shard-default-config26 01:51:54,199 PM [test-akka.actor.default-dispatcher-16] [DEBUG] ShardManager - shard-manager-config26: In findPrimary: org.opendaylight.controller.cluster.datastore.messages.FindPrimary [shardName=default, waitUntilReady=true] 01:51:54,199 PM [test-akka.actor.default-dispatcher-16] [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] 01:51:54,813 PM [test-akka.actor.default-dispatcher-16] [DEBUG] ShardManager - shard-manager-config26: Received ShardNotInitializedTimeout message for shard default 01:51:54,813 PM [test-akka.actor.default-dispatcher-16] [DEBUG] ShardManager - shard-manager-config26: Returning NotInitializedException for shard default 01:51:54,814 PM [test-akka.actor.default-dispatcher-16] [DEBUG] ShardManager - shard-manager-config26: Initializing shard [default] 01:51:54,814 PM [test-akka.actor.default-dispatcher-16] [DEBUG] ShardInformation - Shard member-1-shard-default-config26 is initialized 01:51:55,14 PM [main] [INFO] ShardManagerTest - testOnReceiveFindPrimaryWaitForReadyWithUninitializedShard ending 01:51:55,116 PM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/$m#-805032012] 01:51:55,128 PM [test-akka.actor.default-dispatcher-16] [INFO] ShardManager - Stopping ShardManager shard-manager-config26 01:51:55,137 PM [test-akka.actor.default-dispatcher-6] [INFO] ShardManager - Starting ShardManager shard-manager-config27 01:51:55,139 PM [test-akka.actor.default-dispatcher-16] [INFO] ShardManager - Recovery complete : shard-manager-config27 01:51:55,139 PM [test-akka.actor.default-dispatcher-16] [DEBUG] ShardManager - shard-manager-config27: Creating local shard: member-1-shard-default-config27 01:51:55,148 PM [test-akka.actor.default-dispatcher-6] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1 01:51:55,148 PM [test-akka.actor.default-dispatcher-6] [DEBUG] ShardManager - Creating Shard member-1-shard-default-config27 01:51:55,148 PM [test-akka.actor.default-dispatcher-6] [DEBUG] ShardManager - shard-manager-config27: Initializing shard [default] 01:51:55,148 PM [test-akka.actor.default-dispatcher-6] [DEBUG] ShardInformation - Shard member-1-shard-default-config27 is initialized 01:51:55,148 PM [test-akka.actor.default-dispatcher-6] [DEBUG] ShardManager - shard-manager-config27: findLocalShard : default 01:51:55,250 PM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/$n#-193859283] 01:51:55,261 PM [test-akka.actor.default-dispatcher-6] [INFO] ShardManager - Stopping ShardManager shard-manager-config27 01:51:55,265 PM [main] [INFO] ShardManagerTest - testRegisterForShardLeaderChanges starting 01:51:55,269 PM [test-akka.actor.default-dispatcher-6] [INFO] ShardManager - Starting ShardManager shard-manager-config28 01:51:55,270 PM [test-akka.actor.default-dispatcher-16] [INFO] ShardManager - Recovery complete : shard-manager-config28 01:51:55,270 PM [test-akka.actor.default-dispatcher-16] [DEBUG] ShardManager - shard-manager-config28: Creating local shard: member-1-shard-default-config28 01:51:55,280 PM [test-akka.actor.default-dispatcher-6] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1 01:51:55,280 PM [test-akka.actor.default-dispatcher-6] [DEBUG] ShardManager - Creating Shard member-1-shard-default-config28 01:51:55,280 PM [test-akka.actor.default-dispatcher-6] [DEBUG] ShardManager - shard-manager-config28: Initializing shard [default] 01:51:55,280 PM [test-akka.actor.default-dispatcher-6] [DEBUG] ShardInformation - Shard member-1-shard-default-config28 is initialized 01:51:55,345 PM [test-akka.actor.default-dispatcher-6] [DEBUG] ShardManager - shard-manager-config28: onRegisterForShardAvailabilityChanges: org.opendaylight.controller.cluster.datastore.shardmanager.RegisterForShardAvailabilityChanges@42e2c04d 01:51:55,350 PM [test-akka.actor.default-dispatcher-6] [INFO] ShardManager - shard-manager-config28: Received LeaderStateChanged message: LeaderStateChanged [memberId=member-1-shard-default-config28, leaderId=member-1-shard-default-config28, leaderPayloadVersion=13] 01:51:55,358 PM [test-akka.actor.default-dispatcher-6] [INFO] ShardManager - shard-manager-config28: Received LeaderStateChanged message: LeaderStateChanged [memberId=member-1-shard-default-config28, leaderId=member-1-shard-default-config28, leaderPayloadVersion=13] 01:51:55,860 PM [test-akka.actor.default-dispatcher-6] [INFO] ShardManager - shard-manager-config28: Received LeaderStateChanged message: LeaderStateChanged [memberId=member-1-shard-default-config28, leaderId=null, leaderPayloadVersion=13] 01:51:55,887 PM [test-akka.actor.default-dispatcher-6] [INFO] ShardManager - shard-manager-config28: Received LeaderStateChanged message: LeaderStateChanged [memberId=member-1-shard-default-config28, leaderId=member-2-shard-default-config28, leaderPayloadVersion=13] 01:51:55,898 PM [test-akka.actor.default-dispatcher-6] [INFO] ShardManager - shard-manager-config28: Received LeaderStateChanged message: LeaderStateChanged [memberId=member-1-shard-default-config28, leaderId=member-1-shard-default-config28, leaderPayloadVersion=13] 01:51:56,398 PM [main] [INFO] ShardManagerTest - testRegisterForShardLeaderChanges ending 01:51:56,500 PM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/$o#413405454] 01:51:56,511 PM [test-akka.actor.default-dispatcher-6] [INFO] ShardManager - Stopping ShardManager shard-manager-config28 01:51:56,517 PM [main] [INFO] ShardManager - Starting ShardManager shard-manager-config29 01:51:56,520 PM [test-akka.actor.default-dispatcher-16] [INFO] ShardManager - Recovery complete : shard-manager-config29 01:51:56,520 PM [test-akka.actor.default-dispatcher-16] [DEBUG] ShardManager - shard-manager-config29: Creating local shard: member-1-shard-default-config29 01:51:56,623 PM [main] [INFO] TestActorFactory - Killing actor TestActor[akka://test/user/$$h] 01:51:56,634 PM [main] [INFO] ShardManager - Stopping ShardManager shard-manager-config29 01:51:56,641 PM [test-akka.actor.default-dispatcher-6] [INFO] ShardManager - Starting ShardManager shard-manager-config30 01:51:56,643 PM [test-akka.actor.default-dispatcher-6] [INFO] ShardManager - Recovery complete : shard-manager-config30 01:51:56,643 PM [test-akka.actor.default-dispatcher-6] [DEBUG] ShardManager - shard-manager-config30: Creating local shard: member-1-shard-default-config30 01:51:56,652 PM [test-akka.actor.default-dispatcher-16] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1 01:51:56,652 PM [test-akka.actor.default-dispatcher-16] [DEBUG] ShardManager - Creating Shard member-1-shard-default-config30 01:51:56,652 PM [test-akka.actor.default-dispatcher-16] [DEBUG] ShardManager - shard-manager-config30: In findPrimary: org.opendaylight.controller.cluster.datastore.messages.FindPrimary [shardName=non-existent, waitUntilReady=false] 01:51:56,652 PM [test-akka.actor.default-dispatcher-16] [DEBUG] ShardManager - shard-manager-config30: No shard found for non-existent 01:51:56,754 PM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/$p#-1099752950] 01:51:56,766 PM [test-akka.actor.default-dispatcher-16] [INFO] ShardManager - Stopping ShardManager shard-manager-config30 01:51:56,773 PM [test-akka.actor.default-dispatcher-6] [INFO] ShardManager - Starting ShardManager shard-manager-config31 01:51:56,775 PM [test-akka.actor.default-dispatcher-16] [INFO] ShardManager - Recovery complete : shard-manager-config31 01:51:56,784 PM [test-akka.actor.default-dispatcher-6] [DEBUG] ShardManager - shard-manager-config31: onAddShardReplica: AddShardReplica[ShardName=model-inventory] 01:51:56,784 PM [test-akka.actor.default-dispatcher-6] [DEBUG] ShardManager - shard-manager-config31: No module configuration exists for shard model-inventory 01:51:56,886 PM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/$q#-6293856] 01:51:56,897 PM [test-akka.actor.default-dispatcher-6] [INFO] ShardManager - Stopping ShardManager shard-manager-config31 01:51:56,900 PM [main] [INFO] ShardManagerTest - testAddShardReplicaWithPreExistingReplicaInRemoteShardLeader starting 01:51:56,904 PM [test-akka.actor.default-dispatcher-6] [INFO] ShardManager - Starting ShardManager shard-manager-config32 01:51:56,911 PM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Recovery complete : shard-manager-config32 01:51:56,911 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config32: Creating local shard: member-1-shard-default-config32 01:51:56,915 PM [test-akka.actor.default-dispatcher-6] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1 01:51:56,915 PM [test-akka.actor.default-dispatcher-6] [DEBUG] ShardManager - Creating Shard member-1-shard-default-config32 01:51:56,915 PM [test-akka.actor.default-dispatcher-6] [DEBUG] ShardManager - shard-manager-config32: Initializing shard [default] 01:51:56,915 PM [test-akka.actor.default-dispatcher-6] [DEBUG] ShardInformation - Shard member-1-shard-default-config32 is initialized 01:51:56,915 PM [test-akka.actor.default-dispatcher-6] [INFO] ShardManager - shard-manager-config32: Received MemberUp: memberName: MemberName{name=leader-member}, address: akka://test 01:51:56,916 PM [test-akka.actor.default-dispatcher-6] [INFO] ShardInformation - updatePeerAddress for peer leader-member-shard-default-config32 with address akka://test/user/shardmanager-config32/leader-member-shard-default-config32 01:51:56,916 PM [test-akka.actor.default-dispatcher-6] [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 01:51:56,916 PM [test-akka.actor.default-dispatcher-6] [INFO] ShardManager - shard-manager-config32: Received role changed for member-1-shard-default-config32 from Candidate to Follower 01:51:56,916 PM [test-akka.actor.default-dispatcher-6] [INFO] ShardManager - shard-manager-config32: Received LeaderStateChanged message: LeaderStateChanged [memberId=member-1-shard-default-config32, leaderId=leader-member-shard-default-config32, leaderPayloadVersion=13] 01:51:56,916 PM [test-akka.actor.default-dispatcher-6] [INFO] ShardManager - shard-manager-config32: All Shards are ready - data store config32 is ready 01:51:56,916 PM [test-akka.actor.default-dispatcher-6] [DEBUG] ShardManager - shard-manager-config32: onAddShardReplica: AddShardReplica[ShardName=default] 01:51:56,916 PM [test-akka.actor.default-dispatcher-6] [DEBUG] ShardManager - shard-manager-config32: In findPrimary: org.opendaylight.controller.cluster.datastore.messages.FindPrimary [shardName=default, waitUntilReady=true] 01:51:56,916 PM [test-akka.actor.default-dispatcher-6] [DEBUG] ShardManager - shard-manager-config32: Found primary for default: RemotePrimaryShardFound [primaryPath=akka://test/user/shardmanager-config32/leader-member-shard-default-config32, primaryVersion=13] 01:51:56,916 PM [test-akka.actor.default-dispatcher-6] [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 01:51:56,917 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 01:51:56,917 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config32: Local shard default already exists 01:51:56,966 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config32: findLocalShard : default 01:51:56,968 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config32: onAddShardReplica: AddShardReplica[ShardName=default] 01:51:56,968 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] 01:51:56,968 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] 01:51:56,968 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 01:51:56,969 PM [test-akka.actor.default-dispatcher-6] [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 01:51:56,969 PM [test-akka.actor.default-dispatcher-6] [DEBUG] ShardManager - shard-manager-config32: Local shard default already exists 01:51:56,972 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardInformation - Sending new DatastoreContext to member-1-shard-default-config32 01:51:56,972 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config32: onAddShardReplica: AddShardReplica[ShardName=default] 01:51:56,972 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config32: In findPrimary: org.opendaylight.controller.cluster.datastore.messages.FindPrimary [shardName=default, waitUntilReady=true] 01:51:56,973 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config32: Found primary for default: RemotePrimaryShardFound [primaryPath=akka://test/user/shardmanager-config32/leader-member-shard-default-config32, primaryVersion=13] 01:51:56,973 PM [test-akka.actor.default-dispatcher-6] [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 01:51:57,94 PM [test-akka.actor.default-dispatcher-11] [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. 01:51:57,94 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config32: findLocalShard : default 01:51:57,95 PM [main] [INFO] ShardManagerTest - testAddShardReplicaWithPreExistingReplicaInRemoteShardLeader ending 01:51:57,196 PM [main] [INFO] TestActorFactory - Killing actor TestActor[akka://test/user/shardmanager-config32] 01:51:57,208 PM [test-akka.actor.default-dispatcher-6] [INFO] ShardManager - Stopping ShardManager shard-manager-config32 01:51:57,211 PM [main] [INFO] ShardManagerTest - testOnReceiveFindPrimaryForRemoteShard starting 01:51:57,224 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] Slf4jLogger - Slf4jLogger started 01:51:57,246 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 [-4538779968680178771] 01:51:57,246 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] ... 01:51:57,253 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] 01:51:57,253 PM [cluster-test-akka.actor.default-dispatcher-10] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2558] - Started up successfully 01:51:57,264 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 01:51:57,264 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 01:51:57,271 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 01:51:57,271 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) 01:51:57,271 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] 01:51:57,280 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'. 01:51:57,286 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] ShardManager - Starting ShardManager shard-manager-config33 01:51:57,304 PM [cluster-test-akka.actor.default-dispatcher-6] [INFO] Slf4jLogger - Slf4jLogger started 01:51:57,306 PM [cluster-test-akka.actor.default-dispatcher-10] [INFO] ShardManager - Recovery complete : shard-manager-config33 01:51:57,306 PM [cluster-test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config33: Creating local shard: member-1-shard-default-config33 01:51:57,307 PM [cluster-test-akka.actor.default-dispatcher-10] [INFO] ShardManager - shard-manager-config33: Received MemberUp: memberName: MemberName{name=member-1}, address: akka://cluster-test@127.0.0.1:2558 01:51:57,307 PM [cluster-test-akka.actor.default-dispatcher-10] [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 01:51:57,339 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 [-6415618079774824443] 01:51:57,339 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] ... 01:51:57,339 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 01:51:57,339 PM [cluster-test-akka.actor.default-dispatcher-6] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2559] - Started up successfully 01:51:57,351 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 01:51:57,351 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 01:51:57,352 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-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'. 01:51:57,354 PM [cluster-test-akka.actor.default-dispatcher-6] [INFO] ShardManager - Starting ShardManager shard-manager-config33 01:51:57,360 PM [cluster-test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1 01:51:57,360 PM [cluster-test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - Creating Shard member-1-shard-default-config33 01:51:57,360 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 01:51:57,360 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 01:51:57,360 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#-1659970093] 01:51:57,392 PM [cluster-test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Recovery complete : shard-manager-config33 01:51:57,392 PM [cluster-test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config33: Creating local shard: member-2-shard-default-config33 01:51:57,393 PM [cluster-test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config33: Creating local shard: member-2-shard-astronauts-config33 01:51:57,394 PM [cluster-test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1 01:51:57,394 PM [cluster-test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - Creating Shard member-2-shard-default-config33 01:51:57,394 PM [cluster-test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - Creating Shard member-2-shard-astronauts-config33 01:51:57,394 PM [cluster-test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config33: Initializing shard [astronauts] 01:51:57,394 PM [cluster-test-akka.actor.default-dispatcher-11] [DEBUG] ShardInformation - Shard member-2-shard-astronauts-config33 is initialized 01:51:57,394 PM [cluster-test-akka.actor.default-dispatcher-11] [INFO] ShardManager - shard-manager-config33: Received LeaderStateChanged message: LeaderStateChanged [memberId=member-2-shard-astronauts-config33, leaderId=member-2-shard-astronauts-config33, leaderPayloadVersion=12] 01:51:57,394 PM [cluster-test-akka.actor.default-dispatcher-11] [INFO] ShardManager - shard-manager-config33: Received role changed for member-2-shard-astronauts-config33 from Candidate to Leader 01:51:57,433 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] 01:51:57,438 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] 01:51:57,439 PM [cluster-test-akka.actor.default-dispatcher-11] [INFO] ShardManager - shard-manager-config33: Received MemberUp: memberName: MemberName{name=member-1}, address: akka://cluster-test@127.0.0.1:2558 01:51:57,439 PM [cluster-test-akka.actor.default-dispatcher-11] [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 01:51:57,439 PM [cluster-test-akka.actor.default-dispatcher-11] [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 01:51:57,441 PM [cluster-test-akka.actor.default-dispatcher-11] [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 01:51:57,441 PM [cluster-test-akka.actor.default-dispatcher-11] [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 01:51:58,280 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] 01:51:58,282 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 01:51:58,282 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 01:51:58,282 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 01:51:58,282 PM [cluster-test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config33: In findPrimary: org.opendaylight.controller.cluster.datastore.messages.FindPrimary [shardName=astronauts, waitUntilReady=false] 01:51:58,282 PM [cluster-test-akka.actor.default-dispatcher-11] [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] 01:51:58,289 PM [cluster-test-akka.actor.default-dispatcher-6] [DEBUG] ShardManager - shard-manager-config33: In findPrimary: org.opendaylight.controller.cluster.datastore.messages.RemoteFindPrimary [shardName=astronauts, waitUntilReady=false] 01:51:58,289 PM [cluster-test-akka.actor.default-dispatcher-6] [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#1750123140, primaryVersion=12] 01:51:58,291 PM [main] [INFO] ShardManagerTest - testOnReceiveFindPrimaryForRemoteShard ending 01:51:58,375 PM [cluster-test-akka.actor.default-dispatcher-6] [INFO] ShardManager - shard-manager-config33: Received MemberUp: memberName: MemberName{name=member-2}, address: akka://cluster-test@127.0.0.1:2559 01:51:58,375 PM [cluster-test-akka.actor.default-dispatcher-6] [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 01:51:58,375 PM [cluster-test-akka.actor.default-dispatcher-6] [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 01:51:58,375 PM [cluster-test-akka.actor.default-dispatcher-6] [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 01:51:58,375 PM [cluster-test-akka.actor.default-dispatcher-6] [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 01:51:58,394 PM [cluster-test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Stopping ShardManager shard-manager-config33 01:51:58,399 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] RemoteActorRefProvider$RemotingTerminator - Shutting down remote daemon. 01:51:58,399 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] RemoteActorRefProvider$RemotingTerminator - Remote daemon shut down; proceeding with flushing remote transports. 01:51:58,413 PM [cluster-test-akka.actor.default-dispatcher-11] [WARN] Materializer - [outbound connection to [akka://cluster-test@127.0.0.1:2559], message stream] Upstream failed, cause: StreamTcpException: The connection has been aborted 01:51:58,413 PM [cluster-test-akka.actor.default-dispatcher-11] [WARN] Materializer - [outbound connection to [akka://cluster-test@127.0.0.1:2559], control stream] Upstream failed, cause: StreamTcpException: The connection has been aborted 01:51:58,417 PM [cluster-test-akka.actor.default-dispatcher-11] [INFO] RemoteActorRefProvider$RemotingTerminator - Remoting shut down. 01:51:58,432 PM [cluster-test-akka.actor.default-dispatcher-6] [INFO] ShardManager - Stopping ShardManager shard-manager-config33 01:51:58,434 PM [cluster-test-akka.actor.default-dispatcher-13] [INFO] RemoteActorRefProvider$RemotingTerminator - Shutting down remote daemon. 01:51:58,434 PM [cluster-test-akka.actor.default-dispatcher-13] [INFO] RemoteActorRefProvider$RemotingTerminator - Remote daemon shut down; proceeding with flushing remote transports. 01:51:59,460 PM [cluster-test-akka.actor.default-dispatcher-13] [INFO] RemoteActorRefProvider$RemotingTerminator - Remoting shut down. [WARN] [04/29/2024 13:51:59.462] [cluster-test-akka.actor.internal-dispatcher-2] [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 01:51:59,478 PM [test-akka.actor.default-dispatcher-6] [INFO] ShardManager - Starting ShardManager shard-manager-config34 01:51:59,480 PM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Recovery complete : shard-manager-config34 01:51:59,480 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config34: Creating local shard: member-1-shard-default-config34 01:51:59,489 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config34: findLocalShard : default 01:51:59,489 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config34: Returning NotInitializedException for shard default 01:51:59,591 PM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/$r#-228129053] 01:51:59,602 PM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - Stopping ShardManager shard-manager-config34 01:51:59,614 PM [test-akka.actor.default-dispatcher-6] [INFO] ShardManager - Starting ShardManager shard-manager-config35 01:51:59,617 PM [test-akka.actor.default-dispatcher-6] [INFO] ShardManager - Recovery complete : shard-manager-config35 01:51:59,617 PM [test-akka.actor.default-dispatcher-6] [DEBUG] ShardManager - shard-manager-config35: Creating local shard: member-1-shard-default-config35 01:51:59,623 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1 01:51:59,623 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - Creating Shard member-1-shard-default-config35 01:51:59,623 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config35: Initializing shard [default] 01:51:59,623 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardInformation - Shard member-1-shard-default-config35 is initialized 01:51:59,623 PM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - shard-manager-config35: Received LeaderStateChanged message: LeaderStateChanged [memberId=member-1-shard-default-config35, leaderId=member-1-shard-default-config35, leaderPayloadVersion=13] 01:51:59,623 PM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - shard-manager-config35: Received role changed for member-1-shard-default-config35 from Candidate to Leader 01:51:59,623 PM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - shard-manager-config35: All Shards are ready - data store config35 is ready 01:51:59,623 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config35: onChangeShardServersVotingStatus: ChangeShardMembersVotingStatus [shardName=default, meberVotingStatusMap={member-2=true}] 01:51:59,624 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config35: findLocalShard : default 01:51:59,624 PM [test-akka.actor.default-dispatcher-6] [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 01:51:59,624 PM [test-akka.actor.default-dispatcher-6] [DEBUG] ShardManager - shard-manager-config35: Received ServerChangeReply{status=OK} from local shard akka://test/user/member-1-shard-default-config35 01:51:59,624 PM [test-akka.actor.default-dispatcher-6] [DEBUG] ShardManager - shard-manager-config35: ChangeServersVotingStatus succeeded for shard default 01:51:59,776 PM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/member-1-shard-default-config35#1677008681] 01:51:59,790 PM [main] [INFO] ShardManagerTest - testShutDown starting 01:51:59,797 PM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Starting ShardManager shard-manager-config36 01:51:59,799 PM [test-akka.actor.default-dispatcher-6] [INFO] ShardManager - Recovery complete : shard-manager-config36 01:51:59,799 PM [test-akka.actor.default-dispatcher-6] [DEBUG] ShardManager - shard-manager-config36: Creating local shard: member-1-shard-shard2-config36 01:51:59,799 PM [test-akka.actor.default-dispatcher-6] [DEBUG] ShardManager - shard-manager-config36: Creating local shard: member-1-shard-shard1-config36 01:51:59,809 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1 01:51:59,809 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - Creating Shard member-1-shard-shard2-config36 01:51:59,809 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - Creating Shard member-1-shard-shard1-config36 01:51:59,809 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config36: Initializing shard [shard1] 01:51:59,809 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardInformation - Shard member-1-shard-shard1-config36 is initialized 01:51:59,809 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config36: Initializing shard [shard2] 01:51:59,809 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardInformation - Shard member-1-shard-shard2-config36 is initialized 01:51:59,810 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config36: Issuing gracefulStop to shard member-1-shard-shard2-config36 01:51:59,810 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config36: Issuing gracefulStop to shard member-1-shard-shard1-config36 01:51:59,810 PM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Shutting down ShardManager shard-manager-config36 - waiting on 2 shards 01:52:00,364 PM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/member-1-shard-shard1-config36#-1798274783] 01:52:00,367 PM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/member-1-shard-shard2-config36#-347427214] 01:52:00,367 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config36: All shards shutdown - sending PoisonPill to self 01:52:00,368 PM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Stopping ShardManager shard-manager-config36 01:52:00,368 PM [main] [INFO] ShardManagerTest - testShutDown ending 01:52:00,470 PM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/$t#-2100129096] 01:52:00,485 PM [main] [INFO] ShardManagerTest - testOnReceiveFindPrimaryForNonLocalLeaderShardBeforeMemberUp starting 01:52:00,490 PM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Starting ShardManager shard-manager-config37 01:52:00,492 PM [test-akka.actor.default-dispatcher-6] [INFO] ShardManager - Recovery complete : shard-manager-config37 01:52:00,492 PM [test-akka.actor.default-dispatcher-6] [DEBUG] ShardManager - shard-manager-config37: Creating local shard: member-1-shard-default-config37 01:52:00,500 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1 01:52:00,501 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - Creating Shard member-1-shard-default-config37 01:52:00,501 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config37: Initializing shard [default] 01:52:00,501 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardInformation - Shard member-1-shard-default-config37 is initialized 01:52:00,501 PM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - shard-manager-config37: Received role changed for member-1-shard-default-config37 from Candidate to Follower 01:52:00,501 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManagerTest$TestShardManager - Received unhandled message LeaderStateChanged [memberId=member-1-shard-default-config37, leaderId=member-2-shard-default-config37, leaderPayloadVersion=13] 01:52:00,503 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config37: In findPrimary: org.opendaylight.controller.cluster.datastore.messages.FindPrimary [shardName=default, waitUntilReady=false] 01:52:00,503 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config37: Returning NoShardLeaderException for shard default 01:52:00,503 PM [main] [INFO] ShardManagerTest - testOnReceiveFindPrimaryForNonLocalLeaderShardBeforeMemberUp ending 01:52:00,605 PM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/$u#1546732222] 01:52:00,616 PM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Stopping ShardManager shard-manager-config37 01:52:00,620 PM [main] [INFO] ShardManagerTest - testOnReceiveFindPrimaryWaitForReadyWithNoRoleShard starting 01:52:00,625 PM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Starting ShardManager shard-manager-config38 01:52:00,626 PM [test-akka.actor.default-dispatcher-6] [INFO] ShardManager - Recovery complete : shard-manager-config38 01:52:00,626 PM [test-akka.actor.default-dispatcher-6] [DEBUG] ShardManager - shard-manager-config38: Creating local shard: member-1-shard-default-config38 01:52:00,636 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1 01:52:00,636 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - Creating Shard member-1-shard-default-config38 01:52:00,636 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config38: Initializing shard [default] 01:52:00,636 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardInformation - Shard member-1-shard-default-config38 is initialized 01:52:00,636 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config38: In findPrimary: org.opendaylight.controller.cluster.datastore.messages.FindPrimary [shardName=default, waitUntilReady=true] 01:52:00,636 PM [test-akka.actor.default-dispatcher-11] [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] 01:52:01,853 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config38: Received ShardNotInitializedTimeout message for shard default 01:52:01,853 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config38: Returning NoShardLeaderException for shard default 01:52:01,855 PM [main] [INFO] ShardManagerTest - testOnReceiveFindPrimaryWaitForReadyWithNoRoleShard ending 01:52:01,957 PM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/$v#-906220975] 01:52:01,968 PM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Stopping ShardManager shard-manager-config38 01:52:01,971 PM [main] [INFO] ShardManagerTest - testShardPersistenceWithRestoredData starting 01:52:01,977 PM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Starting ShardManager shard-manager-config39 01:52:01,978 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config39: onSnapshotOffer: ShardManagerSnapshot [ShardList = [default, astronauts] ] 01:52:01,978 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config39: adding shard astronauts 01:52:01,978 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config39: removing shard people 01:52:01,979 PM [test-akka.actor.default-dispatcher-6] [INFO] ShardManager - Recovery complete : shard-manager-config39 01:52:01,979 PM [test-akka.actor.default-dispatcher-6] [DEBUG] ShardManager - shard-manager-config39: Creating local shard: member-1-shard-default-config39 01:52:01,980 PM [test-akka.actor.default-dispatcher-6] [DEBUG] ShardManager - shard-manager-config39: Creating local shard: member-1-shard-astronauts-config39 01:52:01,991 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config39: findLocalShard : people 01:52:01,991 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config39: Local shard people not found - shards present: [default, astronauts] 01:52:01,991 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config39: findLocalShard : default 01:52:01,991 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config39: Returning NotInitializedException for shard default 01:52:01,991 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config39: findLocalShard : astronauts 01:52:01,991 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config39: Returning NotInitializedException for shard astronauts 01:52:01,991 PM [main] [INFO] ShardManagerTest - testShardPersistenceWithRestoredData ending 01:52:02,98 PM [main] [INFO] TestActorFactory - Killing actor TestActor[akka://test/user/$$i] 01:52:02,109 PM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Stopping ShardManager shard-manager-config39 01:52:02,112 PM [main] [INFO] ShardManagerTest - testOnReceiveFindPrimaryForNonLocalLeaderShard starting 01:52:02,116 PM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - Starting ShardManager shard-manager-config40 01:52:02,119 PM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Recovery complete : shard-manager-config40 01:52:02,119 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config40: Creating local shard: member-1-shard-default-config40 01:52:02,127 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1 01:52:02,127 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - Creating Shard member-1-shard-default-config40 01:52:02,127 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config40: Initializing shard [default] 01:52:02,127 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardInformation - Shard member-1-shard-default-config40 is initialized 01:52:02,127 PM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - shard-manager-config40: Received MemberUp: memberName: MemberName{name=member-2}, address: akka://test 01:52:02,127 PM [test-akka.actor.default-dispatcher-10] [INFO] ShardInformation - updatePeerAddress for peer member-2-shard-default-config40 with address akka://test/user/shardmanager-config40/member-2-shard-default-config40 01:52:02,128 PM [test-akka.actor.default-dispatcher-10] [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 01:52:02,128 PM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - shard-manager-config40: Received role changed for member-1-shard-default-config40 from Candidate to Follower 01:52:02,128 PM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - shard-manager-config40: Received LeaderStateChanged message: LeaderStateChanged [memberId=member-1-shard-default-config40, leaderId=member-2-shard-default-config40, leaderPayloadVersion=12] 01:52:02,128 PM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - shard-manager-config40: All Shards are ready - data store config40 is ready 01:52:02,128 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config40: In findPrimary: org.opendaylight.controller.cluster.datastore.messages.FindPrimary [shardName=default, waitUntilReady=false] 01:52:02,128 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config40: Found primary for default: RemotePrimaryShardFound [primaryPath=akka://test/user/shardmanager-config40/member-2-shard-default-config40, primaryVersion=12] 01:52:02,128 PM [main] [INFO] ShardManagerTest - testOnReceiveFindPrimaryForNonLocalLeaderShard ending 01:52:02,230 PM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/$w#734546607] 01:52:02,232 PM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - Stopping ShardManager shard-manager-config40 01:52:02,235 PM [main] [INFO] ShardManagerTest - testShardAvailabilityOnChangeOfMemberReachability starting 01:52:02,247 PM [cluster-test-akka.actor.default-dispatcher-6] [INFO] Slf4jLogger - Slf4jLogger started 01:52:02,275 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 [3438347469488619407] 01:52:02,276 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] ... 01:52:02,285 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] 01:52:02,285 PM [cluster-test-akka.actor.default-dispatcher-10] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2558] - Started up successfully 01:52:02,299 PM [cluster-test-akka.actor.default-dispatcher-6] [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 01:52:02,299 PM [cluster-test-akka.actor.default-dispatcher-6] [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 01:52:02,303 PM [cluster-test-akka.actor.default-dispatcher-6] [INFO] ShardManager - Starting ShardManager shard-manager-config41 01:52:02,311 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-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'. 01:52:02,311 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:2558] is JOINING itself (with roles [member-1, dc-default], version [0.0.0]) and forming new cluster 01:52:02,312 PM [cluster-test-akka.actor.default-dispatcher-10] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2558] - is the new leader among reachable nodes (more leaders may exist) 01:52:02,312 PM [cluster-test-akka.actor.default-dispatcher-10] [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] 01:52:02,337 PM [cluster-test-akka.actor.default-dispatcher-14] [INFO] ShardManager - Recovery complete : shard-manager-config41 01:52:02,337 PM [cluster-test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - shard-manager-config41: Creating local shard: member-1-shard-default-config41 01:52:02,338 PM [cluster-test-akka.actor.default-dispatcher-14] [INFO] ShardManager - shard-manager-config41: Received MemberUp: memberName: MemberName{name=member-1}, address: akka://cluster-test@127.0.0.1:2558 01:52:02,338 PM [cluster-test-akka.actor.default-dispatcher-14] [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 01:52:02,349 PM [cluster-test-akka.actor.default-dispatcher-6] [INFO] Slf4jLogger - Slf4jLogger started 01:52:02,373 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 [8943406336443005017] 01:52:02,378 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] ... 01:52:02,378 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 01:52:02,378 PM [cluster-test-akka.actor.default-dispatcher-6] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2559] - Started up successfully 01:52:02,387 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 01:52:02,387 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 01:52:02,405 PM [cluster-test-akka.actor.default-dispatcher-6] [INFO] ShardManager - Starting ShardManager shard-manager-config41 01:52:02,414 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-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'. 01:52:02,422 PM [cluster-test-akka.actor.default-dispatcher-13] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1 01:52:02,422 PM [cluster-test-akka.actor.default-dispatcher-13] [DEBUG] ShardManager - Creating Shard member-1-shard-default-config41 01:52:02,422 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 01:52:02,422 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 01:52:02,423 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#-1033766137] 01:52:02,423 PM [cluster-test-akka.actor.default-dispatcher-13] [DEBUG] ShardManager - shard-manager-config41: Initializing shard [default] 01:52:02,423 PM [cluster-test-akka.actor.default-dispatcher-13] [DEBUG] ShardInformation - Shard member-1-shard-default-config41 is initialized 01:52:02,423 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] 01:52:02,423 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 01:52:02,425 PM [cluster-test-akka.actor.default-dispatcher-15] [INFO] ShardManager - Recovery complete : shard-manager-config41 01:52:02,425 PM [cluster-test-akka.actor.default-dispatcher-15] [DEBUG] ShardManager - shard-manager-config41: Creating local shard: member-2-shard-default-config41 01:52:02,425 PM [cluster-test-akka.actor.default-dispatcher-15] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1 01:52:02,425 PM [cluster-test-akka.actor.default-dispatcher-15] [DEBUG] ShardManager - Creating Shard member-2-shard-default-config41 01:52:02,426 PM [cluster-test-akka.actor.default-dispatcher-15] [DEBUG] ShardManager - shard-manager-config41: Initializing shard [default] 01:52:02,426 PM [cluster-test-akka.actor.default-dispatcher-15] [DEBUG] ShardInformation - Shard member-2-shard-default-config41 is initialized 01:52:02,426 PM [cluster-test-akka.actor.default-dispatcher-15] [INFO] ShardManager - shard-manager-config41: Received LeaderStateChanged message: LeaderStateChanged [memberId=member-2-shard-default-config41, leaderId=member-2-shard-default-config41, leaderPayloadVersion=13] 01:52:02,426 PM [cluster-test-akka.actor.default-dispatcher-15] [INFO] ShardManager - shard-manager-config41: Received role changed for member-2-shard-default-config41 from Candidate to Leader 01:52:02,426 PM [cluster-test-akka.actor.default-dispatcher-15] [INFO] ShardManager - shard-manager-config41: All Shards are ready - data store config41 is ready 01:52:02,487 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:2559] is JOINING, roles [member-2, dc-default], version [0.0.0] 01:52:02,491 PM [cluster-test-akka.actor.default-dispatcher-12] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2559] - Welcome from [akka://cluster-test@127.0.0.1:2558] 01:52:02,491 PM [cluster-test-akka.actor.default-dispatcher-12] [INFO] ShardManager - shard-manager-config41: Received MemberUp: memberName: MemberName{name=member-1}, address: akka://cluster-test@127.0.0.1:2558 01:52:02,491 PM [cluster-test-akka.actor.default-dispatcher-12] [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 01:52:02,491 PM [cluster-test-akka.actor.default-dispatcher-12] [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 01:52:02,491 PM [cluster-test-akka.actor.default-dispatcher-12] [INFO] ShardManager - shard-manager-config41: All Shards are ready - data store config41 is ready 01:52:03,303 PM [cluster-test-akka.actor.default-dispatcher-13] [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] 01:52:03,304 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 01:52:03,304 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 01:52:03,304 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 01:52:03,304 PM [cluster-test-akka.actor.default-dispatcher-13] [INFO] ShardManager - shard-manager-config41: All Shards are ready - data store config41 is ready 01:52:03,305 PM [cluster-test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config41: In findPrimary: org.opendaylight.controller.cluster.datastore.messages.FindPrimary [shardName=default, waitUntilReady=true] 01:52:03,305 PM [cluster-test-akka.actor.default-dispatcher-11] [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] 01:52:03,305 PM [cluster-test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Received UnreachableMember: memberName MemberName{name=member-2}, address: akka://cluster-test@127.0.0.1:2558 01:52:03,305 PM [cluster-test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - Marking Leader member-2-shard-default-config41 as unavailable. 01:52:03,306 PM [cluster-test-akka.actor.default-dispatcher-11] [INFO] ShardManager - shard-manager-config41: Received MemberRemoved: memberName: MemberName{name=member-2}, address: akka://cluster-test@127.0.0.1:2558 01:52:03,306 PM [cluster-test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config41: In findPrimary: org.opendaylight.controller.cluster.datastore.messages.FindPrimary [shardName=default, waitUntilReady=true] 01:52:03,306 PM [cluster-test-akka.actor.default-dispatcher-11] [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] 01:52:03,411 PM [cluster-test-akka.actor.default-dispatcher-15] [INFO] ShardManager - shard-manager-config41: Received MemberUp: memberName: MemberName{name=member-2}, address: akka://cluster-test@127.0.0.1:2559 01:52:03,411 PM [cluster-test-akka.actor.default-dispatcher-15] [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 01:52:03,411 PM [cluster-test-akka.actor.default-dispatcher-15] [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 01:52:03,411 PM [cluster-test-akka.actor.default-dispatcher-15] [INFO] ShardManager - shard-manager-config41: All Shards are ready - data store config41 is ready 01:52:04,521 PM [cluster-test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config41: Received ShardNotInitializedTimeout message for shard default 01:52:04,521 PM [cluster-test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config41: Returning NoShardLeaderException for shard default 01:52:04,522 PM [cluster-test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Received ReachableMember: memberName MemberName{name=member-2}, address: akka://cluster-test@127.0.0.1:2558 01:52:04,522 PM [cluster-test-akka.actor.default-dispatcher-11] [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 01:52:04,522 PM [cluster-test-akka.actor.default-dispatcher-11] [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 01:52:04,522 PM [cluster-test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - Marking Leader member-2-shard-default-config41 as available. 01:52:04,522 PM [cluster-test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config41: In findPrimary: org.opendaylight.controller.cluster.datastore.messages.FindPrimary [shardName=default, waitUntilReady=true] 01:52:04,522 PM [cluster-test-akka.actor.default-dispatcher-11] [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] 01:52:04,523 PM [cluster-test-akka.actor.default-dispatcher-11] [INFO] ShardManager - shard-manager-config41: Received MemberUp: memberName: MemberName{name=member-2}, address: akka://cluster-test@127.0.0.1:2558 01:52:04,523 PM [cluster-test-akka.actor.default-dispatcher-11] [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 01:52:04,523 PM [cluster-test-akka.actor.default-dispatcher-11] [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 01:52:04,523 PM [cluster-test-akka.actor.default-dispatcher-11] [INFO] ShardManager - shard-manager-config41: All Shards are ready - data store config41 is ready 01:52:04,523 PM [cluster-test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Received UnreachableMember: memberName MemberName{name=member-2}, address: akka://cluster-test@127.0.0.1:2558 01:52:04,523 PM [cluster-test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - Marking Leader member-2-shard-default-config41 as unavailable. 01:52:04,523 PM [cluster-test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config41: In findPrimary: org.opendaylight.controller.cluster.datastore.messages.FindPrimary [shardName=default, waitUntilReady=true] 01:52:04,524 PM [cluster-test-akka.actor.default-dispatcher-11] [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] 01:52:04,524 PM [cluster-test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Received ReachableMember: memberName MemberName{name=member-2}, address: akka://cluster-test@127.0.0.1:2558 01:52:04,524 PM [cluster-test-akka.actor.default-dispatcher-11] [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 01:52:04,524 PM [cluster-test-akka.actor.default-dispatcher-11] [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 01:52:04,524 PM [cluster-test-akka.actor.default-dispatcher-11] [DEBUG] ShardInformation - Shard member-1-shard-default-config41 is initialized - notifying 1 OnShardInitialized callbacks 01:52:04,524 PM [cluster-test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - Marking Leader member-2-shard-default-config41 as available. 01:52:04,524 PM [cluster-test-akka.actor.default-dispatcher-11] [DEBUG] ShardInformation - Shard member-1-shard-default-config41 is ready - notifying 1 OnShardInitialized callbacks 01:52:04,524 PM [cluster-test-akka.actor.default-dispatcher-11] [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] 01:52:04,524 PM [main] [INFO] ShardManagerTest - testShardAvailabilityOnChangeOfMemberReachability ending 01:52:04,626 PM [cluster-test-akka.actor.default-dispatcher-12] [INFO] ShardManager - Stopping ShardManager shard-manager-config41 01:52:04,628 PM [cluster-test-akka.actor.default-dispatcher-12] [INFO] RemoteActorRefProvider$RemotingTerminator - Shutting down remote daemon. 01:52:04,628 PM [cluster-test-akka.actor.default-dispatcher-12] [INFO] RemoteActorRefProvider$RemotingTerminator - Remote daemon shut down; proceeding with flushing remote transports. 01:52:04,644 PM [cluster-test-akka.actor.default-dispatcher-12] [WARN] Materializer - [outbound connection to [akka://cluster-test@127.0.0.1:2559], message stream] Upstream failed, cause: StreamTcpException: The connection has been aborted 01:52:04,644 PM [cluster-test-akka.actor.default-dispatcher-12] [WARN] Materializer - [outbound connection to [akka://cluster-test@127.0.0.1:2559], control stream] Upstream failed, cause: StreamTcpException: The connection has been aborted 01:52:04,647 PM [cluster-test-akka.actor.default-dispatcher-12] [INFO] RemoteActorRefProvider$RemotingTerminator - Remoting shut down. 01:52:04,665 PM [cluster-test-akka.actor.default-dispatcher-10] [INFO] ShardManager - Stopping ShardManager shard-manager-config41 01:52:04,666 PM [cluster-test-akka.actor.default-dispatcher-12] [INFO] RemoteActorRefProvider$RemotingTerminator - Shutting down remote daemon. 01:52:04,667 PM [cluster-test-akka.actor.default-dispatcher-12] [INFO] RemoteActorRefProvider$RemotingTerminator - Remote daemon shut down; proceeding with flushing remote transports. 01:52:05,686 PM [cluster-test-akka.actor.default-dispatcher-12] [INFO] RemoteActorRefProvider$RemotingTerminator - Remoting shut down. [WARN] [04/29/2024 13:52:05.689] [cluster-test-akka.actor.internal-dispatcher-2] [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 01:52:05,710 PM [main] [INFO] ShardManagerTest - testAddShardReplica starting 01:52:05,720 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] Slf4jLogger - Slf4jLogger started 01:52:05,742 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 [8897585426776796131] 01:52:05,742 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] ... 01:52:05,746 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] 01:52:05,746 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2558] - Started up successfully 01:52:05,757 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 01:52:05,757 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 01:52:05,764 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:2558] is JOINING itself (with roles [member-1, dc-default], version [0.0.0]) and forming new cluster 01:52:05,764 PM [cluster-test-akka.actor.default-dispatcher-10] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2558] - is the new leader among reachable nodes (more leaders may exist) 01:52:05,764 PM [cluster-test-akka.actor.default-dispatcher-10] [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] 01:52:05,773 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'. 01:52:05,776 PM [cluster-test-akka.actor.default-dispatcher-10] [INFO] ShardManager - Starting ShardManager shardmanager-config42 01:52:05,793 PM [cluster-test-akka.actor.default-dispatcher-10] [INFO] ShardManager - Recovery complete : shardmanager-config42 01:52:05,793 PM [cluster-test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shardmanager-config42: Creating local shard: member-1-shard-default-config42 01:52:05,794 PM [cluster-test-akka.actor.default-dispatcher-10] [INFO] ShardManager - shardmanager-config42: Received MemberUp: memberName: MemberName{name=member-1}, address: akka://cluster-test@127.0.0.1:2558 01:52:05,794 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 01:52:05,815 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] Slf4jLogger - Slf4jLogger started 01:52:05,848 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 [1302196220039688263] 01:52:05,848 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] ... 01:52:05,848 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 01:52:05,848 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2559] - Started up successfully 01:52:05,849 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 01:52:05,859 PM [cluster-test-akka.actor.default-dispatcher-11] [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 01:52:05,859 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'. 01:52:05,867 PM [cluster-test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1 01:52:05,867 PM [cluster-test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - Creating Shard member-1-shard-default-config42 01:52:05,867 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 01:52:05,867 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 01:52:05,868 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#609114615] 01:52:05,869 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] ShardManager - Starting ShardManager shardmanager-config42 01:52:05,882 PM [cluster-test-akka.actor.default-dispatcher-13] [INFO] ShardManager - Recovery complete : shardmanager-config42 01:52:05,882 PM [cluster-test-akka.actor.default-dispatcher-13] [DEBUG] ShardManager - shardmanager-config42: Creating local shard: member-2-shard-default-config42 01:52:05,883 PM [cluster-test-akka.actor.default-dispatcher-13] [DEBUG] ShardManager - shardmanager-config42: Creating local shard: member-2-shard-astronauts-config42 01:52:05,883 PM [cluster-test-akka.actor.default-dispatcher-13] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1 01:52:05,883 PM [cluster-test-akka.actor.default-dispatcher-13] [DEBUG] ShardManager - Creating Shard member-2-shard-default-config42 01:52:05,883 PM [cluster-test-akka.actor.default-dispatcher-13] [DEBUG] ShardManager - Creating Shard member-2-shard-astronauts-config42 01:52:05,883 PM [cluster-test-akka.actor.default-dispatcher-13] [DEBUG] ShardManager - shardmanager-config42: Initializing shard [astronauts] 01:52:05,883 PM [cluster-test-akka.actor.default-dispatcher-13] [DEBUG] ShardInformation - Shard member-2-shard-astronauts-config42 is initialized 01:52:05,883 PM [cluster-test-akka.actor.default-dispatcher-13] [INFO] ShardManager - shardmanager-config42: Received LeaderStateChanged message: LeaderStateChanged [memberId=member-2-shard-astronauts-config42, leaderId=member-2-shard-astronauts-config42, leaderPayloadVersion=12] 01:52:05,884 PM [cluster-test-akka.actor.default-dispatcher-13] [INFO] ShardManager - shardmanager-config42: Received role changed for member-2-shard-astronauts-config42 from Candidate to Leader 01:52:05,956 PM [cluster-test-akka.actor.default-dispatcher-14] [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] 01:52:05,961 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:2558] 01:52:05,963 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] ShardManager - shardmanager-config42: Received MemberUp: memberName: MemberName{name=member-1}, address: akka://cluster-test@127.0.0.1:2558 01:52:05,963 PM [cluster-test-akka.actor.default-dispatcher-5] [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 01:52:05,963 PM [cluster-test-akka.actor.default-dispatcher-5] [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 01:52:05,963 PM [cluster-test-akka.actor.default-dispatcher-5] [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 01:52:05,963 PM [cluster-test-akka.actor.default-dispatcher-5] [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 01:52:06,777 PM [cluster-test-akka.actor.default-dispatcher-14] [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] 01:52:06,779 PM [cluster-test-akka.actor.default-dispatcher-14] [INFO] ShardManager - shardmanager-config42: Received MemberUp: memberName: MemberName{name=member-2}, address: akka://cluster-test@127.0.0.1:2559 01:52:06,779 PM [cluster-test-akka.actor.default-dispatcher-14] [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 01:52:06,779 PM [cluster-test-akka.actor.default-dispatcher-14] [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 01:52:06,782 PM [cluster-test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shardmanager-config42: onAddShardReplica: AddShardReplica[ShardName=astronauts] 01:52:06,782 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] 01:52:06,782 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] 01:52:06,785 PM [cluster-test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - shardmanager-config42: In findPrimary: org.opendaylight.controller.cluster.datastore.messages.RemoteFindPrimary [shardName=astronauts, waitUntilReady=true] 01:52:06,785 PM [cluster-test-akka.actor.default-dispatcher-5] [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] 01:52:06,788 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 01:52:06,794 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 01:52:06,794 PM [cluster-test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shardmanager-config42: Leader shard successfully added the replica shard astronauts 01:52:06,794 PM [cluster-test-akka.actor.default-dispatcher-10] [DEBUG] ShardInformation - Sending new DatastoreContext to member-1-shard-astronauts-config42 01:52:06,794 PM [cluster-test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shardmanager-config42: persisting the shard list [default, astronauts] 01:52:06,795 PM [cluster-test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shardmanager-config42 saved ShardManager snapshot successfully. Deleting the prev snapshot if available 01:52:06,795 PM [cluster-test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shardmanager-config42: Successfully deleted prior snapshots 01:52:06,833 PM [main] [INFO] ShardManagerTest - testAddShardReplica ending 01:52:06,868 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] ShardManager - shardmanager-config42: Received MemberUp: memberName: MemberName{name=member-2}, address: akka://cluster-test@127.0.0.1:2559 01:52:06,868 PM [cluster-test-akka.actor.default-dispatcher-5] [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 01:52:06,868 PM [cluster-test-akka.actor.default-dispatcher-5] [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 01:52:06,868 PM [cluster-test-akka.actor.default-dispatcher-5] [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 01:52:06,868 PM [cluster-test-akka.actor.default-dispatcher-5] [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 01:52:06,936 PM [cluster-test-akka.actor.default-dispatcher-10] [INFO] ShardManager - Stopping ShardManager shardmanager-config42 01:52:06,937 PM [cluster-test-akka.actor.default-dispatcher-11] [INFO] RemoteActorRefProvider$RemotingTerminator - Shutting down remote daemon. 01:52:06,938 PM [cluster-test-akka.actor.default-dispatcher-11] [INFO] RemoteActorRefProvider$RemotingTerminator - Remote daemon shut down; proceeding with flushing remote transports. 01:52:06,959 PM [cluster-test-akka.actor.default-dispatcher-11] [WARN] Materializer - [outbound connection to [akka://cluster-test@127.0.0.1:2559], message stream] Upstream failed, cause: StreamTcpException: The connection has been aborted 01:52:06,959 PM [cluster-test-akka.actor.default-dispatcher-11] [WARN] Materializer - [outbound connection to [akka://cluster-test@127.0.0.1:2559], control stream] Upstream failed, cause: StreamTcpException: The connection has been aborted 01:52:07,0 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] ShardManager - Stopping ShardManager shardmanager-config42 01:52:07,2 PM [cluster-test-akka.actor.default-dispatcher-12] [INFO] RemoteActorRefProvider$RemotingTerminator - Shutting down remote daemon. 01:52:07,2 PM [cluster-test-akka.actor.default-dispatcher-12] [INFO] RemoteActorRefProvider$RemotingTerminator - Remote daemon shut down; proceeding with flushing remote transports. 01:52:08,21 PM [cluster-test-akka.actor.default-dispatcher-12] [INFO] RemoteActorRefProvider$RemotingTerminator - Remoting shut down. [WARN] [04/29/2024 13:52:08.023] [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 01:52:08,57 PM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Starting ShardManager shard-manager-config43 01:52:08,59 PM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - Recovery complete : shard-manager-config43 01:52:08,59 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config43: Creating local shard: member-1-shard-default-config43 01:52:08,60 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1 01:52:08,60 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - Creating Shard member-1-shard-default-config43 01:52:08,60 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config43: Initializing shard [default] 01:52:08,60 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardInformation - Shard member-1-shard-default-config43 is initialized 01:52:08,60 PM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - shard-manager-config43: Received LeaderStateChanged message: LeaderStateChanged [memberId=member-1-shard-default-config43, leaderId=member-1-shard-default-config43, leaderPayloadVersion=13] 01:52:08,60 PM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - shard-manager-config43: Received role changed for member-1-shard-default-config43 from Candidate to Leader 01:52:08,60 PM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - shard-manager-config43: All Shards are ready - data store config43 is ready 01:52:08,60 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config43: onRemoveShardReplica: RemoveShardReplica [shardName=default, memberName=MemberName{name=member-1}] 01:52:08,60 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config43: In findPrimary: org.opendaylight.controller.cluster.datastore.messages.FindPrimary [shardName=default, waitUntilReady=true] 01:52:08,60 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config43: Found primary for default: LocalPrimaryShardFound [primaryPath=akka://test@127.0.0.1:2565/user/member-1-shard-default-config43#816233551, localShardDataTree=org.opendaylight.yangtools.yang.data.tree.api.DataTree$MockitoMock$Kbwo7KiD@19fd0299] 01:52:08,61 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#816233551 for shard member-1-shard-default-config43 01:52:08,61 PM [test-akka.actor.default-dispatcher-6] [DEBUG] ShardManager - shard-manager-config43: Received RemoveServerReply{status=OK} for shard default 01:52:08,61 PM [test-akka.actor.default-dispatcher-6] [DEBUG] ShardManager - shard-manager-config43: Leader shard successfully removed the replica shard default 01:52:08,208 PM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/member-1-shard-default-config43#816233551] 01:52:08,222 PM [main] [INFO] ShardManagerTest - testOnReceiveFindPrimaryWaitForReadyWithIsolatedLeaderShard starting 01:52:08,227 PM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - Starting ShardManager shard-manager-config44 01:52:08,228 PM [test-akka.actor.default-dispatcher-6] [INFO] ShardManager - Recovery complete : shard-manager-config44 01:52:08,229 PM [test-akka.actor.default-dispatcher-6] [DEBUG] ShardManager - shard-manager-config44: Creating local shard: member-1-shard-default-config44 01:52:08,238 PM [test-akka.actor.default-dispatcher-6] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1 01:52:08,238 PM [test-akka.actor.default-dispatcher-6] [DEBUG] ShardManager - Creating Shard member-1-shard-default-config44 01:52:08,238 PM [test-akka.actor.default-dispatcher-6] [DEBUG] ShardManager - shard-manager-config44: Initializing shard [default] 01:52:08,238 PM [test-akka.actor.default-dispatcher-6] [DEBUG] ShardInformation - Shard member-1-shard-default-config44 is initialized 01:52:08,238 PM [test-akka.actor.default-dispatcher-6] [INFO] ShardManager - shard-manager-config44: Received role changed for member-1-shard-default-config44 from null to IsolatedLeader 01:52:08,238 PM [test-akka.actor.default-dispatcher-6] [DEBUG] ShardManager - shard-manager-config44: In findPrimary: org.opendaylight.controller.cluster.datastore.messages.FindPrimary [shardName=default, waitUntilReady=true] 01:52:08,238 PM [test-akka.actor.default-dispatcher-6] [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] 01:52:09,454 PM [test-akka.actor.default-dispatcher-6] [DEBUG] ShardManager - shard-manager-config44: Received ShardNotInitializedTimeout message for shard default 01:52:09,454 PM [test-akka.actor.default-dispatcher-6] [DEBUG] ShardManager - shard-manager-config44: Returning NoShardLeaderException for shard default 01:52:09,455 PM [main] [INFO] ShardManagerTest - testOnReceiveFindPrimaryWaitForReadyWithIsolatedLeaderShard ending 01:52:09,556 PM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/$y#-1666328957] 01:52:09,567 PM [test-akka.actor.default-dispatcher-6] [INFO] ShardManager - Stopping ShardManager shard-manager-config44 01:52:09,574 PM [test-akka.actor.default-dispatcher-6] [INFO] ShardManager - Starting ShardManager shard-manager-config45 01:52:09,578 PM [test-akka.actor.default-dispatcher-6] [INFO] ShardManager - Recovery complete : shard-manager-config45 01:52:09,578 PM [test-akka.actor.default-dispatcher-6] [DEBUG] ShardManager - shard-manager-config45: Creating local shard: member-1-shard-default-config45 01:52:09,585 PM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1 01:52:09,585 PM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - Creating Shard member-1-shard-default-config45 01:52:09,585 PM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - shard-manager-config45: findLocalShard : non-existent 01:52:09,585 PM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - shard-manager-config45: Local shard non-existent not found - shards present: [default] 01:52:09,686 PM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/$z#839895332] 01:52:09,697 PM [test-akka.actor.default-dispatcher-14] [INFO] ShardManager - Stopping ShardManager shard-manager-config45 01:52:09,702 PM [test-akka.actor.default-dispatcher-14] [INFO] ShardManager - Starting ShardManager shard-manager-config46 01:52:09,704 PM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - Recovery complete : shard-manager-config46 01:52:09,722 PM [test-akka.actor.default-dispatcher-6] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1 01:52:09,722 PM [test-akka.actor.default-dispatcher-6] [DEBUG] ShardManager - shard-manager-config46: onRemoveShardReplica: RemoveShardReplica [shardName=astronauts, memberName=MemberName{name=member-2}] 01:52:09,723 PM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - shard-manager-config46: Sending RemoveServer message to peer akka://test@127.0.0.1:2565/system/testProbe-86#-1718479537 for shard member-2-shard-astronauts-config46 01:52:09,735 PM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - shard-manager-config46: onRemoveShardReplica: RemoveShardReplica [shardName=astronauts, memberName=MemberName{name=member-3}] 01:52:09,735 PM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - shard-manager-config46: A shard replica operation for astronauts is already in progress 01:52:09,843 PM [test-akka.actor.default-dispatcher-14] [INFO] ShardManager - Starting ShardManager shard-manager-config47 01:52:09,844 PM [test-akka.actor.default-dispatcher-14] [INFO] ShardManager - Recovery complete : shard-manager-config47 01:52:09,844 PM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - shard-manager-config47: Creating local shard: member-1-shard-default-config47 01:52:09,858 PM [test-akka.actor.default-dispatcher-6] [DEBUG] ShardManager - shard-manager-config47: In findPrimary: org.opendaylight.controller.cluster.datastore.messages.FindPrimary [shardName=default, waitUntilReady=false] 01:52:09,858 PM [test-akka.actor.default-dispatcher-6] [DEBUG] ShardManager - shard-manager-config47: Returning NotInitializedException for shard default 01:52:09,959 PM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/$A#1106676868] 01:52:09,970 PM [test-akka.actor.default-dispatcher-6] [INFO] ShardManager - Stopping ShardManager shard-manager-config47 01:52:09,973 PM [main] [INFO] ShardManagerTest - testServerRemovedShardActorRunning starting 01:52:09,979 PM [test-akka.actor.default-dispatcher-6] [INFO] ShardManager - Starting ShardManager shard-manager-config48 01:52:09,981 PM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - Recovery complete : shard-manager-config48 01:52:09,981 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config48: Creating local shard: member-1-shard-default-config48 01:52:09,981 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config48: Creating local shard: member-1-shard-people-config48 01:52:09,992 PM [test-akka.actor.default-dispatcher-6] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1 01:52:09,992 PM [test-akka.actor.default-dispatcher-6] [DEBUG] ShardManager - Creating Shard member-1-shard-default-config48 01:52:09,992 PM [test-akka.actor.default-dispatcher-6] [DEBUG] ShardManager - Creating Shard member-1-shard-people-config48 01:52:09,995 PM [test-akka.actor.default-dispatcher-6] [DEBUG] ShardManager - shard-manager-config48: Initializing shard [default] 01:52:09,995 PM [test-akka.actor.default-dispatcher-6] [DEBUG] ShardInformation - Shard member-1-shard-default-config48 is initialized 01:52:09,995 PM [test-akka.actor.default-dispatcher-6] [DEBUG] ShardManager - shard-manager-config48: findLocalShard : people 01:52:09,995 PM [test-akka.actor.default-dispatcher-6] [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] 01:52:09,997 PM [test-shard-dispatcher-18] [INFO] Shard - Shard created : member-1-shard-people-config48, persistent : true 01:52:10,2 PM [test-shard-dispatcher-18] [INFO] Shard - Starting recovery for member-1-shard-people-config48 with journal batch size 1 01:52:10,2 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#-1183510122] 01:52:10,3 PM [test-akka.actor.default-dispatcher-6] [INFO] RoleChangeNotifier - RoleChangeNotifier:akka://test@127.0.0.1:2565/user/$$j/member-1-shard-people-config48/member-1-shard-people-config48-notifier#325875923 created and ready for shard:member-1-shard-people-config48 01:52:10,4 PM [test-shard-dispatcher-18] [DEBUG] Shard - member-1-shard-people-config48: onReceiveRecover: Received message class akka.persistence.RecoveryCompleted$ from Actor[akka://test/deadLetters] 01:52:10,4 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 01:52:10,4 PM [test-shard-dispatcher-18] [DEBUG] DataTreeChangeListenerSupport - member-1-shard-people-config48: onLeadershipChange, isLeader: false, hasLeader : false 01:52:10,4 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 01:52:10,4 PM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - shard-manager-config48: Initializing shard [people] 01:52:10,4 PM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardInformation - Shard member-1-shard-people-config48 is initialized 01:52:10,4 PM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardInformation - Shard member-1-shard-people-config48 is initialized - notifying 1 OnShardInitialized callbacks 01:52:10,4 PM [test-akka.actor.default-dispatcher-10] [INFO] RoleChangeNotifier - RoleChangeNotifier for member-1-shard-people-config48 , received role change from null to Follower 01:52:10,5 PM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - shard-manager-config48: findLocalShard : default 01:52:10,5 PM [test-akka.actor.default-dispatcher-6] [INFO] RoleChangeNotifier - RoleChangeNotifier for member-1-shard-people-config48 , registered listener akka://test/user/$$j 01:52:10,5 PM [test-akka.actor.default-dispatcher-6] [INFO] ShardManager - shard-manager-config48: Received role changed for member-1-shard-people-config48 from null to Follower 01:52:10,5 PM [test-akka.actor.default-dispatcher-6] [DEBUG] ShardManager - shard-manager-config48 : Sending Shutdown to Shard actor Actor[akka://test/user/member-1-shard-default-config48#-679432280] with 10000 ms timeout 01:52:10,8 PM [test-akka.actor.default-dispatcher-6] [DEBUG] ShardManager - shard-manager-config48 : Local Shard replica for shard default has been removed 01:52:10,8 PM [test-akka.actor.default-dispatcher-6] [DEBUG] ShardManager - shard-manager-config48: persisting the shard list [people] 01:52:10,8 PM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - shard-manager-config48 saved ShardManager snapshot successfully. Deleting the prev snapshot if available 01:52:10,8 PM [main] [INFO] ShardManagerTest - testServerRemovedShardActorRunning ending 01:52:10,9 PM [test-akka.actor.default-dispatcher-6] [DEBUG] ShardManager - shard-manager-config48: Successfully deleted prior snapshots 01:52:10,110 PM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/member-1-shard-default-config48#-679432280] 01:52:10,121 PM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - shard-manager-config48 : Successfully shut down Shard actor Actor[akka://test/user/member-1-shard-default-config48#-679432280] 01:52:10,121 PM [main] [INFO] TestActorFactory - Killing actor TestActor[akka://test/user/$$j] 01:52:10,122 PM [test-shard-dispatcher-18] [INFO] Shard - Stopping Shard member-1-shard-people-config48 01:52:10,122 PM [test-shard-dispatcher-18] [DEBUG] MessageAssembler - member-1-shard-people-config48 (Follower): Closing 01:52:10,122 PM [test-shard-dispatcher-18] [DEBUG] Shard - member-1-shard-people-config48: Aborting 0 pending queued transactions 01:52:10,123 PM [test-akka.actor.default-dispatcher-14] [INFO] ShardManager - Stopping ShardManager shard-manager-config48 01:52:10,129 PM [main] [INFO] ShardManager - Starting ShardManager shard-manager-config49 01:52:10,130 PM [test-akka.actor.default-dispatcher-14] [INFO] ShardManager - Recovery complete : shard-manager-config49 01:52:10,130 PM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - shard-manager-config49: Creating local shard: member-1-shard-default-config49 01:52:10,131 PM [main] [INFO] ShardManager - shard-manager-config49: Received role changed for member-1-shard-default-config49 from null to Follower 01:52:10,131 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] 01:52:10,142 PM [main] [INFO] ShardManager - shard-manager-config49: Received MemberUp: memberName: MemberName{name=member-2}, address: akka://test 01:52:10,142 PM [main] [INFO] ShardInformation - updatePeerAddress for peer member-2-shard-default-config49 with address akka://test/user/shardmanager-config49/member-2-shard-default-config49 01:52:10,142 PM [main] [INFO] ShardManager - shard-manager-config49: All Shards are ready - data store config49 is ready 01:52:10,243 PM [main] [INFO] TestActorFactory - Killing actor TestActor[akka://test/user/$$k] 01:52:10,254 PM [main] [INFO] ShardManager - Stopping ShardManager shard-manager-config49 01:52:10,257 PM [main] [INFO] ShardManagerTest - testRestoreFromSnapshot starting 01:52:10,261 PM [test-akka.actor.default-dispatcher-14] [INFO] ShardManager - Starting ShardManager shard-manager-config50 01:52:10,263 PM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - Recovery complete : shard-manager-config50 01:52:10,263 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config50: Restoring from ShardManagerSnapshot: ShardManagerSnapshot [ShardList = [shard1, shard2, astronauts] ] 01:52:10,263 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config50: onSnapshotOffer: ShardManagerSnapshot [ShardList = [shard1, shard2, astronauts] ] 01:52:10,263 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config50: adding shard shard1 01:52:10,263 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config50: adding shard shard2 01:52:10,264 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config50: adding shard astronauts 01:52:10,264 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config50: Creating local shard: member-1-shard-shard2-config50 01:52:10,264 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config50: Creating local shard: member-1-shard-astronauts-config50 01:52:10,264 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config50: Creating local shard: member-1-shard-shard1-config50 01:52:10,265 PM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1 01:52:10,265 PM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - Creating Shard member-1-shard-shard2-config50 01:52:10,266 PM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - Creating Shard member-1-shard-astronauts-config50 01:52:10,267 PM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - Creating Shard member-1-shard-shard1-config50 01:52:10,268 PM [test-shard-dispatcher-18] [INFO] Shard - Shard created : member-1-shard-shard2-config50, persistent : true 01:52:10,269 PM [test-shard-dispatcher-18] [INFO] Shard - Starting recovery for member-1-shard-shard2-config50 with journal batch size 1 01:52:10,269 PM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardSnapshotActor - Actor created Actor[akka://test/user/$$l/member-1-shard-shard2-config50/shard-member-1:snapshot-read#178378037] 01:52:10,269 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#124752725 created and ready for shard:member-1-shard-shard2-config50 01:52:10,270 PM [test-shard-dispatcher-18] [INFO] Shard - Shard created : member-1-shard-astronauts-config50, persistent : true 01:52:10,270 PM [test-akka.actor.default-dispatcher-11] [INFO] RoleChangeNotifier - RoleChangeNotifier:akka://test@127.0.0.1:2565/user/$$l/member-1-shard-astronauts-config50/member-1-shard-astronauts-config50-notifier#-1806830513 created and ready for shard:member-1-shard-astronauts-config50 01:52:10,270 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardSnapshotActor - Actor created Actor[akka://test/user/$$l/member-1-shard-astronauts-config50/shard-member-1:snapshot-read#380499690] 01:52:10,270 PM [test-shard-dispatcher-18] [INFO] Shard - Starting recovery for member-1-shard-astronauts-config50 with journal batch size 1 01:52:10,271 PM [test-shard-dispatcher-18] [INFO] Shard - Shard created : member-1-shard-shard1-config50, persistent : true 01:52:10,271 PM [test-shard-dispatcher-18] [INFO] Shard - Starting recovery for member-1-shard-shard1-config50 with journal batch size 1 01:52:10,272 PM [test-akka.actor.default-dispatcher-10] [INFO] RoleChangeNotifier - RoleChangeNotifier:akka://test@127.0.0.1:2565/user/$$l/member-1-shard-shard1-config50/member-1-shard-shard1-config50-notifier#2140730643 created and ready for shard:member-1-shard-shard1-config50 01:52:10,272 PM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardSnapshotActor - Actor created Actor[akka://test/user/$$l/member-1-shard-shard1-config50/shard-member-1:snapshot-read#350847334] 01:52:10,272 PM [test-shard-dispatcher-19] [DEBUG] Shard - member-1-shard-shard2-config50: onReceiveRecover: Received message class akka.persistence.RecoveryCompleted$ from Actor[akka://test/deadLetters] 01:52:10,272 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 01:52:10,272 PM [test-shard-dispatcher-19] [DEBUG] DataTreeChangeListenerSupport - member-1-shard-shard2-config50: onLeadershipChange, isLeader: false, hasLeader : false 01:52:10,272 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 01:52:10,272 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config50: Initializing shard [shard2] 01:52:10,272 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardInformation - Shard member-1-shard-shard2-config50 is initialized 01:52:10,272 PM [test-akka.actor.default-dispatcher-10] [INFO] RoleChangeNotifier - RoleChangeNotifier for member-1-shard-shard2-config50 , received role change from null to Follower 01:52:10,273 PM [test-shard-dispatcher-19] [DEBUG] Shard - member-1-shard-shard2-config50 (Follower): Received TimeoutNow - switching to Candidate 01:52:10,273 PM [test-shard-dispatcher-20] [DEBUG] Shard - member-1-shard-astronauts-config50: onReceiveRecover: Received message class akka.persistence.RecoveryCompleted$ from Actor[akka://test/deadLetters] 01:52:10,273 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 01:52:10,274 PM [test-shard-dispatcher-20] [DEBUG] DataTreeChangeListenerSupport - member-1-shard-astronauts-config50: onLeadershipChange, isLeader: false, hasLeader : false 01:52:10,274 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 01:52:10,274 PM [test-shard-dispatcher-20] [DEBUG] Shard - member-1-shard-astronauts-config50 (Follower): Received TimeoutNow - switching to Candidate 01:52:10,274 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config50: Initializing shard [astronauts] 01:52:10,274 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardInformation - Shard member-1-shard-astronauts-config50 is initialized 01:52:10,274 PM [test-akka.actor.default-dispatcher-11] [INFO] RoleChangeNotifier - RoleChangeNotifier for member-1-shard-astronauts-config50 , received role change from null to Follower 01:52:10,275 PM [test-shard-dispatcher-21] [DEBUG] Shard - member-1-shard-shard1-config50: onReceiveRecover: Received message class akka.persistence.RecoveryCompleted$ from Actor[akka://test/deadLetters] 01:52:10,275 PM [test-shard-dispatcher-21] [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 01:52:10,275 PM [test-shard-dispatcher-21] [DEBUG] DataTreeChangeListenerSupport - member-1-shard-shard1-config50: onLeadershipChange, isLeader: false, hasLeader : false 01:52:10,275 PM [test-shard-dispatcher-21] [DEBUG] Shard - member-1-shard-shard1-config50: onStateChanged: Closing all transaction chains because shard member-1-shard-shard1-config50 is no longer the leader 01:52:10,275 PM [test-shard-dispatcher-21] [DEBUG] Shard - member-1-shard-shard1-config50 (Follower): Received TimeoutNow - switching to Candidate 01:52:10,276 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config50: Initializing shard [shard1] 01:52:10,276 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardInformation - Shard member-1-shard-shard1-config50 is initialized 01:52:10,276 PM [test-akka.actor.default-dispatcher-10] [INFO] RoleChangeNotifier - RoleChangeNotifier for member-1-shard-shard1-config50 , received role change from null to Follower 01:52:10,276 PM [test-shard-dispatcher-19] [DEBUG] Shard - member-1-shard-shard2-config50 (Candidate): Election: Candidate has following voting peers: [] 01:52:10,276 PM [test-shard-dispatcher-19] [DEBUG] Shard - member-1-shard-shard2-config50: Set currentTerm=1, votedFor=member-1-shard-shard2-config50 01:52:10,276 PM [test-shard-dispatcher-20] [DEBUG] Shard - member-1-shard-astronauts-config50 (Candidate): Election: Candidate has following voting peers: [] 01:52:10,276 PM [test-shard-dispatcher-20] [DEBUG] Shard - member-1-shard-astronauts-config50: Set currentTerm=1, votedFor=member-1-shard-astronauts-config50 01:52:10,277 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config50: findLocalShard : shard1 01:52:10,277 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config50: findLocalShard : shard2 01:52:10,277 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config50: findLocalShard : astronauts 01:52:10,277 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config50: onGetSnapshot 01:52:10,278 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManagerGetSnapshotReplyActor - shard-manager-config50: Expecting 3 shard snapshot replies 01:52:10,278 PM [test-shard-dispatcher-21] [DEBUG] Shard - member-1-shard-shard1-config50 (Candidate): Election: Candidate has following voting peers: [] 01:52:10,278 PM [test-shard-dispatcher-21] [DEBUG] Shard - member-1-shard-shard1-config50: Set currentTerm=1, votedFor=member-1-shard-shard1-config50 01:52:10,279 PM [test-shard-dispatcher-19] [INFO] Shard - member-1-shard-shard2-config50 (Candidate): Starting new election term 1 01:52:10,279 PM [test-shard-dispatcher-21] [INFO] Shard - member-1-shard-shard1-config50 (Candidate): Starting new election term 1 01:52:10,279 PM [test-shard-dispatcher-19] [INFO] Shard - member-1-shard-shard2-config50 (Follower) :- Switching from behavior Follower to Candidate, election term: 1 01:52:10,279 PM [test-shard-dispatcher-21] [INFO] Shard - member-1-shard-shard1-config50 (Follower) :- Switching from behavior Follower to Candidate, election term: 1 01:52:10,279 PM [test-shard-dispatcher-19] [DEBUG] MessageAssembler - member-1-shard-shard2-config50 (Follower): Closing 01:52:10,279 PM [test-shard-dispatcher-21] [DEBUG] MessageAssembler - member-1-shard-shard1-config50 (Follower): Closing 01:52:10,279 PM [test-shard-dispatcher-21] [DEBUG] DataTreeChangeListenerSupport - member-1-shard-shard1-config50: onLeadershipChange, isLeader: false, hasLeader : false 01:52:10,279 PM [test-shard-dispatcher-19] [DEBUG] DataTreeChangeListenerSupport - member-1-shard-shard2-config50: onLeadershipChange, isLeader: false, hasLeader : false 01:52:10,279 PM [test-shard-dispatcher-21] [DEBUG] Shard - member-1-shard-shard1-config50: onStateChanged: Closing all transaction chains because shard member-1-shard-shard1-config50 is no longer the leader 01:52:10,279 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 01:52:10,280 PM [test-akka.actor.default-dispatcher-10] [INFO] RoleChangeNotifier - RoleChangeNotifier for member-1-shard-shard1-config50 , received role change from Follower to Candidate 01:52:10,280 PM [test-akka.actor.default-dispatcher-10] [INFO] RoleChangeNotifier - RoleChangeNotifier for member-1-shard-shard2-config50 , received role change from Follower to Candidate 01:52:10,280 PM [test-shard-dispatcher-20] [INFO] Shard - member-1-shard-astronauts-config50 (Candidate): Starting new election term 1 01:52:10,280 PM [test-shard-dispatcher-20] [INFO] Shard - member-1-shard-astronauts-config50 (Follower) :- Switching from behavior Follower to Candidate, election term: 1 01:52:10,280 PM [test-shard-dispatcher-20] [DEBUG] MessageAssembler - member-1-shard-astronauts-config50 (Follower): Closing 01:52:10,280 PM [test-shard-dispatcher-20] [DEBUG] DataTreeChangeListenerSupport - member-1-shard-astronauts-config50: onLeadershipChange, isLeader: false, hasLeader : false 01:52:10,280 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 01:52:10,283 PM [test-akka.actor.default-dispatcher-6] [INFO] RoleChangeNotifier - RoleChangeNotifier for member-1-shard-astronauts-config50 , received role change from Follower to Candidate 01:52:10,295 PM [test-shard-dispatcher-21] [DEBUG] Shard - member-1-shard-shard2-config50 (Candidate): Received ElectionTimeout 01:52:10,296 PM [test-shard-dispatcher-20] [DEBUG] Shard - member-1-shard-astronauts-config50 (Candidate): Received ElectionTimeout 01:52:10,296 PM [test-shard-dispatcher-19] [DEBUG] Shard - member-1-shard-shard1-config50 (Candidate): Received ElectionTimeout 01:52:10,302 PM [test-shard-dispatcher-21] [DEBUG] Shard - member-1-shard-shard2-config50 (Leader): Election: Leader has following peers: [] 01:52:10,302 PM [test-shard-dispatcher-19] [DEBUG] Shard - member-1-shard-shard1-config50 (Leader): Election: Leader has following peers: [] 01:52:10,302 PM [test-shard-dispatcher-20] [DEBUG] Shard - member-1-shard-astronauts-config50 (Leader): Election: Leader has following peers: [] 01:52:10,302 PM [test-shard-dispatcher-21] [INFO] Shard - member-1-shard-shard2-config50 (Candidate) :- Switching from behavior Candidate to Leader, election term: 1 01:52:10,302 PM [test-shard-dispatcher-19] [INFO] Shard - member-1-shard-shard1-config50 (Candidate) :- Switching from behavior Candidate to Leader, election term: 1 01:52:10,302 PM [test-shard-dispatcher-20] [INFO] Shard - member-1-shard-astronauts-config50 (Candidate) :- Switching from behavior Candidate to Leader, election term: 1 01:52:10,302 PM [test-shard-dispatcher-21] [DEBUG] DataTreeChangeListenerSupport - member-1-shard-shard2-config50: onLeadershipChange, isLeader: true, hasLeader : true 01:52:10,302 PM [test-shard-dispatcher-19] [DEBUG] DataTreeChangeListenerSupport - member-1-shard-shard1-config50: onLeadershipChange, isLeader: true, hasLeader : true 01:52:10,302 PM [test-shard-dispatcher-20] [DEBUG] DataTreeChangeListenerSupport - member-1-shard-astronauts-config50: onLeadershipChange, isLeader: true, hasLeader : true 01:52:10,303 PM [test-shard-dispatcher-21] [DEBUG] Shard - member-1-shard-shard2-config50: became leader with frontend state for [] 01:52:10,303 PM [test-shard-dispatcher-19] [DEBUG] Shard - member-1-shard-shard1-config50: became leader with frontend state for [] 01:52:10,304 PM [test-akka.actor.default-dispatcher-6] [INFO] RoleChangeNotifier - RoleChangeNotifier for member-1-shard-shard1-config50 , received role change from Candidate to Leader 01:52:10,304 PM [test-akka.actor.default-dispatcher-6] [INFO] RoleChangeNotifier - RoleChangeNotifier for member-1-shard-shard2-config50 , received role change from Candidate to Leader 01:52:10,307 PM [test-shard-dispatcher-20] [DEBUG] Shard - member-1-shard-astronauts-config50: became leader with frontend state for [] 01:52:10,308 PM [test-shard-dispatcher-21] [DEBUG] Shard - member-1-shard-shard2-config50: onGetSnapshot 01:52:10,308 PM [test-shard-dispatcher-20] [DEBUG] Shard - member-1-shard-astronauts-config50: onGetSnapshot 01:52:10,308 PM [test-shard-dispatcher-21] [DEBUG] Shard - member-1-shard-shard2-config50: Capturing Snapshot : lastLogEntry is null. Using snapshot values lastAppliedIndex -1 and lastAppliedTerm -1 instead. 01:52:10,308 PM [test-shard-dispatcher-20] [DEBUG] Shard - member-1-shard-astronauts-config50: Capturing Snapshot : lastLogEntry is null. Using snapshot values lastAppliedIndex -1 and lastAppliedTerm -1 instead. 01:52:10,311 PM [test-akka.actor.default-dispatcher-10] [INFO] RoleChangeNotifier - RoleChangeNotifier for member-1-shard-shard2-config50 , registered listener akka://test/user/$$l 01:52:10,311 PM [test-akka.actor.default-dispatcher-16] [INFO] RoleChangeNotifier - RoleChangeNotifier for member-1-shard-astronauts-config50 , received role change from Candidate to Leader 01:52:10,311 PM [test-akka.actor.default-dispatcher-16] [INFO] RoleChangeNotifier - RoleChangeNotifier for member-1-shard-astronauts-config50 , registered listener akka://test/user/$$l 01:52:10,311 PM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - shard-manager-config50: Received LeaderStateChanged message: LeaderStateChanged [memberId=member-1-shard-shard2-config50, leaderId=member-1-shard-shard2-config50, leaderPayloadVersion=13] 01:52:10,311 PM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - shard-manager-config50: Received role changed for member-1-shard-shard2-config50 from Candidate to Leader 01:52:10,311 PM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - shard-manager-config50: Received LeaderStateChanged message: LeaderStateChanged [memberId=member-1-shard-astronauts-config50, leaderId=member-1-shard-astronauts-config50, leaderPayloadVersion=13] 01:52:10,312 PM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - shard-manager-config50: Received role changed for member-1-shard-astronauts-config50 from Candidate to Leader 01:52:10,312 PM [test-shard-dispatcher-19] [DEBUG] Shard - member-1-shard-shard1-config50: onGetSnapshot 01:52:10,312 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. 01:52:10,312 PM [test-akka.actor.default-dispatcher-14] [INFO] RoleChangeNotifier - RoleChangeNotifier for member-1-shard-shard1-config50 , registered listener akka://test/user/$$l 01:52:10,312 PM [test-akka.actor.default-dispatcher-14] [INFO] ShardManager - shard-manager-config50: Received LeaderStateChanged message: LeaderStateChanged [memberId=member-1-shard-shard1-config50, leaderId=member-1-shard-shard1-config50, leaderPayloadVersion=13] 01:52:10,312 PM [test-akka.actor.default-dispatcher-14] [INFO] ShardManager - shard-manager-config50: Received role changed for member-1-shard-shard1-config50 from Candidate to Leader 01:52:10,312 PM [test-akka.actor.default-dispatcher-14] [INFO] ShardManager - shard-manager-config50: All Shards are ready - data store config50 is ready 01:52:10,313 PM [test-shard-dispatcher-21] [DEBUG] Shard - member-1-shard-shard2-config50: requesting serialization of snapshot MetadataShardDataTreeSnapshot{metadata={class org.opendaylight.controller.cluster.datastore.persisted.FrontendShardDataTreeSnapshotMetadata=FrontendShardDataTreeSnapshotMetadata{clients=[]}}} 01:52:10,313 PM [test-shard-dispatcher-20] [DEBUG] Shard - member-1-shard-astronauts-config50: requesting serialization of snapshot MetadataShardDataTreeSnapshot{metadata={class org.opendaylight.controller.cluster.datastore.persisted.FrontendShardDataTreeSnapshotMetadata=FrontendShardDataTreeSnapshotMetadata{clients=[]}}} 01:52:10,313 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=[]}}} 01:52:10,314 PM [test-akka.actor.default-dispatcher-16] [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@3788dea, electionTerm=1, electionVotedFor=member-1-shard-astronauts-config50, ServerConfigPayload=null]] 01:52:10,314 PM [test-akka.actor.default-dispatcher-16] [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@764a6177, electionTerm=1, electionVotedFor=member-1-shard-shard2-config50, ServerConfigPayload=null]] 01:52:10,316 PM [test-akka.actor.default-dispatcher-10] [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@1f0a61b, electionTerm=1, electionVotedFor=member-1-shard-shard1-config50, ServerConfigPayload=null]] 01:52:10,316 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManagerGetSnapshotReplyActor - shard-manager-config50: All shard snapshots received 01:52:10,317 PM [main] [INFO] ShardManagerTest - testRestoreFromSnapshot ending 01:52:10,418 PM [main] [INFO] TestActorFactory - Killing actor TestActor[akka://test/user/$$l] 01:52:10,429 PM [test-shard-dispatcher-19] [INFO] Shard - Stopping Shard member-1-shard-shard1-config50 01:52:10,429 PM [test-shard-dispatcher-19] [DEBUG] MessageSlicer - member-1-shard-shard1-config50 (Leader)_slicer-id-7: Closing 01:52:10,429 PM [test-shard-dispatcher-22] [INFO] Shard - Stopping Shard member-1-shard-astronauts-config50 01:52:10,429 PM [test-shard-dispatcher-20] [INFO] Shard - Stopping Shard member-1-shard-shard2-config50 01:52:10,429 PM [test-shard-dispatcher-22] [DEBUG] MessageSlicer - member-1-shard-astronauts-config50 (Leader)_slicer-id-8: Closing 01:52:10,429 PM [test-shard-dispatcher-20] [DEBUG] MessageSlicer - member-1-shard-shard2-config50 (Leader)_slicer-id-6: Closing 01:52:10,430 PM [test-shard-dispatcher-19] [DEBUG] Shard - member-1-shard-shard1-config50: Aborting 0 pending queued transactions 01:52:10,430 PM [test-shard-dispatcher-22] [DEBUG] Shard - member-1-shard-astronauts-config50: Aborting 0 pending queued transactions 01:52:10,430 PM [test-shard-dispatcher-20] [DEBUG] Shard - member-1-shard-shard2-config50: Aborting 0 pending queued transactions 01:52:10,431 PM [test-akka.actor.default-dispatcher-16] [INFO] ShardManager - Stopping ShardManager shard-manager-config50 01:52:10,434 PM [main] [INFO] ShardManagerTest - testOnCreateShardWithNoInitialSchemaContext starting 01:52:10,438 PM [test-akka.actor.default-dispatcher-16] [INFO] ShardManager - Starting ShardManager shard-manager-config51 01:52:10,440 PM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - Recovery complete : shard-manager-config51 01:52:10,449 PM [test-akka.actor.default-dispatcher-16] [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@28905531] 01:52:10,450 PM [test-akka.actor.default-dispatcher-16] [DEBUG] ShardManager - shard-manager-config51 doCreateShard: shardId: member-1-shard-foo-config51, memberNames: [MemberName{name=member-1}], peerAddresses: {}, isActiveMember: true 01:52:10,450 PM [test-akka.actor.default-dispatcher-16] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1 01:52:10,450 PM [test-akka.actor.default-dispatcher-16] [DEBUG] ShardManager - Creating Shard member-1-shard-foo-config51 01:52:10,451 PM [test-akka.actor.default-dispatcher-16] [DEBUG] ShardManager - shard-manager-config51: findLocalShard : foo 01:52:10,452 PM [test-akka.actor.default-dispatcher-16] [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] 01:52:10,452 PM [test-shard-dispatcher-20] [INFO] Shard - Shard created : member-1-shard-foo-config51, persistent : true 01:52:10,454 PM [test-akka.actor.default-dispatcher-16] [INFO] RoleChangeNotifier - RoleChangeNotifier:akka://test@127.0.0.1:2565/user/$B/member-1-shard-foo-config51/member-1-shard-foo-config51-notifier#277234713 created and ready for shard:member-1-shard-foo-config51 01:52:10,454 PM [test-akka.actor.default-dispatcher-16] [DEBUG] ShardSnapshotActor - Actor created Actor[akka://test/user/$B/member-1-shard-foo-config51/shard-member-1:snapshot-read#-502200280] 01:52:10,454 PM [test-shard-dispatcher-20] [INFO] Shard - Starting recovery for member-1-shard-foo-config51 with journal batch size 1 01:52:10,455 PM [test-shard-dispatcher-20] [DEBUG] Shard - member-1-shard-foo-config51: onReceiveRecover: Received message class akka.persistence.RecoveryCompleted$ from Actor[akka://test/deadLetters] 01:52:10,455 PM [test-shard-dispatcher-20] [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 01:52:10,455 PM [test-akka.actor.default-dispatcher-6] [DEBUG] ShardManager - shard-manager-config51: Initializing shard [foo] 01:52:10,455 PM [test-akka.actor.default-dispatcher-6] [DEBUG] ShardInformation - Shard member-1-shard-foo-config51 is initialized 01:52:10,456 PM [test-shard-dispatcher-20] [DEBUG] DataTreeChangeListenerSupport - member-1-shard-foo-config51: onLeadershipChange, isLeader: false, hasLeader : false 01:52:10,456 PM [test-akka.actor.default-dispatcher-6] [DEBUG] ShardInformation - Shard member-1-shard-foo-config51 is initialized - notifying 1 OnShardInitialized callbacks 01:52:10,456 PM [test-shard-dispatcher-20] [DEBUG] Shard - member-1-shard-foo-config51: onStateChanged: Closing all transaction chains because shard member-1-shard-foo-config51 is no longer the leader 01:52:10,456 PM [test-shard-dispatcher-20] [DEBUG] Shard - member-1-shard-foo-config51 (Follower): Received TimeoutNow - switching to Candidate 01:52:10,456 PM [test-shard-dispatcher-20] [DEBUG] Shard - member-1-shard-foo-config51 (Candidate): Election: Candidate has following voting peers: [] 01:52:10,456 PM [test-shard-dispatcher-20] [DEBUG] Shard - member-1-shard-foo-config51: Set currentTerm=1, votedFor=member-1-shard-foo-config51 01:52:10,456 PM [test-shard-dispatcher-20] [INFO] Shard - member-1-shard-foo-config51 (Candidate): Starting new election term 1 01:52:10,456 PM [test-shard-dispatcher-20] [INFO] Shard - member-1-shard-foo-config51 (Follower) :- Switching from behavior Follower to Candidate, election term: 1 01:52:10,456 PM [test-shard-dispatcher-20] [DEBUG] MessageAssembler - member-1-shard-foo-config51 (Follower): Closing 01:52:10,456 PM [test-shard-dispatcher-20] [DEBUG] DataTreeChangeListenerSupport - member-1-shard-foo-config51: onLeadershipChange, isLeader: false, hasLeader : false 01:52:10,456 PM [test-shard-dispatcher-20] [DEBUG] Shard - member-1-shard-foo-config51: onStateChanged: Closing all transaction chains because shard member-1-shard-foo-config51 is no longer the leader 01:52:10,456 PM [test-akka.actor.default-dispatcher-6] [INFO] RoleChangeNotifier - RoleChangeNotifier for member-1-shard-foo-config51 , received role change from null to Follower 01:52:10,456 PM [test-akka.actor.default-dispatcher-6] [INFO] RoleChangeNotifier - RoleChangeNotifier for member-1-shard-foo-config51 , received role change from Follower to Candidate 01:52:10,457 PM [main] [INFO] ShardManagerTest - testOnCreateShardWithNoInitialSchemaContext ending 01:52:10,461 PM [test-shard-dispatcher-20] [DEBUG] Shard - member-1-shard-foo-config51 (Candidate): Received ElectionTimeout 01:52:10,461 PM [test-shard-dispatcher-20] [DEBUG] Shard - member-1-shard-foo-config51 (Leader): Election: Leader has following peers: [] 01:52:10,462 PM [test-shard-dispatcher-20] [INFO] Shard - member-1-shard-foo-config51 (Candidate) :- Switching from behavior Candidate to Leader, election term: 1 01:52:10,462 PM [test-shard-dispatcher-20] [DEBUG] DataTreeChangeListenerSupport - member-1-shard-foo-config51: onLeadershipChange, isLeader: true, hasLeader : true 01:52:10,462 PM [test-shard-dispatcher-20] [DEBUG] Shard - member-1-shard-foo-config51: became leader with frontend state for [] 01:52:10,462 PM [test-akka.actor.default-dispatcher-6] [INFO] RoleChangeNotifier - RoleChangeNotifier for member-1-shard-foo-config51 , received role change from Candidate to Leader 01:52:10,462 PM [test-akka.actor.default-dispatcher-6] [INFO] RoleChangeNotifier - RoleChangeNotifier for member-1-shard-foo-config51 , registered listener akka://test/user/$B 01:52:10,462 PM [test-akka.actor.default-dispatcher-6] [INFO] ShardManager - shard-manager-config51: Received LeaderStateChanged message: LeaderStateChanged [memberId=member-1-shard-foo-config51, leaderId=member-1-shard-foo-config51, leaderPayloadVersion=13] 01:52:10,462 PM [test-akka.actor.default-dispatcher-6] [INFO] ShardManager - shard-manager-config51: Received role changed for member-1-shard-foo-config51 from Candidate to Leader 01:52:10,462 PM [test-akka.actor.default-dispatcher-6] [INFO] ShardManager - shard-manager-config51: All Shards are ready - data store config51 is ready 01:52:10,558 PM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/$B#-1966037024] 01:52:10,570 PM [test-shard-dispatcher-20] [INFO] Shard - Stopping Shard member-1-shard-foo-config51 01:52:10,570 PM [test-shard-dispatcher-20] [DEBUG] MessageSlicer - member-1-shard-foo-config51 (Leader)_slicer-id-10: Closing 01:52:10,570 PM [test-shard-dispatcher-20] [DEBUG] Shard - member-1-shard-foo-config51: Aborting 0 pending queued transactions 01:52:10,572 PM [test-akka.actor.default-dispatcher-6] [INFO] ShardManager - Stopping ShardManager shard-manager-config51 01:52:10,574 PM [main] [INFO] ShardManagerTest - testGetSnapshot starting 01:52:10,582 PM [test-akka.actor.default-dispatcher-6] [INFO] ShardManager - Starting ShardManager shard-manager-config52 01:52:10,585 PM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Recovery complete : shard-manager-config52 01:52:10,585 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config52: Creating local shard: member-1-shard-shard2-config52 01:52:10,586 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config52: Creating local shard: member-1-shard-shard1-config52 01:52:10,593 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config52: onGetSnapshot 01:52:10,593 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1 01:52:10,593 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - Creating Shard member-1-shard-shard2-config52 01:52:10,594 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - Creating Shard member-1-shard-shard1-config52 01:52:10,595 PM [test-shard-dispatcher-20] [INFO] Shard - Shard created : member-1-shard-shard2-config52, persistent : true 01:52:10,595 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config52: findLocalShard : shard1 01:52:10,595 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-shard1-config52, leaderAvailable=false, actorInitialized=false, followerSyncStatus=false, role=null, leaderId=null, activeMember=true] 01:52:10,596 PM [test-akka.actor.default-dispatcher-11] [INFO] RoleChangeNotifier - RoleChangeNotifier:akka://test@127.0.0.1:2565/user/$$m/member-1-shard-shard2-config52/member-1-shard-shard2-config52-notifier#951702369 created and ready for shard:member-1-shard-shard2-config52 01:52:10,596 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#1675707691] 01:52:10,596 PM [test-shard-dispatcher-20] [INFO] Shard - Starting recovery for member-1-shard-shard2-config52 with journal batch size 1 01:52:10,597 PM [test-shard-dispatcher-20] [INFO] Shard - Shard created : member-1-shard-shard1-config52, persistent : true 01:52:10,598 PM [test-akka.actor.default-dispatcher-16] [INFO] RoleChangeNotifier - RoleChangeNotifier:akka://test@127.0.0.1:2565/user/$$m/member-1-shard-shard1-config52/member-1-shard-shard1-config52-notifier#44068868 created and ready for shard:member-1-shard-shard1-config52 01:52:10,598 PM [test-akka.actor.default-dispatcher-16] [DEBUG] ShardSnapshotActor - Actor created Actor[akka://test/user/$$m/member-1-shard-shard1-config52/shard-member-1:snapshot-read#-1799449279] 01:52:10,599 PM [test-shard-dispatcher-20] [INFO] Shard - Starting recovery for member-1-shard-shard1-config52 with journal batch size 1 01:52:10,599 PM [test-shard-dispatcher-20] [DEBUG] Shard - member-1-shard-shard2-config52: onReceiveRecover: Received message class akka.persistence.RecoveryCompleted$ from Actor[akka://test/deadLetters] 01:52:10,600 PM [test-shard-dispatcher-20] [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 01:52:10,600 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config52: Initializing shard [shard2] 01:52:10,600 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardInformation - Shard member-1-shard-shard2-config52 is initialized 01:52:10,600 PM [test-shard-dispatcher-20] [DEBUG] DataTreeChangeListenerSupport - member-1-shard-shard2-config52: onLeadershipChange, isLeader: false, hasLeader : false 01:52:10,600 PM [test-shard-dispatcher-20] [DEBUG] Shard - member-1-shard-shard2-config52: onStateChanged: Closing all transaction chains because shard member-1-shard-shard2-config52 is no longer the leader 01:52:10,600 PM [test-akka.actor.default-dispatcher-11] [INFO] RoleChangeNotifier - RoleChangeNotifier for member-1-shard-shard2-config52 , received role change from null to Follower 01:52:10,600 PM [test-shard-dispatcher-20] [DEBUG] Shard - member-1-shard-shard2-config52 (Follower): Received TimeoutNow - switching to Candidate 01:52:10,600 PM [test-shard-dispatcher-20] [DEBUG] Shard - member-1-shard-shard2-config52 (Candidate): Election: Candidate has following voting peers: [] 01:52:10,600 PM [test-shard-dispatcher-20] [DEBUG] Shard - member-1-shard-shard2-config52: Set currentTerm=1, votedFor=member-1-shard-shard2-config52 01:52:10,600 PM [test-shard-dispatcher-20] [INFO] Shard - member-1-shard-shard2-config52 (Candidate): Starting new election term 1 01:52:10,600 PM [test-shard-dispatcher-20] [INFO] Shard - member-1-shard-shard2-config52 (Follower) :- Switching from behavior Follower to Candidate, election term: 1 01:52:10,600 PM [test-shard-dispatcher-20] [DEBUG] MessageAssembler - member-1-shard-shard2-config52 (Follower): Closing 01:52:10,600 PM [test-shard-dispatcher-20] [DEBUG] DataTreeChangeListenerSupport - member-1-shard-shard2-config52: onLeadershipChange, isLeader: false, hasLeader : false 01:52:10,600 PM [test-shard-dispatcher-20] [DEBUG] Shard - member-1-shard-shard2-config52: onStateChanged: Closing all transaction chains because shard member-1-shard-shard2-config52 is no longer the leader 01:52:10,600 PM [test-akka.actor.default-dispatcher-11] [INFO] RoleChangeNotifier - RoleChangeNotifier for member-1-shard-shard2-config52 , received role change from Follower to Candidate 01:52:10,601 PM [test-shard-dispatcher-22] [DEBUG] Shard - member-1-shard-shard2-config52 (Candidate): Received ElectionTimeout 01:52:10,601 PM [test-shard-dispatcher-22] [DEBUG] Shard - member-1-shard-shard2-config52 (Leader): Election: Leader has following peers: [] 01:52:10,601 PM [test-shard-dispatcher-22] [INFO] Shard - member-1-shard-shard2-config52 (Candidate) :- Switching from behavior Candidate to Leader, election term: 1 01:52:10,601 PM [test-shard-dispatcher-22] [DEBUG] DataTreeChangeListenerSupport - member-1-shard-shard2-config52: onLeadershipChange, isLeader: true, hasLeader : true 01:52:10,602 PM [test-shard-dispatcher-22] [DEBUG] Shard - member-1-shard-shard2-config52: became leader with frontend state for [] 01:52:10,602 PM [test-akka.actor.default-dispatcher-11] [INFO] RoleChangeNotifier - RoleChangeNotifier for member-1-shard-shard2-config52 , received role change from Candidate to Leader 01:52:10,602 PM [test-akka.actor.default-dispatcher-11] [INFO] RoleChangeNotifier - RoleChangeNotifier for member-1-shard-shard2-config52 , registered listener akka://test/user/$$m 01:52:10,602 PM [test-shard-dispatcher-22] [DEBUG] Shard - member-1-shard-shard1-config52: onReceiveRecover: Received message class akka.persistence.RecoveryCompleted$ from Actor[akka://test/deadLetters] 01:52:10,602 PM [test-shard-dispatcher-22] [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 01:52:10,602 PM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - shard-manager-config52: Received LeaderStateChanged message: LeaderStateChanged [memberId=member-1-shard-shard2-config52, leaderId=member-1-shard-shard2-config52, leaderPayloadVersion=13] 01:52:10,602 PM [test-shard-dispatcher-22] [DEBUG] DataTreeChangeListenerSupport - member-1-shard-shard1-config52: onLeadershipChange, isLeader: false, hasLeader : false 01:52:10,602 PM [test-shard-dispatcher-22] [DEBUG] Shard - member-1-shard-shard1-config52: onStateChanged: Closing all transaction chains because shard member-1-shard-shard1-config52 is no longer the leader 01:52:10,602 PM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - shard-manager-config52: Received role changed for member-1-shard-shard2-config52 from Candidate to Leader 01:52:10,602 PM [test-shard-dispatcher-22] [DEBUG] Shard - member-1-shard-shard1-config52 (Follower): Received TimeoutNow - switching to Candidate 01:52:10,602 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config52: Initializing shard [shard1] 01:52:10,602 PM [test-shard-dispatcher-22] [DEBUG] Shard - member-1-shard-shard1-config52 (Candidate): Election: Candidate has following voting peers: [] 01:52:10,602 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardInformation - Shard member-1-shard-shard1-config52 is initialized 01:52:10,602 PM [test-shard-dispatcher-22] [DEBUG] Shard - member-1-shard-shard1-config52: Set currentTerm=1, votedFor=member-1-shard-shard1-config52 01:52:10,602 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardInformation - Shard member-1-shard-shard1-config52 is initialized - notifying 1 OnShardInitialized callbacks 01:52:10,602 PM [test-shard-dispatcher-22] [INFO] Shard - member-1-shard-shard1-config52 (Candidate): Starting new election term 1 01:52:10,602 PM [test-shard-dispatcher-22] [INFO] Shard - member-1-shard-shard1-config52 (Follower) :- Switching from behavior Follower to Candidate, election term: 1 01:52:10,602 PM [test-akka.actor.default-dispatcher-11] [INFO] RoleChangeNotifier - RoleChangeNotifier for member-1-shard-shard1-config52 , received role change from null to Follower 01:52:10,602 PM [test-shard-dispatcher-22] [DEBUG] MessageAssembler - member-1-shard-shard1-config52 (Follower): Closing 01:52:10,602 PM [test-shard-dispatcher-22] [DEBUG] DataTreeChangeListenerSupport - member-1-shard-shard1-config52: onLeadershipChange, isLeader: false, hasLeader : false 01:52:10,602 PM [test-shard-dispatcher-22] [DEBUG] Shard - member-1-shard-shard1-config52: onStateChanged: Closing all transaction chains because shard member-1-shard-shard1-config52 is no longer the leader 01:52:10,602 PM [test-akka.actor.default-dispatcher-14] [INFO] RoleChangeNotifier - RoleChangeNotifier for member-1-shard-shard1-config52 , received role change from Follower to Candidate 01:52:10,603 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config52: findLocalShard : shard2 01:52:10,603 PM [test-shard-dispatcher-20] [DEBUG] Shard - member-1-shard-shard1-config52 (Candidate): Received ElectionTimeout 01:52:10,603 PM [test-shard-dispatcher-20] [DEBUG] Shard - member-1-shard-shard1-config52 (Leader): Election: Leader has following peers: [] 01:52:10,603 PM [test-shard-dispatcher-20] [INFO] Shard - member-1-shard-shard1-config52 (Candidate) :- Switching from behavior Candidate to Leader, election term: 1 01:52:10,603 PM [test-shard-dispatcher-20] [DEBUG] DataTreeChangeListenerSupport - member-1-shard-shard1-config52: onLeadershipChange, isLeader: true, hasLeader : true 01:52:10,603 PM [test-shard-dispatcher-20] [DEBUG] Shard - member-1-shard-shard1-config52: became leader with frontend state for [] 01:52:10,603 PM [test-akka.actor.default-dispatcher-6] [INFO] RoleChangeNotifier - RoleChangeNotifier for member-1-shard-shard1-config52 , received role change from Candidate to Leader 01:52:10,603 PM [test-akka.actor.default-dispatcher-6] [INFO] RoleChangeNotifier - RoleChangeNotifier for member-1-shard-shard1-config52 , registered listener akka://test/user/$$m 01:52:10,603 PM [test-akka.actor.default-dispatcher-6] [DEBUG] ShardManager - shard-manager-config52: onGetSnapshot 01:52:10,604 PM [test-akka.actor.default-dispatcher-6] [INFO] ShardManager - shard-manager-config52: Received LeaderStateChanged message: LeaderStateChanged [memberId=member-1-shard-shard1-config52, leaderId=member-1-shard-shard1-config52, leaderPayloadVersion=13] 01:52:10,604 PM [test-akka.actor.default-dispatcher-6] [INFO] ShardManager - shard-manager-config52: Received role changed for member-1-shard-shard1-config52 from Candidate to Leader 01:52:10,604 PM [test-akka.actor.default-dispatcher-6] [INFO] ShardManager - shard-manager-config52: All Shards are ready - data store config52 is ready 01:52:10,604 PM [test-shard-dispatcher-20] [DEBUG] Shard - member-1-shard-shard1-config52: onGetSnapshot 01:52:10,604 PM [test-akka.actor.default-dispatcher-6] [DEBUG] ShardManagerGetSnapshotReplyActor - shard-manager-config52: Expecting 2 shard snapshot replies 01:52:10,604 PM [test-shard-dispatcher-19] [DEBUG] Shard - member-1-shard-shard2-config52: onGetSnapshot 01:52:10,604 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. 01:52:10,604 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. 01:52:10,604 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=[]}}} 01:52:10,604 PM [test-akka.actor.default-dispatcher-12] [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@6a78ebe0, electionTerm=1, electionVotedFor=member-1-shard-shard1-config52, ServerConfigPayload=null]] 01:52:10,604 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=[]}}} 01:52:10,605 PM [test-akka.actor.default-dispatcher-12] [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@64bf18df, electionTerm=1, electionVotedFor=member-1-shard-shard2-config52, ServerConfigPayload=null]] 01:52:10,605 PM [test-akka.actor.default-dispatcher-12] [DEBUG] ShardManagerGetSnapshotReplyActor - shard-manager-config52: All shard snapshots received 01:52:10,616 PM [test-akka.actor.default-dispatcher-12] [DEBUG] ShardManager - shard-manager-config52: onAddShardReplica: AddShardReplica[ShardName=astronauts] 01:52:10,619 PM [test-akka.actor.default-dispatcher-6] [DEBUG] ShardManager - shard-manager-config52: Sending AddServer message to peer akka://test@127.0.0.1:2565/system/testProbe-100#56665077 for shard member-1-shard-astronauts-config52 01:52:10,620 PM [test-shard-dispatcher-20] [INFO] Shard - Shard created : member-1-shard-astronauts-config52, persistent : true 01:52:10,621 PM [test-akka.actor.default-dispatcher-6] [INFO] RoleChangeNotifier - RoleChangeNotifier:akka://test@127.0.0.1:2565/user/$$m/member-1-shard-astronauts-config52/member-1-shard-astronauts-config52-notifier#608692589 created and ready for shard:member-1-shard-astronauts-config52 01:52:10,621 PM [test-akka.actor.default-dispatcher-6] [DEBUG] ShardSnapshotActor - Actor created Actor[akka://test/user/$$m/member-1-shard-astronauts-config52/shard-member-1:snapshot-read#424181013] 01:52:10,621 PM [test-shard-dispatcher-20] [INFO] Shard - Starting recovery for member-1-shard-astronauts-config52 with journal batch size 1 01:52:10,622 PM [test-shard-dispatcher-20] [DEBUG] Shard - member-1-shard-astronauts-config52: onReceiveRecover: Received message class akka.persistence.RecoveryCompleted$ from Actor[akka://test/deadLetters] 01:52:10,622 PM [test-shard-dispatcher-20] [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 01:52:10,622 PM [test-shard-dispatcher-20] [DEBUG] DataTreeChangeListenerSupport - member-1-shard-astronauts-config52: onLeadershipChange, isLeader: false, hasLeader : false 01:52:10,622 PM [test-shard-dispatcher-20] [DEBUG] Shard - member-1-shard-astronauts-config52: onStateChanged: Closing all transaction chains because shard member-1-shard-astronauts-config52 is no longer the leader 01:52:10,623 PM [test-shard-dispatcher-20] [INFO] DefaultConfigParamsImpl - Trying to use custom RaftPolicy org.opendaylight.controller.cluster.raft.policy.DisableElectionsRaftPolicy 01:52:10,623 PM [test-akka.actor.default-dispatcher-12] [DEBUG] ShardManager - shard-manager-config52: Initializing shard [astronauts] 01:52:10,623 PM [test-akka.actor.default-dispatcher-12] [DEBUG] ShardInformation - Shard member-1-shard-astronauts-config52 is initialized 01:52:10,623 PM [test-akka.actor.default-dispatcher-11] [INFO] RoleChangeNotifier - RoleChangeNotifier for member-1-shard-astronauts-config52 , received role change from null to Follower 01:52:10,623 PM [test-akka.actor.default-dispatcher-12] [DEBUG] ShardManager - shard-manager-config52: Received AddServerReply{status=OK, leaderHint=} for shard astronauts from leader akka://test@127.0.0.1:2565/system/testProbe-100#56665077 01:52:10,623 PM [test-akka.actor.default-dispatcher-12] [DEBUG] ShardManager - shard-manager-config52: Leader shard successfully added the replica shard astronauts 01:52:10,623 PM [test-akka.actor.default-dispatcher-12] [DEBUG] ShardInformation - Sending new DatastoreContext to member-1-shard-astronauts-config52 01:52:10,623 PM [test-akka.actor.default-dispatcher-12] [DEBUG] ShardManager - shard-manager-config52: persisting the shard list [shard2, astronauts, shard1] 01:52:10,624 PM [test-akka.actor.default-dispatcher-12] [DEBUG] ShardManager - shard-manager-config52 saved ShardManager snapshot successfully. Deleting the prev snapshot if available 01:52:10,624 PM [test-akka.actor.default-dispatcher-12] [DEBUG] ShardManager - shard-manager-config52: Successfully deleted prior snapshots 01:52:10,624 PM [test-akka.actor.default-dispatcher-12] [DEBUG] ShardManager - shard-manager-config52: findLocalShard : astronauts 01:52:10,624 PM [test-akka.actor.default-dispatcher-12] [DEBUG] ShardManager - shard-manager-config52: onGetSnapshot 01:52:10,624 PM [test-akka.actor.default-dispatcher-16] [DEBUG] ShardManagerGetSnapshotReplyActor - shard-manager-config52: Expecting 3 shard snapshot replies 01:52:10,624 PM [test-shard-dispatcher-20] [DEBUG] Shard - member-1-shard-astronauts-config52: RaftPolicy used with prev.config org.opendaylight.controller.cluster.raft.policy.DisableElectionsRaftPolicy, RaftPolicy used with newConfig null 01:52:10,624 PM [test-akka.actor.default-dispatcher-16] [INFO] RoleChangeNotifier - RoleChangeNotifier for member-1-shard-astronauts-config52 , registered listener akka://test/user/$$m 01:52:10,624 PM [test-shard-dispatcher-20] [DEBUG] Shard - member-1-shard-astronauts-config52: Re-initializing to Follower with previous leaderId null 01:52:10,624 PM [test-akka.actor.default-dispatcher-16] [INFO] ShardManager - shard-manager-config52: Received role changed for member-1-shard-astronauts-config52 from null to Follower 01:52:10,624 PM [test-shard-dispatcher-20] [DEBUG] MessageAssembler - member-1-shard-astronauts-config52 (Follower): Closing 01:52:10,625 PM [test-shard-dispatcher-20] [DEBUG] DataTreeChangeListenerSupport - member-1-shard-astronauts-config52: onLeadershipChange, isLeader: false, hasLeader : false 01:52:10,625 PM [test-shard-dispatcher-20] [DEBUG] Shard - member-1-shard-astronauts-config52: onStateChanged: Closing all transaction chains because shard member-1-shard-astronauts-config52 is no longer the leader 01:52:10,625 PM [test-shard-dispatcher-20] [DEBUG] Shard - member-1-shard-astronauts-config52 (Follower): Received TimeoutNow - switching to Candidate 01:52:10,625 PM [test-shard-dispatcher-20] [DEBUG] Shard - member-1-shard-astronauts-config52 (Candidate): Election: Candidate has following voting peers: [] 01:52:10,625 PM [test-shard-dispatcher-20] [DEBUG] Shard - member-1-shard-astronauts-config52: Set currentTerm=1, votedFor=member-1-shard-astronauts-config52 01:52:10,625 PM [test-shard-dispatcher-20] [INFO] Shard - member-1-shard-astronauts-config52 (Candidate): Starting new election term 1 01:52:10,625 PM [test-shard-dispatcher-20] [INFO] Shard - member-1-shard-astronauts-config52 (Follower) :- Switching from behavior Follower to Candidate, election term: 1 01:52:10,625 PM [test-shard-dispatcher-20] [DEBUG] MessageAssembler - member-1-shard-astronauts-config52 (Follower): Closing 01:52:10,625 PM [test-shard-dispatcher-20] [DEBUG] DataTreeChangeListenerSupport - member-1-shard-astronauts-config52: onLeadershipChange, isLeader: false, hasLeader : false 01:52:10,625 PM [test-shard-dispatcher-20] [DEBUG] Shard - member-1-shard-astronauts-config52: onStateChanged: Closing all transaction chains because shard member-1-shard-astronauts-config52 is no longer the leader 01:52:10,625 PM [test-akka.actor.default-dispatcher-11] [INFO] RoleChangeNotifier - RoleChangeNotifier for member-1-shard-astronauts-config52 , received role change from Follower to Candidate 01:52:10,625 PM [test-shard-dispatcher-20] [DEBUG] Shard - member-1-shard-shard2-config52: onGetSnapshot 01:52:10,625 PM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - shard-manager-config52: Received role changed for member-1-shard-astronauts-config52 from Follower to Candidate 01:52:10,625 PM [test-shard-dispatcher-20] [DEBUG] Shard - member-1-shard-shard2-config52: Capturing Snapshot : lastLogEntry is null. Using snapshot values lastAppliedIndex -1 and lastAppliedTerm -1 instead. 01:52:10,625 PM [test-shard-dispatcher-20] [DEBUG] Shard - member-1-shard-shard2-config52: requesting serialization of snapshot MetadataShardDataTreeSnapshot{metadata={class org.opendaylight.controller.cluster.datastore.persisted.FrontendShardDataTreeSnapshotMetadata=FrontendShardDataTreeSnapshotMetadata{clients=[]}}} 01:52:10,625 PM [test-shard-dispatcher-20] [DEBUG] Shard - member-1-shard-shard1-config52: onGetSnapshot 01:52:10,625 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. 01:52:10,625 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=[]}}} 01:52:10,625 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@17bbf1d7, electionTerm=1, electionVotedFor=member-1-shard-shard2-config52, ServerConfigPayload=null]] 01:52:10,626 PM [test-akka.actor.default-dispatcher-10] [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@fa6b662, electionTerm=1, electionVotedFor=member-1-shard-shard1-config52, ServerConfigPayload=null]] 01:52:10,627 PM [test-shard-dispatcher-22] [DEBUG] Shard - member-1-shard-astronauts-config52 (Candidate): Received ElectionTimeout 01:52:10,627 PM [test-shard-dispatcher-22] [DEBUG] Shard - member-1-shard-astronauts-config52 (Leader): Election: Leader has following peers: [] 01:52:10,627 PM [test-shard-dispatcher-22] [INFO] Shard - member-1-shard-astronauts-config52 (Candidate) :- Switching from behavior Candidate to Leader, election term: 1 01:52:10,627 PM [test-shard-dispatcher-22] [DEBUG] DataTreeChangeListenerSupport - member-1-shard-astronauts-config52: onLeadershipChange, isLeader: true, hasLeader : true 01:52:10,627 PM [test-shard-dispatcher-22] [DEBUG] Shard - member-1-shard-astronauts-config52: became leader with frontend state for [] 01:52:10,627 PM [test-shard-dispatcher-22] [DEBUG] Shard - member-1-shard-astronauts-config52: onGetSnapshot 01:52:10,627 PM [test-shard-dispatcher-22] [DEBUG] Shard - member-1-shard-astronauts-config52: Capturing Snapshot : lastLogEntry is null. Using snapshot values lastAppliedIndex -1 and lastAppliedTerm -1 instead. 01:52:10,627 PM [test-akka.actor.default-dispatcher-23] [INFO] RoleChangeNotifier - RoleChangeNotifier for member-1-shard-astronauts-config52 , received role change from Candidate to Leader 01:52:10,628 PM [test-akka.actor.default-dispatcher-23] [INFO] ShardManager - shard-manager-config52: Received LeaderStateChanged message: LeaderStateChanged [memberId=member-1-shard-astronauts-config52, leaderId=member-1-shard-astronauts-config52, leaderPayloadVersion=13] 01:52:10,628 PM [test-shard-dispatcher-22] [DEBUG] Shard - member-1-shard-astronauts-config52: requesting serialization of snapshot MetadataShardDataTreeSnapshot{metadata={class org.opendaylight.controller.cluster.datastore.persisted.FrontendShardDataTreeSnapshotMetadata=FrontendShardDataTreeSnapshotMetadata{clients=[]}}} 01:52:10,628 PM [test-akka.actor.default-dispatcher-23] [INFO] ShardManager - shard-manager-config52: Received role changed for member-1-shard-astronauts-config52 from Candidate to Leader 01:52:10,628 PM [test-akka.actor.default-dispatcher-23] [INFO] ShardManager - shard-manager-config52: All Shards are ready - data store config52 is ready 01:52:10,628 PM [test-akka.actor.default-dispatcher-6] [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@3484b5a4, electionTerm=1, electionVotedFor=member-1-shard-astronauts-config52, ServerConfigPayload=null]] 01:52:10,628 PM [test-akka.actor.default-dispatcher-6] [DEBUG] ShardManagerGetSnapshotReplyActor - shard-manager-config52: All shard snapshots received 01:52:10,628 PM [main] [INFO] ShardManagerTest - testGetSnapshot ending 01:52:10,731 PM [main] [INFO] TestActorFactory - Killing actor TestActor[akka://test/user/$$m] 01:52:10,742 PM [test-shard-dispatcher-22] [INFO] Shard - Stopping Shard member-1-shard-astronauts-config52 01:52:10,742 PM [test-shard-dispatcher-22] [DEBUG] MessageSlicer - member-1-shard-astronauts-config52 (Leader)_slicer-id-16: Closing 01:52:10,742 PM [test-shard-dispatcher-19] [INFO] Shard - Stopping Shard member-1-shard-shard1-config52 01:52:10,742 PM [test-shard-dispatcher-22] [DEBUG] Shard - member-1-shard-astronauts-config52: Aborting 0 pending queued transactions 01:52:10,742 PM [test-shard-dispatcher-19] [DEBUG] MessageSlicer - member-1-shard-shard1-config52 (Leader)_slicer-id-14: Closing 01:52:10,742 PM [test-shard-dispatcher-21] [INFO] Shard - Stopping Shard member-1-shard-shard2-config52 01:52:10,742 PM [test-shard-dispatcher-21] [DEBUG] MessageSlicer - member-1-shard-shard2-config52 (Leader)_slicer-id-13: Closing 01:52:10,742 PM [test-shard-dispatcher-19] [DEBUG] Shard - member-1-shard-shard1-config52: Aborting 0 pending queued transactions 01:52:10,743 PM [test-shard-dispatcher-21] [DEBUG] Shard - member-1-shard-shard2-config52: Aborting 0 pending queued transactions 01:52:10,743 PM [test-akka.actor.default-dispatcher-24] [INFO] ShardManager - Stopping ShardManager shard-manager-config52 01:52:10,745 PM [main] [INFO] ShardManagerTest - testWhenMultipleShardsPresentSyncStatusMustBeTrueForAllShards starting 01:52:10,748 PM [main] [INFO] ShardManager - Starting ShardManager shard-manager-config53 01:52:10,750 PM [test-akka.actor.default-dispatcher-24] [INFO] ShardManager - Recovery complete : shard-manager-config53 01:52:10,750 PM [test-akka.actor.default-dispatcher-24] [DEBUG] ShardManager - shard-manager-config53: Creating local shard: member-1-shard-default-config53 01:52:10,751 PM [test-akka.actor.default-dispatcher-24] [DEBUG] ShardManager - shard-manager-config53: Creating local shard: member-1-shard-astronauts-config53 01:52:10,849 PM [main] [INFO] ShardManager - shard-manager-config53: Received role changed for member-1-shard-default-config53 from Follower to Leader 01:52:10,850 PM [main] [INFO] ShardManager - shard-manager-config53: Received role changed for member-1-shard-astronauts-config53 from Follower to Leader 01:52:10,850 PM [main] [INFO] ShardManager - shard-manager-config53: Received role changed for member-1-shard-astronauts-config53 from Leader to Follower 01:52:10,850 PM [main] [INFO] ShardManager - shard-manager-config53 Received follower initial sync status for member-1-shard-astronauts-config53 status sync done true 01:52:10,850 PM [main] [INFO] ShardManagerTest - testWhenMultipleShardsPresentSyncStatusMustBeTrueForAllShards ending 01:52:10,951 PM [main] [INFO] TestActorFactory - Killing actor TestActor[akka://test/user/$$n] 01:52:10,962 PM [main] [INFO] ShardManager - Stopping ShardManager shard-manager-config53 01:52:10,966 PM [main] [INFO] ShardManagerTest - testAddShardReplicaWithFindPrimaryTimeout starting 01:52:10,970 PM [test-akka.actor.default-dispatcher-16] [INFO] ShardManager - Starting ShardManager shard-manager-config54 01:52:10,971 PM [test-akka.actor.default-dispatcher-24] [INFO] ShardManager - Recovery complete : shard-manager-config54 01:52:10,981 PM [test-akka.actor.default-dispatcher-16] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1 01:52:10,981 PM [test-akka.actor.default-dispatcher-16] [INFO] ShardManager - shard-manager-config54: Received MemberUp: memberName: MemberName{name=member-2}, address: akka://non-existent@127.0.0.1:5 01:52:10,981 PM [test-akka.actor.default-dispatcher-16] [INFO] ShardManager - shard-manager-config54: All Shards are ready - data store config54 is ready 01:52:10,981 PM [test-akka.actor.default-dispatcher-16] [DEBUG] ShardManager - shard-manager-config54: onAddShardReplica: AddShardReplica[ShardName=astronauts] 01:52:10,981 PM [test-akka.actor.default-dispatcher-16] [DEBUG] ShardManager - shard-manager-config54: In findPrimary: org.opendaylight.controller.cluster.datastore.messages.FindPrimary [shardName=astronauts, waitUntilReady=true] 01:52:10,981 PM [test-akka.actor.default-dispatcher-16] [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] 01:52:11,3 PM [test-akka.actor.default-dispatcher-16] [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/:5,None,List(),Some(5000 milliseconds),true)] failed because of java.net.ConnectException: Connection refused 01:52:11,4 PM [test-akka.actor.default-dispatcher-16] [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/:5,None,List(),Some(5000 milliseconds),true)] failed because of java.net.ConnectException: Connection refused 01:52:11,193 PM [test-akka.actor.default-dispatcher-16] [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#1872482593]] 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. 01:52:11,193 PM [main] [INFO] ShardManagerTest - testAddShardReplicaWithFindPrimaryTimeout ending 01:52:11,297 PM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/shardmanager-config54#1872482593] 01:52:11,308 PM [test-akka.actor.default-dispatcher-16] [INFO] ShardManager - Stopping ShardManager shard-manager-config54 01:52:11,310 PM [main] [INFO] ShardManagerTest - testOnCreateShard starting 01:52:11,316 PM [test-akka.actor.default-dispatcher-16] [INFO] ShardManager - Starting ShardManager shard-manager-config55 01:52:11,317 PM [test-akka.actor.default-dispatcher-24] [INFO] ShardManager - Recovery complete : shard-manager-config55 01:52:11,318 PM [test-akka.actor.default-dispatcher-23] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1 01:52:11,328 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@6a2c4d90] 01:52:11,328 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 01:52:11,330 PM [test-akka.actor.default-dispatcher-6] [DEBUG] ShardManager - shard-manager-config55: findLocalShard : foo 01:52:11,330 PM [test-akka.actor.default-dispatcher-6] [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] 01:52:11,332 PM [test-shard-dispatcher-20] [INFO] Shard - Shard created : member-1-shard-foo-config55, persistent : false 01:52:11,333 PM [test-akka.actor.default-dispatcher-6] [INFO] RoleChangeNotifier - RoleChangeNotifier:akka://test@127.0.0.1:2565/user/$C/member-1-shard-foo-config55/member-1-shard-foo-config55-notifier#-1414009128 created and ready for shard:member-1-shard-foo-config55 01:52:11,333 PM [test-akka.actor.default-dispatcher-6] [DEBUG] ShardSnapshotActor - Actor created Actor[akka://test/user/$C/member-1-shard-foo-config55/shard-member-1:snapshot-read#700814237] 01:52:11,334 PM [test-shard-dispatcher-20] [INFO] Shard - Starting recovery for member-1-shard-foo-config55 with journal batch size 1 01:52:11,339 PM [test-shard-dispatcher-20] [DEBUG] Shard - member-1-shard-foo-config55: onReceiveRecover: Received message class akka.persistence.RecoveryCompleted$ from Actor[akka://test/deadLetters] 01:52:11,340 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 01:52:11,340 PM [test-shard-dispatcher-20] [DEBUG] DataTreeChangeListenerSupport - member-1-shard-foo-config55: onLeadershipChange, isLeader: false, hasLeader : false 01:52:11,340 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 01:52:11,340 PM [test-akka.actor.default-dispatcher-11] [INFO] RoleChangeNotifier - RoleChangeNotifier for member-1-shard-foo-config55 , received role change from null to Follower 01:52:11,340 PM [test-akka.actor.default-dispatcher-23] [DEBUG] ShardManager - shard-manager-config55: Initializing shard [foo] 01:52:11,340 PM [test-akka.actor.default-dispatcher-23] [DEBUG] ShardInformation - Shard member-1-shard-foo-config55 is initialized 01:52:11,340 PM [test-akka.actor.default-dispatcher-23] [DEBUG] ShardInformation - Shard member-1-shard-foo-config55 is initialized - notifying 1 OnShardInitialized callbacks 01:52:11,340 PM [test-akka.actor.default-dispatcher-23] [INFO] RoleChangeNotifier - RoleChangeNotifier for member-1-shard-foo-config55 , registered listener akka://test/user/$C 01:52:11,341 PM [test-akka.actor.default-dispatcher-23] [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@6a2c4d90] 01:52:11,341 PM [test-akka.actor.default-dispatcher-23] [DEBUG] ShardManager - shard-manager-config55: Shard foo already exists 01:52:11,341 PM [test-akka.actor.default-dispatcher-23] [INFO] ShardManager - shard-manager-config55: Received role changed for member-1-shard-foo-config55 from null to Follower 01:52:11,341 PM [main] [INFO] ShardManagerTest - testOnCreateShard ending 01:52:11,442 PM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/$C#515012831] 01:52:11,454 PM [test-shard-dispatcher-20] [INFO] Shard - Stopping Shard member-1-shard-foo-config55 01:52:11,454 PM [test-shard-dispatcher-20] [DEBUG] MessageAssembler - member-1-shard-foo-config55 (Follower): Closing 01:52:11,454 PM [test-shard-dispatcher-20] [DEBUG] Shard - member-1-shard-foo-config55: Aborting 0 pending queued transactions 01:52:11,454 PM [test-akka.actor.default-dispatcher-16] [INFO] ShardManager - Stopping ShardManager shard-manager-config55 01:52:11,457 PM [test-akka.actor.default-dispatcher-16] [INFO] ShardManager - Stopping ShardManager shard-manager-config1 01:52:11,458 PM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Stopping ShardManager shard-manager-config35 01:52:11,458 PM [test-akka.actor.default-dispatcher-16] [INFO] ShardManager - Stopping ShardManager shard-manager-config43 01:52:11,458 PM [test-akka.actor.default-dispatcher-23] [INFO] ShardManager - Stopping ShardManager shard-manager-config11 01:52:11,458 PM [test-akka.actor.default-dispatcher-16] [INFO] ShardManager - Stopping ShardManager shard-manager-config21 01:52:11,458 PM [test-akka.actor.default-dispatcher-23] [INFO] ShardManager - Stopping ShardManager shard-manager-config46 01:52:11,459 PM [test-akka.actor.default-dispatcher-11] [INFO] RemoteActorRefProvider$RemotingTerminator - Shutting down remote daemon. 01:52:11,459 PM [test-akka.actor.default-dispatcher-11] [INFO] RemoteActorRefProvider$RemotingTerminator - Remote daemon shut down; proceeding with flushing remote transports. 01:52:11,464 PM [test-akka.actor.default-dispatcher-11] [INFO] RemoteActorRefProvider$RemotingTerminator - Remoting shut down. [WARN] [04/29/2024 13:52:11.467] [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