11:20:13,586 AM [test-akka.actor.default-dispatcher-5] [INFO] Slf4jLogger - Slf4jLogger started
11:20:13,593 AM [test-akka.actor.default-dispatcher-5] [INFO] ArteryTransport - Remoting started with transport [Artery tcp]; listening on address [akka://test@127.0.0.1:2565] with UID [2680372904147772795]
11:20:13,594 AM [test-akka.actor.default-dispatcher-5] [INFO] Cluster - Cluster Node [akka://test@127.0.0.1:2565] - Starting up, Akka version [2.6.21] ...
11:20:13,604 AM [test-akka.actor.default-dispatcher-5] [INFO] Cluster - Cluster Node [akka://test@127.0.0.1:2565] - Registered cluster JMX MBean [akka:type=Cluster]
11:20:13,604 AM [test-akka.actor.default-dispatcher-5] [INFO] Cluster - Cluster Node [akka://test@127.0.0.1:2565] - Started up successfully
11:20:13,605 AM [test-akka.actor.default-dispatcher-5] [INFO] Cluster - Cluster Node [akka://test@127.0.0.1:2565] - No downing-provider-class configured, manual cluster downing required, see https://doc.akka.io/docs/akka/current/typed/cluster.html#downing
11:20:13,605 AM [test-akka.actor.default-dispatcher-5] [INFO] Cluster - Cluster Node [akka://test@127.0.0.1:2565] - No seed-nodes configured, manual cluster join required, see https://doc.akka.io/docs/akka/current/typed/cluster.html#joining
11:20:13,634 AM [test-akka.actor.default-dispatcher-10] [INFO] EmptyLocalActorRef - Message [org.opendaylight.controller.cluster.common.actor.Monitor] from Actor[akka://test/user/$a#1239133127] 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'.
11:20:13,637 AM [test-akka.actor.default-dispatcher-5] [INFO] ShardManager - Starting ShardManager shard-manager-config1
11:20:13,656 AM [test-akka.actor.default-dispatcher-5] [INFO] ShardManager - Recovery complete : shard-manager-config1
11:20:13,656 AM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - shard-manager-config1: Creating local shard: member-1-shard-default-config1
11:20:13,658 AM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1
11:20:13,658 AM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - Creating Shard member-1-shard-default-config1
11:20:13,658 AM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - shard-manager-config1: Initializing shard [default]
11:20:13,658 AM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardInformation - Shard member-1-shard-default-config1 is initialized
11:20:13,658 AM [test-akka.actor.default-dispatcher-5] [INFO] ShardManager - shard-manager-config1: Received role changed for member-1-shard-default-config1 from null to Follower
11:20:13,659 AM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - shard-manager-config1: onChangeShardServersVotingStatus: ChangeShardMembersVotingStatus [shardName=default, meberVotingStatusMap={member-2=true}]
11:20:13,661 AM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - shard-manager-config1: findLocalShard : default
11:20:13,664 AM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config1: Sending ChangeServersVotingStatus message ChangeServersVotingStatus [serverVotingStatusMap={member-2-shard-default-config1=true}, serversVisited=[]] to local shard akka://test/user/member-1-shard-default-config1
11:20:13,666 AM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - shard-manager-config1: Received ServerChangeReply{status=NO_LEADER} from local shard akka://test/user/member-1-shard-default-config1
11:20:13,666 AM [test-akka.actor.default-dispatcher-5] [WARN] ShardManager - shard-manager-config1: ChangeServersVotingStatus failed for shard default with status NO_LEADER
11:20:13,813 AM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/member-1-shard-default-config1#1476523292]
11:20:13,825 AM [main] [INFO] ShardManagerTest - testOnReceiveFindPrimaryWaitForShardLeader starting
11:20:13,827 AM [test-akka.actor.default-dispatcher-10] [INFO] EmptyLocalActorRef - Message [org.opendaylight.controller.cluster.common.actor.Monitor] from Actor[akka://test/user/$b#-1103077516] 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'.
11:20:13,828 AM [test-akka.actor.default-dispatcher-5] [INFO] ShardManager - Starting ShardManager shard-manager-config2
11:20:13,830 AM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Recovery complete : shard-manager-config2
11:20:13,830 AM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config2: Creating local shard: member-1-shard-default-config2
11:20:13,838 AM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1
11:20:13,838 AM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - Creating Shard member-1-shard-default-config2
11:20:13,839 AM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - shard-manager-config2: In findPrimary: org.opendaylight.controller.cluster.datastore.messages.FindPrimary [shardName=default, waitUntilReady=true]
11:20:13,846 AM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - shard-manager-config2: Scheduling 10000 ms timer to wait for shard ShardInformation [shardId=member-1-shard-default-config2, leaderAvailable=false, actorInitialized=false, followerSyncStatus=false, role=null, leaderId=null, activeMember=true]
11:20:13,989 AM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - shard-manager-config2: Initializing shard [default]
11:20:13,989 AM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardInformation - Shard member-1-shard-default-config2 is initialized
11:20:13,989 AM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardInformation - Shard member-1-shard-default-config2 is initialized - notifying 1 OnShardInitialized callbacks
11:20:14,139 AM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - shard-manager-config2: Received role changed for member-1-shard-default-config2 from Candidate to Leader
11:20:14,139 AM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardInformation - Shard member-1-shard-default-config2 is initialized - notifying 1 OnShardInitialized callbacks
11:20:14,290 AM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - shard-manager-config2: Received LeaderStateChanged message: LeaderStateChanged [memberId=member-1-shard-default-config2, leaderId=member-1-shard-default-config2, leaderPayloadVersion=13]
11:20:14,290 AM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardInformation - Shard member-1-shard-default-config2 is ready - notifying 1 OnShardInitialized callbacks
11:20:14,290 AM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config2: Found primary for default: LocalPrimaryShardFound [primaryPath=akka://test@127.0.0.1:2565/user/member-1-shard-default-config#2004511266, localShardDataTree=org.opendaylight.yangtools.yang.data.tree.api.DataTree$MockitoMock$mgMIAwg7@1a2818ca]
11:20:14,291 AM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - shard-manager-config2: All Shards are ready - data store config2 is ready
11:20:14,491 AM [main] [INFO] ShardManagerTest - testOnReceiveFindPrimaryWaitForShardLeader ending
11:20:14,593 AM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/$b#-1103077516]
11:20:14,604 AM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Stopping ShardManager shard-manager-config2
11:20:14,608 AM [test-akka.actor.default-dispatcher-5] [INFO] EmptyLocalActorRef - Message [org.opendaylight.controller.cluster.common.actor.Monitor] from TestActor[akka://test/user/$$g] 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'.
11:20:14,608 AM [main] [INFO] ShardManager - Starting ShardManager shard-manager-config3
11:20:14,609 AM [test-akka.actor.default-dispatcher-5] [INFO] ShardManager - Recovery complete : shard-manager-config3
11:20:14,610 AM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - shard-manager-config3: Creating local shard: member-1-shard-default-config3
11:20:14,610 AM [main] [INFO] ShardManager - shard-manager-config3: Received role changed for member-1-shard-default-config3 from Follower to Candidate
11:20:14,610 AM [main] [INFO] ShardManager - shard-manager-config3 Received follower initial sync status for member-1-shard-default-config3 status sync done true
11:20:14,712 AM [main] [INFO] TestActorFactory - Killing actor TestActor[akka://test/user/$$g]
11:20:14,722 AM [main] [INFO] ShardManager - Stopping ShardManager shard-manager-config3
11:20:14,732 AM [cluster-test-akka.actor.default-dispatcher-5] [INFO] Slf4jLogger - Slf4jLogger started
11:20:14,739 AM [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 [-3130951337014593536]
11:20:14,739 AM [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] ...
11:20:14,743 AM [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
11:20:14,743 AM [cluster-test-akka.actor.default-dispatcher-5] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2558] - Started up successfully
11:20:14,751 AM [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
11:20:14,751 AM [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
11:20:14,765 AM [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
11:20:14,767 AM [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)
11:20:14,774 AM [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]
11:20:14,785 AM [cluster-test-akka.actor.default-dispatcher-5] [INFO] ShardManager - Starting ShardManager shard-manager-config4
11:20:14,793 AM [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'.
11:20:14,798 AM [cluster-test-akka.actor.default-dispatcher-6] [INFO] Slf4jLogger - Slf4jLogger started
11:20:14,804 AM [cluster-test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Recovery complete : shard-manager-config4
11:20:14,804 AM [cluster-test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config4: Creating local shard: member-1-shard-default-config4
11:20:14,805 AM [cluster-test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config4: Creating local shard: member-1-shard-astronauts-config4
11:20:14,805 AM [cluster-test-akka.actor.default-dispatcher-11] [INFO] ShardManager - shard-manager-config4: Received MemberUp: memberName: MemberName{name=member-1}, address: akka://cluster-test@127.0.0.1:2558
11:20:14,805 AM [cluster-test-akka.actor.default-dispatcher-11] [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
11:20:14,805 AM [cluster-test-akka.actor.default-dispatcher-11] [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
11:20:14,812 AM [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 [181161505127620531]
11:20:14,812 AM [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] ...
11:20:14,814 AM [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
11:20:14,814 AM [cluster-test-akka.actor.default-dispatcher-6] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2559] - Started up successfully
11:20:14,821 AM [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
11:20:14,821 AM [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
11:20:14,824 AM [main] [ERROR] ShardManagerTest - Mock Shard Leader Actor : TestActor[akka://cluster-test/user/member-2-shard-default-config4]
11:20:14,830 AM [cluster-test-akka.actor.default-dispatcher-6] [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'.
11:20:14,835 AM [cluster-test-akka.actor.default-dispatcher-10] [INFO] ShardManager - Starting ShardManager shard-manager-config4
11:20:14,836 AM [main] [ERROR] ShardManagerTest - Forwarding actor : Actor[akka://cluster-test/user/shardmanager-config4/member-2-shard-default-config4#1828582961]
11:20:14,845 AM [cluster-test-akka.actor.default-dispatcher-14] [INFO] ShardManager - Recovery complete : shard-manager-config4
11:20:14,845 AM [cluster-test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - shard-manager-config4: Creating local shard: member-2-shard-default-config4
11:20:14,847 AM [cluster-test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1
11:20:14,847 AM [cluster-test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - Creating Shard member-1-shard-default-config4
11:20:14,847 AM [cluster-test-akka.actor.default-dispatcher-11] [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
11:20:14,847 AM [cluster-test-akka.actor.default-dispatcher-11] [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
11:20:14,847 AM [cluster-test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1
11:20:14,847 AM [cluster-test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - Creating Shard member-2-shard-default-config4
11:20:14,847 AM [cluster-test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - shard-manager-config4: Initializing shard [default]
11:20:14,847 AM [cluster-test-akka.actor.default-dispatcher-14] [DEBUG] ShardInformation - Shard member-2-shard-default-config4 is initialized
11:20:14,847 AM [cluster-test-akka.actor.default-dispatcher-14] [INFO] ShardManager - shard-manager-config4: Received LeaderStateChanged message: LeaderStateChanged [memberId=member-2-shard-default-config4, leaderId=member-2-shard-default-config4, leaderPayloadVersion=12]
11:20:14,847 AM [cluster-test-akka.actor.default-dispatcher-14] [INFO] ShardManager - shard-manager-config4: Received role changed for member-2-shard-default-config4 from Candidate to Leader
11:20:14,847 AM [cluster-test-akka.actor.default-dispatcher-14] [INFO] ShardManager - shard-manager-config4: All Shards are ready - data store config4 is ready
11:20:14,849 AM [cluster-test-akka.actor.default-dispatcher-11] [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#1087720489]
11:20:14,849 AM [cluster-test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - Creating Shard member-1-shard-astronauts-config4
11:20:14,849 AM [cluster-test-akka.actor.default-dispatcher-11] [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
11:20:14,849 AM [cluster-test-akka.actor.default-dispatcher-11] [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
11:20:14,849 AM [cluster-test-akka.actor.default-dispatcher-11] [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#1087720489]
11:20:14,849 AM [cluster-test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config4: Initializing shard [default]
11:20:14,849 AM [cluster-test-akka.actor.default-dispatcher-11] [DEBUG] ShardInformation - Shard member-1-shard-default-config4 is initialized
11:20:14,849 AM [cluster-test-akka.actor.default-dispatcher-11] [INFO] ShardManager - shard-manager-config4: Received LeaderStateChanged message: LeaderStateChanged [memberId=member-1-shard-default-config4, leaderId=member-2-shard-default-config4, leaderPayloadVersion=12]
11:20:14,849 AM [cluster-test-akka.actor.default-dispatcher-11] [INFO] ShardManager - shard-manager-config4: Received role changed for member-1-shard-default-config4 from Candidate to Follower
11:20:15,161 AM [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]
11:20:15,207 AM [cluster-test-akka.actor.default-dispatcher-10] [INFO] ShardManager - shard-manager-config4: Received MemberUp: memberName: MemberName{name=member-1}, address: akka://cluster-test@127.0.0.1:2558
11:20:15,207 AM [cluster-test-akka.actor.default-dispatcher-10] [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
11:20:15,207 AM [cluster-test-akka.actor.default-dispatcher-10] [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
11:20:15,208 AM [cluster-test-akka.actor.default-dispatcher-10] [INFO] ShardManager - shard-manager-config4: All Shards are ready - data store config4 is ready
11:20:15,208 AM [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]
11:20:15,789 AM [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]
11:20:15,789 AM [cluster-test-akka.actor.default-dispatcher-13] [INFO] ShardManager - shard-manager-config4: Received MemberUp: memberName: MemberName{name=member-2}, address: akka://cluster-test@127.0.0.1:2559
11:20:15,790 AM [cluster-test-akka.actor.default-dispatcher-13] [INFO] ShardInformation - updatePeerAddress for peer member-2-shard-default-config4 with address akka://cluster-test@127.0.0.1:2559/user/shardmanager-config4/member-2-shard-default-config4
11:20:15,790 AM [cluster-test-akka.actor.default-dispatcher-13] [DEBUG] ShardInformation - Sending PeerAddressResolved for peer member-2-shard-default-config4 with address akka://cluster-test@127.0.0.1:2559/user/shardmanager-config4/member-2-shard-default-config4 to akka://cluster-test/user/member-1-shard-default-config
11:20:15,790 AM [cluster-test-akka.actor.default-dispatcher-13] [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
11:20:15,790 AM [cluster-test-akka.actor.default-dispatcher-13] [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
11:20:15,791 AM [cluster-test-akka.actor.default-dispatcher-12] [DEBUG] ShardManager - shard-manager-config4: onRemoveShardReplica: RemoveShardReplica [shardName=default, memberName=MemberName{name=member-1}]
11:20:15,793 AM [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]
11:20:15,793 AM [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]
11:20:15,793 AM [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
11:20:15,812 AM [cluster-test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config4: Received RemoveServerReply{status=OK, leaderHint=member-2-shard-default-config4} for shard default
11:20:15,812 AM [cluster-test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config4: Leader shard successfully removed the replica shard default
11:20:15,845 AM [cluster-test-akka.actor.default-dispatcher-12] [INFO] ShardManager - shard-manager-config4: Received MemberUp: memberName: MemberName{name=member-2}, address: akka://cluster-test@127.0.0.1:2559
11:20:15,845 AM [cluster-test-akka.actor.default-dispatcher-12] [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
11:20:15,845 AM [cluster-test-akka.actor.default-dispatcher-12] [DEBUG] ShardInformation - Sending PeerAddressResolved for peer member-2-shard-default-config4 with address akka://cluster-test@127.0.0.1:2559/user/shardmanager-config4/member-2-shard-default-config4 to akka://cluster-test/user/member-2-shard-default-config4
11:20:15,845 AM [cluster-test-akka.actor.default-dispatcher-12] [INFO] ShardManager - shard-manager-config4: All Shards are ready - data store config4 is ready
11:20:15,943 AM [cluster-test-akka.actor.default-dispatcher-13] [INFO] ShardManager - Stopping ShardManager shard-manager-config4
11:20:15,945 AM [cluster-test-akka.actor.default-dispatcher-13] [INFO] RemoteActorRefProvider$RemotingTerminator - Shutting down remote daemon.
11:20:15,945 AM [cluster-test-akka.actor.default-dispatcher-13] [INFO] RemoteActorRefProvider$RemotingTerminator - Remote daemon shut down; proceeding with flushing remote transports.
11:20:15,972 AM [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
11:20:15,972 AM [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
11:20:15,980 AM [cluster-test-akka.actor.default-dispatcher-13] [INFO] RemoteActorRefProvider$RemotingTerminator - Remoting shut down.
11:20:16,12 AM [cluster-test-akka.actor.default-dispatcher-12] [INFO] ShardManager - Stopping ShardManager shard-manager-config4
11:20:16,13 AM [cluster-test-akka.actor.default-dispatcher-12] [INFO] RemoteActorRefProvider$RemotingTerminator - Shutting down remote daemon.
11:20:16,13 AM [cluster-test-akka.actor.default-dispatcher-12] [INFO] RemoteActorRefProvider$RemotingTerminator - Remote daemon shut down; proceeding with flushing remote transports.
11:20:17,36 AM [cluster-test-akka.actor.default-dispatcher-12] [INFO] RemoteActorRefProvider$RemotingTerminator - Remoting shut down.
[WARN] [02/27/2024 11:20:17.038] [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
11:20:17,56 AM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - Starting ShardManager shard-manager-config5
11:20:17,57 AM [test-akka.actor.default-dispatcher-5] [INFO] EmptyLocalActorRef - Message [org.opendaylight.controller.cluster.common.actor.Monitor] from Actor[akka://test/user/$c#-843624582] 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'.
11:20:17,58 AM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Recovery complete : shard-manager-config5
11:20:17,58 AM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config5: Creating local shard: member-1-shard-default-config5
11:20:17,67 AM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1
11:20:17,67 AM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - Creating Shard member-1-shard-default-config5
11:20:17,68 AM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config5: Initializing shard [default]
11:20:17,68 AM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardInformation - Shard member-1-shard-default-config5 is initialized
11:20:17,220 AM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/$c#-843624582]
11:20:17,231 AM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - Stopping ShardManager shard-manager-config5
11:20:17,235 AM [test-akka.actor.default-dispatcher-10] [INFO] EmptyLocalActorRef - Message [org.opendaylight.controller.cluster.common.actor.Monitor] from TestActor[akka://test/user/$$h] 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'.
11:20:17,235 AM [main] [INFO] ShardManager - Starting ShardManager shard-manager-config6
11:20:17,237 AM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - Recovery complete : shard-manager-config6
11:20:17,237 AM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config6: Creating local shard: member-1-shard-default-config6
11:20:17,237 AM [main] [INFO] ShardManager - shard-manager-config6: Received role changed for member-1-shard-default-config6 from null to Follower
11:20:17,248 AM [main] [INFO] ShardManager - shard-manager-config6: Received MemberUp: memberName: MemberName{name=member-2}, address: akka://test
11:20:17,248 AM [main] [INFO] ShardInformation - updatePeerAddress for peer member-2-shard-default-config6 with address akka://test/user/shardmanager-config6/member-2-shard-default-config6
11:20:17,248 AM [main] [INFO] ShardManager - shard-manager-config6: Received LeaderStateChanged message: LeaderStateChanged [memberId=member-1-shard-default-config6, leaderId=member-2-shard-default-config6, leaderPayloadVersion=13]
11:20:17,248 AM [main] [INFO] ShardManager - shard-manager-config6: All Shards are ready - data store config6 is ready
11:20:17,350 AM [main] [INFO] TestActorFactory - Killing actor TestActor[akka://test/user/$$h]
11:20:17,361 AM [main] [INFO] ShardManager - Stopping ShardManager shard-manager-config6
11:20:17,366 AM [test-akka.actor.default-dispatcher-5] [INFO] EmptyLocalActorRef - Message [org.opendaylight.controller.cluster.common.actor.Monitor] from Actor[akka://test/user/$d#1950395231] 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'.
11:20:17,367 AM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - Starting ShardManager shard-manager-config7
11:20:17,374 AM [test-akka.actor.default-dispatcher-5] [INFO] ShardManager - Recovery complete : shard-manager-config7
11:20:17,374 AM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - shard-manager-config7: onRemoveShardReplica: RemoveShardReplica [shardName=model-inventory, memberName=MemberName{name=member-1}]
11:20:17,374 AM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - shard-manager-config7: In findPrimary: org.opendaylight.controller.cluster.datastore.messages.FindPrimary [shardName=model-inventory, waitUntilReady=true]
11:20:17,375 AM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - shard-manager-config7: No shard found for model-inventory
11:20:17,375 AM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config7: Failed to find leader for shard model-inventory: received response: {}
org.opendaylight.controller.cluster.datastore.exceptions.PrimaryNotFoundException: No primary shard found for model-inventory.
	at org.opendaylight.controller.cluster.datastore.shardmanager.ShardManager.findPrimary(ShardManager.java: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)
11:20:17,477 AM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/$d#1950395231]
11:20:17,488 AM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Stopping ShardManager shard-manager-config7
11:20:17,490 AM [main] [INFO] ShardManagerTest - testAddShardReplicaWithPreExistingLocalReplicaLeader starting
11:20:17,493 AM [test-akka.actor.default-dispatcher-11] [INFO] EmptyLocalActorRef - Message [org.opendaylight.controller.cluster.common.actor.Monitor] from Actor[akka://test/user/$e#415229240] 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'.
11:20:17,493 AM [test-akka.actor.default-dispatcher-5] [INFO] ShardManager - Starting ShardManager shard-manager-config8
11:20:17,494 AM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - Recovery complete : shard-manager-config8
11:20:17,494 AM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config8: Creating local shard: member-1-shard-default-config8
11:20:17,504 AM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1
11:20:17,504 AM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - Creating Shard member-1-shard-default-config8
11:20:17,504 AM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - shard-manager-config8: Initializing shard [default]
11:20:17,504 AM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardInformation - Shard member-1-shard-default-config8 is initialized
11:20:17,504 AM [test-akka.actor.default-dispatcher-5] [INFO] ShardManager - shard-manager-config8: Received LeaderStateChanged message: LeaderStateChanged [memberId=member-1-shard-default-config8, leaderId=member-1-shard-default-config8, leaderPayloadVersion=13]
11:20:17,504 AM [test-akka.actor.default-dispatcher-5] [INFO] ShardManager - shard-manager-config8: Received role changed for member-1-shard-default-config8 from Candidate to Leader
11:20:17,504 AM [test-akka.actor.default-dispatcher-5] [INFO] ShardManager - shard-manager-config8: All Shards are ready - data store config8 is ready
11:20:17,504 AM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - shard-manager-config8: onAddShardReplica: AddShardReplica[ShardName=default]
11:20:17,506 AM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - shard-manager-config8: In findPrimary: org.opendaylight.controller.cluster.datastore.messages.FindPrimary [shardName=default, waitUntilReady=true]
11:20:17,506 AM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - shard-manager-config8: Found primary for default: LocalPrimaryShardFound [primaryPath=akka://test@127.0.0.1:2565/user/member-1-shard-default-config#847128359, localShardDataTree=org.opendaylight.yangtools.yang.data.tree.api.DataTree$MockitoMock$mgMIAwg7@1eef4756]
11:20:17,506 AM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config8: Local shard default already exists
11:20:17,508 AM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config8: findLocalShard : default
11:20:17,508 AM [main] [INFO] ShardManagerTest - testAddShardReplicaWithPreExistingLocalReplicaLeader ending
11:20:17,609 AM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/$e#415229240]
11:20:17,620 AM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - Stopping ShardManager shard-manager-config8
11:20:17,622 AM [main] [INFO] ShardManagerTest - testOnReceiveFindLocalShardWaitForShardInitialized starting
11:20:17,625 AM [test-akka.actor.default-dispatcher-10] [INFO] EmptyLocalActorRef - Message [org.opendaylight.controller.cluster.common.actor.Monitor] from Actor[akka://test/user/$f#-1405158988] 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'.
11:20:17,625 AM [test-akka.actor.default-dispatcher-5] [INFO] ShardManager - Starting ShardManager shard-manager-config9
11:20:17,626 AM [test-akka.actor.default-dispatcher-5] [INFO] ShardManager - Recovery complete : shard-manager-config9
11:20:17,627 AM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - shard-manager-config9: Creating local shard: member-1-shard-default-config9
11:20:17,636 AM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1
11:20:17,636 AM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - Creating Shard member-1-shard-default-config9
11:20:17,636 AM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config9: findLocalShard : default
11:20:17,636 AM [test-akka.actor.default-dispatcher-10] [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]
11:20:17,636 AM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config9: Initializing shard [default]
11:20:17,636 AM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardInformation - Shard member-1-shard-default-config9 is initialized
11:20:17,636 AM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardInformation - Shard member-1-shard-default-config9 is initialized - notifying 1 OnShardInitialized callbacks
11:20:17,641 AM [main] [INFO] ShardManagerTest - testOnReceiveFindLocalShardWaitForShardInitialized starting
11:20:17,742 AM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/$f#-1405158988]
11:20:17,753 AM [test-akka.actor.default-dispatcher-5] [INFO] ShardManager - Stopping ShardManager shard-manager-config9
11:20:17,755 AM [main] [INFO] ShardManagerTest - testShardAvailabilityChangeOnMemberUnreachableAndLeadershipChange starting
11:20:17,762 AM [cluster-test-akka.actor.default-dispatcher-5] [INFO] Slf4jLogger - Slf4jLogger started
11:20:17,769 AM [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 [669397744019030082]
11:20:17,769 AM [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] ...
11:20:17,777 AM [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]
11:20:17,777 AM [cluster-test-akka.actor.default-dispatcher-10] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2558] - Started up successfully
11:20:17,777 AM [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
11:20:17,777 AM [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
11:20:17,788 AM [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
11:20:17,788 AM [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)
11:20:17,788 AM [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]
11:20:17,793 AM [cluster-test-akka.actor.default-dispatcher-5] [INFO] ShardManager - Starting ShardManager shard-manager-config10
11:20:17,793 AM [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'.
11:20:17,849 AM [cluster-test-akka.actor.default-dispatcher-12] [INFO] ShardManager - Recovery complete : shard-manager-config10
11:20:17,849 AM [cluster-test-akka.actor.default-dispatcher-12] [DEBUG] ShardManager - shard-manager-config10: Creating local shard: member-1-shard-default-config10
11:20:17,850 AM [cluster-test-akka.actor.default-dispatcher-12] [INFO] ShardManager - shard-manager-config10: Received MemberUp: memberName: MemberName{name=member-1}, address: akka://cluster-test@127.0.0.1:2558
11:20:17,850 AM [cluster-test-akka.actor.default-dispatcher-12] [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
11:20:17,854 AM [cluster-test-akka.actor.default-dispatcher-5] [INFO] Slf4jLogger - Slf4jLogger started
11:20:17,873 AM [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 [2166256420236723892]
11:20:17,873 AM [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] ...
11:20:17,874 AM [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
11:20:17,874 AM [cluster-test-akka.actor.default-dispatcher-5] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2559] - Started up successfully
11:20:17,882 AM [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
11:20:17,882 AM [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
11:20:17,899 AM [cluster-test-akka.actor.default-dispatcher-10] [INFO] ShardManager - Starting ShardManager shard-manager-config10
11:20:17,899 AM [cluster-test-akka.actor.default-dispatcher-10] [INFO] EmptyLocalActorRef - Message [org.opendaylight.controller.cluster.common.actor.Monitor] from TestActor[akka://cluster-test/user/shardmanager-config10] to Actor[akka://cluster-test/user/termination-monitor] was not delivered. [1] dead letters encountered. If this is not an expected behavior then Actor[akka://cluster-test/user/termination-monitor] may have terminated unexpectedly. This logging can be turned off or adjusted with configuration settings 'akka.log-dead-letters' and 'akka.log-dead-letters-during-shutdown'.
11:20:17,900 AM [cluster-test-akka.actor.default-dispatcher-12] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1
11:20:17,900 AM [cluster-test-akka.actor.default-dispatcher-12] [DEBUG] ShardManager - Creating Shard member-1-shard-default-config10
11:20:17,900 AM [cluster-test-akka.actor.default-dispatcher-12] [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
11:20:17,900 AM [cluster-test-akka.actor.default-dispatcher-12] [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
11:20:17,900 AM [cluster-test-akka.actor.default-dispatcher-12] [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#754678026]
11:20:17,900 AM [cluster-test-akka.actor.default-dispatcher-12] [DEBUG] ShardManager - shard-manager-config10: Initializing shard [default]
11:20:17,900 AM [cluster-test-akka.actor.default-dispatcher-12] [DEBUG] ShardInformation - Shard member-1-shard-default-config10 is initialized
11:20:17,900 AM [cluster-test-akka.actor.default-dispatcher-12] [INFO] ShardManager - shard-manager-config10: Received LeaderStateChanged message: LeaderStateChanged [memberId=member-1-shard-default-config10, leaderId=member-2-shard-default-config10, leaderPayloadVersion=13]
11:20:17,900 AM [cluster-test-akka.actor.default-dispatcher-12] [INFO] ShardManager - shard-manager-config10: Received role changed for member-1-shard-default-config10 from Candidate to Follower
11:20:17,913 AM [cluster-test-akka.actor.default-dispatcher-10] [INFO] ShardManager - Recovery complete : shard-manager-config10
11:20:17,913 AM [cluster-test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config10: Creating local shard: member-2-shard-default-config10
11:20:17,914 AM [cluster-test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1
11:20:17,914 AM [cluster-test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - Creating Shard member-2-shard-default-config10
11:20:17,914 AM [cluster-test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config10: Initializing shard [default]
11:20:17,914 AM [cluster-test-akka.actor.default-dispatcher-10] [DEBUG] ShardInformation - Shard member-2-shard-default-config10 is initialized
11:20:17,914 AM [cluster-test-akka.actor.default-dispatcher-10] [INFO] ShardManager - shard-manager-config10: Received LeaderStateChanged message: LeaderStateChanged [memberId=member-2-shard-default-config10, leaderId=member-2-shard-default-config10, leaderPayloadVersion=13]
11:20:17,914 AM [cluster-test-akka.actor.default-dispatcher-10] [INFO] ShardManager - shard-manager-config10: Received role changed for member-2-shard-default-config10 from Candidate to Leader
11:20:17,914 AM [cluster-test-akka.actor.default-dispatcher-10] [INFO] ShardManager - shard-manager-config10: All Shards are ready - data store config10 is ready
11:20:17,950 AM [cluster-test-akka.actor.default-dispatcher-12] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2558] - Node [akka://cluster-test@127.0.0.1:2559] is JOINING, roles [member-2, dc-default], version [0.0.0]
11:20:17,956 AM [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]
11:20:17,956 AM [cluster-test-akka.actor.default-dispatcher-5] [INFO] ShardManager - shard-manager-config10: Received MemberUp: memberName: MemberName{name=member-1}, address: akka://cluster-test@127.0.0.1:2558
11:20:17,956 AM [cluster-test-akka.actor.default-dispatcher-5] [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
11:20:17,956 AM [cluster-test-akka.actor.default-dispatcher-5] [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
11:20:17,956 AM [cluster-test-akka.actor.default-dispatcher-5] [INFO] ShardManager - shard-manager-config10: All Shards are ready - data store config10 is ready
11:20:18,790 AM [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:2559] to [Up]
11:20:18,791 AM [cluster-test-akka.actor.default-dispatcher-10] [INFO] ShardManager - shard-manager-config10: Received MemberUp: memberName: MemberName{name=member-2}, address: akka://cluster-test@127.0.0.1:2559
11:20:18,791 AM [cluster-test-akka.actor.default-dispatcher-10] [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
11:20:18,791 AM [cluster-test-akka.actor.default-dispatcher-10] [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
11:20:18,791 AM [cluster-test-akka.actor.default-dispatcher-10] [INFO] ShardManager - shard-manager-config10: All Shards are ready - data store config10 is ready
11:20:18,792 AM [cluster-test-akka.actor.default-dispatcher-12] [DEBUG] ShardManager - shard-manager-config10: In findPrimary: org.opendaylight.controller.cluster.datastore.messages.FindPrimary [shardName=default, waitUntilReady=true]
11:20:18,792 AM [cluster-test-akka.actor.default-dispatcher-12] [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]
11:20:18,793 AM [cluster-test-akka.actor.default-dispatcher-12] [INFO] ShardManager - Received UnreachableMember: memberName MemberName{name=member-2}, address: akka://cluster-test@127.0.0.1:2558
11:20:18,793 AM [cluster-test-akka.actor.default-dispatcher-12] [DEBUG] ShardManager - Marking Leader member-2-shard-default-config10 as unavailable.
11:20:18,793 AM [cluster-test-akka.actor.default-dispatcher-12] [DEBUG] ShardManager - shard-manager-config10: In findPrimary: org.opendaylight.controller.cluster.datastore.messages.FindPrimary [shardName=default, waitUntilReady=true]
11:20:18,794 AM [cluster-test-akka.actor.default-dispatcher-12] [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]
11:20:18,899 AM [cluster-test-akka.actor.default-dispatcher-10] [INFO] ShardManager - shard-manager-config10: Received MemberUp: memberName: MemberName{name=member-2}, address: akka://cluster-test@127.0.0.1:2559
11:20:18,899 AM [cluster-test-akka.actor.default-dispatcher-10] [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
11:20:18,899 AM [cluster-test-akka.actor.default-dispatcher-10] [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
11:20:18,899 AM [cluster-test-akka.actor.default-dispatcher-10] [INFO] ShardManager - shard-manager-config10: All Shards are ready - data store config10 is ready
11:20:20,9 AM [cluster-test-akka.actor.default-dispatcher-12] [DEBUG] ShardManager - shard-manager-config10: Received ShardNotInitializedTimeout message for shard default
11:20:20,9 AM [cluster-test-akka.actor.default-dispatcher-12] [DEBUG] ShardManager - shard-manager-config10: Returning NoShardLeaderException for shard default
11:20:20,9 AM [cluster-test-akka.actor.default-dispatcher-10] [INFO] ShardManager - shard-manager-config10: Received LeaderStateChanged message: LeaderStateChanged [memberId=member-1-shard-default-config10, leaderId=member-1-shard-default-config10, leaderPayloadVersion=13]
11:20:20,9 AM [cluster-test-akka.actor.default-dispatcher-10] [INFO] ShardManager - shard-manager-config10: All Shards are ready - data store config10 is ready
11:20:20,9 AM [cluster-test-akka.actor.default-dispatcher-10] [INFO] ShardManager - shard-manager-config10: Received role changed for member-1-shard-default-config10 from Follower to Leader
11:20:20,9 AM [cluster-test-akka.actor.default-dispatcher-10] [INFO] ShardManager - shard-manager-config10: All Shards are ready - data store config10 is ready
11:20:20,10 AM [cluster-test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config10: In findPrimary: org.opendaylight.controller.cluster.datastore.messages.FindPrimary [shardName=default, waitUntilReady=true]
11:20:20,10 AM [cluster-test-akka.actor.default-dispatcher-10] [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#754678026, localShardDataTree=org.opendaylight.yangtools.yang.data.tree.api.DataTree$MockitoMock$mgMIAwg7@1e595610]
11:20:20,10 AM [main] [INFO] ShardManagerTest - testShardAvailabilityChangeOnMemberUnreachableAndLeadershipChange ending
11:20:20,112 AM [cluster-test-akka.actor.default-dispatcher-13] [INFO] ShardManager - Stopping ShardManager shard-manager-config10
11:20:20,113 AM [cluster-test-akka.actor.default-dispatcher-13] [INFO] RemoteActorRefProvider$RemotingTerminator - Shutting down remote daemon.
11:20:20,113 AM [cluster-test-akka.actor.default-dispatcher-13] [INFO] RemoteActorRefProvider$RemotingTerminator - Remote daemon shut down; proceeding with flushing remote transports.
11:20:20,123 AM [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
11:20:20,124 AM [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
11:20:20,126 AM [cluster-test-akka.actor.default-dispatcher-13] [INFO] RemoteActorRefProvider$RemotingTerminator - Remoting shut down.
11:20:20,142 AM [cluster-test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Stopping ShardManager shard-manager-config10
11:20:20,144 AM [cluster-test-akka.actor.default-dispatcher-10] [INFO] RemoteActorRefProvider$RemotingTerminator - Shutting down remote daemon.
11:20:20,144 AM [cluster-test-akka.actor.default-dispatcher-10] [INFO] RemoteActorRefProvider$RemotingTerminator - Remote daemon shut down; proceeding with flushing remote transports.
11:20:21,163 AM [cluster-test-akka.actor.default-dispatcher-10] [INFO] RemoteActorRefProvider$RemotingTerminator - Remoting shut down.
[WARN] [02/27/2024 11:20:21.165] [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
11:20:21,177 AM [test-akka.actor.default-dispatcher-5] [INFO] ShardManager - Starting ShardManager shard-manager-config11
11:20:21,178 AM [test-akka.actor.default-dispatcher-5] [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'.
11:20:21,180 AM [test-akka.actor.default-dispatcher-5] [INFO] ShardManager - Recovery complete : shard-manager-config11
11:20:21,203 AM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1
11:20:21,203 AM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config11: onAddShardReplica: AddShardReplica[ShardName=astronauts]
11:20:21,205 AM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config11: Sending AddServer message to peer akka://test@127.0.0.1:2565/system/testProbe-552#-1158361296 for shard member-1-shard-astronauts-config11
11:20:21,217 AM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config11: onRemoveShardReplica: RemoveShardReplica [shardName=astronauts, memberName=MemberName{name=member-2}]
11:20:21,218 AM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config11: A shard replica operation for astronauts is already in progress
11:20:21,321 AM [main] [INFO] ShardManagerTest - testPerShardDatastoreContext starting
11:20:21,329 AM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - Starting ShardManager shard-manager-config12
11:20:21,330 AM [test-akka.actor.default-dispatcher-10] [INFO] EmptyLocalActorRef - Message [org.opendaylight.controller.cluster.common.actor.Monitor] from Actor[akka://test/user/$g#1540536135] 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'.
11:20:21,330 AM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - Recovery complete : shard-manager-config12
11:20:21,330 AM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config12: Creating local shard: member-1-shard-default-config12
11:20:21,331 AM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config12: Creating local shard: member-1-shard-topology-config12
11:20:21,339 AM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1
11:20:21,339 AM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - Creating Shard member-1-shard-default-config12
11:20:21,339 AM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - Creating Shard member-1-shard-topology-config12
11:20:21,340 AM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardInformation - Sending new DatastoreContext to member-1-shard-default-config12
11:20:21,340 AM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardInformation - Sending new DatastoreContext to member-1-shard-topology-config12
11:20:21,390 AM [main] [INFO] ShardManagerTest - testPerShardDatastoreContext ending
11:20:21,492 AM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/default1#1785100397]
11:20:21,503 AM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/topology2#1393594808]
11:20:21,503 AM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/$g#1540536135]
11:20:21,503 AM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Stopping ShardManager shard-manager-config12
11:20:21,505 AM [main] [INFO] ShardManagerTest - testOnReceiveFindPrimaryForLocalLeaderShard starting
11:20:21,508 AM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Starting ShardManager shard-manager-config13
11:20:21,510 AM [test-akka.actor.default-dispatcher-5] [INFO] ShardManager - Recovery complete : shard-manager-config13
11:20:21,510 AM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - shard-manager-config13: Creating local shard: member-1-shard-default-config13
11:20:21,519 AM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1
11:20:21,519 AM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - Creating Shard member-1-shard-default-config13
11:20:21,519 AM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config13: Initializing shard [default]
11:20:21,519 AM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardInformation - Shard member-1-shard-default-config13 is initialized
11:20:21,519 AM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - shard-manager-config13: Received LeaderStateChanged message: LeaderStateChanged [memberId=member-1-shard-default-config13, leaderId=member-1-shard-default-config13, leaderPayloadVersion=13]
11:20:21,569 AM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - shard-manager-config13: Received role changed for member-1-shard-default-config13 from Candidate to Leader
11:20:21,569 AM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - shard-manager-config13: All Shards are ready - data store config13 is ready
11:20:21,570 AM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config13: In findPrimary: org.opendaylight.controller.cluster.datastore.messages.FindPrimary [shardName=default, waitUntilReady=false]
11:20:21,570 AM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config13: Found primary for default: LocalPrimaryShardFound [primaryPath=akka://test@127.0.0.1:2565/user/member-1-shard-default-config#-1720407647, localShardDataTree=org.opendaylight.yangtools.yang.data.tree.api.DataTree$MockitoMock$mgMIAwg7@1c9c8728]
11:20:21,570 AM [main] [INFO] ShardManagerTest - testOnReceiveFindPrimaryForLocalLeaderShard ending
11:20:21,672 AM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/$h#-1273047582]
11:20:21,683 AM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - Stopping ShardManager shard-manager-config13
11:20:21,685 AM [main] [INFO] ShardManagerTest - testShardAvailabilityChangeOnMemberWithNameContainedInLeaderIdUnreachable starting
11:20:21,693 AM [cluster-test-akka.actor.default-dispatcher-5] [INFO] Slf4jLogger - Slf4jLogger started
11:20:21,703 AM [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 [2416791561743792825]
11:20:21,703 AM [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] ...
11:20:21,703 AM [cluster-test-akka.actor.default-dispatcher-5] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2562] - Registered cluster JMX MBean [akka:type=Cluster]
11:20:21,703 AM [cluster-test-akka.actor.default-dispatcher-5] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2562] - Started up successfully
11:20:21,705 AM [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
11:20:21,705 AM [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
11:20:21,715 AM [cluster-test-akka.actor.default-dispatcher-5] [INFO] ShardManager - Starting ShardManager shard-manager-config14
11:20:21,715 AM [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:2562] is JOINING itself (with roles [member-256, dc-default], version [0.0.0]) and forming new cluster
11:20:21,715 AM [cluster-test-akka.actor.default-dispatcher-10] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2562] - is the new leader among reachable nodes (more leaders may exist)
11:20:21,715 AM [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:2562] to [Up]
11:20:21,715 AM [cluster-test-akka.actor.default-dispatcher-10] [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'.
11:20:21,722 AM [cluster-test-akka.actor.default-dispatcher-6] [INFO] Slf4jLogger - Slf4jLogger started
11:20:21,727 AM [cluster-test-akka.actor.default-dispatcher-5] [INFO] ShardManager - Recovery complete : shard-manager-config14
11:20:21,727 AM [cluster-test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - shard-manager-config14: Creating local shard: member-256-shard-default-config14
11:20:21,728 AM [cluster-test-akka.actor.default-dispatcher-5] [INFO] ShardManager - shard-manager-config14: Received MemberUp: memberName: MemberName{name=member-256}, address: akka://cluster-test@127.0.0.1:2562
11:20:21,728 AM [cluster-test-akka.actor.default-dispatcher-5] [INFO] ShardInformation - updatePeerAddress for peer member-256-shard-default-config14 with address akka://cluster-test@127.0.0.1:2562/user/shardmanager-config14/member-256-shard-default-config14
11:20:21,729 AM [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 [-1027733660455983424]
11:20:21,729 AM [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] ...
11:20:21,731 AM [cluster-test-akka.actor.default-dispatcher-10] [WARN] Cluster - Could not register Cluster JMX MBean with name=akka:type=Cluster as it is already registered. If you are running multiple clusters in the same JVM, set 'akka.cluster.jmx.multi-mbeans-in-same-jvm = on' in config
11:20:21,731 AM [cluster-test-akka.actor.default-dispatcher-10] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2559] - Started up successfully
11:20:21,732 AM [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
11:20:21,732 AM [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
11:20:21,744 AM [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'.
11:20:21,747 AM [cluster-test-akka.actor.default-dispatcher-6] [INFO] ShardManager - Starting ShardManager shard-manager-config14
11:20:21,750 AM [cluster-test-akka.actor.default-dispatcher-10] [INFO] ShardManager - Recovery complete : shard-manager-config14
11:20:21,751 AM [cluster-test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config14: Creating local shard: member-2-shard-default-config14
11:20:21,752 AM [cluster-test-akka.actor.default-dispatcher-12] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1
11:20:21,752 AM [cluster-test-akka.actor.default-dispatcher-12] [DEBUG] ShardManager - Creating Shard member-256-shard-default-config14
11:20:21,752 AM [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
11:20:21,752 AM [cluster-test-akka.actor.default-dispatcher-12] [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
11:20:21,752 AM [cluster-test-akka.actor.default-dispatcher-12] [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#1231549275]
11:20:21,753 AM [cluster-test-akka.actor.default-dispatcher-12] [DEBUG] ShardManager - shard-manager-config14: Initializing shard [default]
11:20:21,753 AM [cluster-test-akka.actor.default-dispatcher-12] [DEBUG] ShardInformation - Shard member-256-shard-default-config14 is initialized
11:20:21,753 AM [cluster-test-akka.actor.default-dispatcher-12] [INFO] ShardManager - shard-manager-config14: Received LeaderStateChanged message: LeaderStateChanged [memberId=member-256-shard-default-config14, leaderId=member-256-shard-default-config14, leaderPayloadVersion=13]
11:20:21,753 AM [cluster-test-akka.actor.default-dispatcher-12] [INFO] ShardManager - shard-manager-config14: Received role changed for member-256-shard-default-config14 from Candidate to Leader
11:20:21,753 AM [cluster-test-akka.actor.default-dispatcher-12] [INFO] ShardManager - shard-manager-config14: All Shards are ready - data store config14 is ready
11:20:21,753 AM [cluster-test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1
11:20:21,753 AM [cluster-test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - Creating Shard member-2-shard-default-config14
11:20:21,753 AM [cluster-test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config14: Initializing shard [default]
11:20:21,753 AM [cluster-test-akka.actor.default-dispatcher-11] [DEBUG] ShardInformation - Shard member-2-shard-default-config14 is initialized
11:20:21,753 AM [cluster-test-akka.actor.default-dispatcher-11] [INFO] ShardManager - shard-manager-config14: Received LeaderStateChanged message: LeaderStateChanged [memberId=member-2-shard-default-config14, leaderId=member-256-shard-default-config14, leaderPayloadVersion=13]
11:20:21,753 AM [cluster-test-akka.actor.default-dispatcher-11] [INFO] ShardManager - shard-manager-config14: Received role changed for member-2-shard-default-config14 from Candidate to Follower
11:20:21,795 AM [cluster-test-akka.actor.default-dispatcher-12] [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]
11:20:21,799 AM [cluster-test-akka.actor.default-dispatcher-6] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2559] - Welcome from [akka://cluster-test@127.0.0.1:2562]
11:20:21,799 AM [cluster-test-akka.actor.default-dispatcher-6] [INFO] ShardManager - shard-manager-config14: Received MemberUp: memberName: MemberName{name=member-256}, address: akka://cluster-test@127.0.0.1:2562
11:20:21,799 AM [cluster-test-akka.actor.default-dispatcher-6] [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
11:20:21,799 AM [cluster-test-akka.actor.default-dispatcher-6] [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
11:20:21,800 AM [cluster-test-akka.actor.default-dispatcher-6] [INFO] ShardManager - shard-manager-config14: All Shards are ready - data store config14 is ready
11:20:22,722 AM [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:2559] to [Up]
11:20:22,722 AM [cluster-test-akka.actor.default-dispatcher-5] [INFO] ShardManager - shard-manager-config14: Received MemberUp: memberName: MemberName{name=member-2}, address: akka://cluster-test@127.0.0.1:2559
11:20:22,722 AM [cluster-test-akka.actor.default-dispatcher-5] [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
11:20:22,722 AM [cluster-test-akka.actor.default-dispatcher-5] [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
11:20:22,722 AM [cluster-test-akka.actor.default-dispatcher-5] [INFO] ShardManager - shard-manager-config14: All Shards are ready - data store config14 is ready
11:20:22,723 AM [cluster-test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config14: In findPrimary: org.opendaylight.controller.cluster.datastore.messages.FindPrimary [shardName=default, waitUntilReady=true]
11:20:22,723 AM [cluster-test-akka.actor.default-dispatcher-10] [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#1231549275, localShardDataTree=org.opendaylight.yangtools.yang.data.tree.api.DataTree$MockitoMock$mgMIAwg7@4aeedd58]
11:20:22,724 AM [cluster-test-akka.actor.default-dispatcher-10] [INFO] ShardManager - Received UnreachableMember: memberName MemberName{name=member-2}, address: akka://cluster-test@127.0.0.1:2558
11:20:22,724 AM [cluster-test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config14: In findPrimary: org.opendaylight.controller.cluster.datastore.messages.FindPrimary [shardName=default, waitUntilReady=true]
11:20:22,724 AM [cluster-test-akka.actor.default-dispatcher-10] [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#1231549275, localShardDataTree=org.opendaylight.yangtools.yang.data.tree.api.DataTree$MockitoMock$mgMIAwg7@4aeedd58]
11:20:22,725 AM [main] [INFO] ShardManagerTest - testShardAvailabilityChangeOnMemberWithNameContainedInLeaderIdUnreachable ending
11:20:22,758 AM [cluster-test-akka.actor.default-dispatcher-6] [INFO] ShardManager - shard-manager-config14: Received MemberUp: memberName: MemberName{name=member-2}, address: akka://cluster-test@127.0.0.1:2559
11:20:22,758 AM [cluster-test-akka.actor.default-dispatcher-6] [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
11:20:22,758 AM [cluster-test-akka.actor.default-dispatcher-6] [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
11:20:22,758 AM [cluster-test-akka.actor.default-dispatcher-6] [INFO] ShardManager - shard-manager-config14: All Shards are ready - data store config14 is ready
11:20:22,827 AM [cluster-test-akka.actor.default-dispatcher-12] [INFO] ShardManager - Stopping ShardManager shard-manager-config14
11:20:22,828 AM [cluster-test-akka.actor.default-dispatcher-5] [INFO] RemoteActorRefProvider$RemotingTerminator - Shutting down remote daemon.
11:20:22,828 AM [cluster-test-akka.actor.default-dispatcher-5] [INFO] RemoteActorRefProvider$RemotingTerminator - Remote daemon shut down; proceeding with flushing remote transports.
11:20:22,835 AM [cluster-test-akka.actor.default-dispatcher-5] [WARN] Materializer - [outbound connection to [akka://cluster-test@127.0.0.1:2559], control stream] Upstream failed, cause: StreamTcpException: The connection has been aborted
11:20:22,835 AM [cluster-test-akka.actor.default-dispatcher-5] [WARN] Materializer - [outbound connection to [akka://cluster-test@127.0.0.1:2559], message stream] Upstream failed, cause: StreamTcpException: The connection has been aborted
11:20:22,883 AM [cluster-test-akka.actor.default-dispatcher-6] [INFO] ShardManager - Stopping ShardManager shard-manager-config14
11:20:22,884 AM [cluster-test-akka.actor.default-dispatcher-10] [INFO] RemoteActorRefProvider$RemotingTerminator - Shutting down remote daemon.
11:20:22,884 AM [cluster-test-akka.actor.default-dispatcher-10] [INFO] RemoteActorRefProvider$RemotingTerminator - Remote daemon shut down; proceeding with flushing remote transports.
11:20:23,769 AM [cluster-test-akka.actor.default-dispatcher-11] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2559] - is the new leader among reachable nodes (more leaders may exist)
11:20:23,900 AM [cluster-test-akka.actor.default-dispatcher-11] [INFO] RemoteActorRefProvider$RemotingTerminator - Remoting shut down.
[WARN] [02/27/2024 11:20:23.901] [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
11:20:23,914 AM [main] [INFO] ShardManager - Starting ShardManager shard-manager-config15
11:20:23,915 AM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - Recovery complete : shard-manager-config15
11:20:23,915 AM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config15: Creating local shard: member-1-shard-default-config15
11:20:23,920 AM [main] [INFO] ShardManager - shard-manager-config15: Received role changed for member-1-shard-default-config15 from Follower to Leader
11:20:24,21 AM [main] [INFO] TestActorFactory - Killing actor TestActor[akka://test/user/$$i]
11:20:24,32 AM [main] [INFO] ShardManager - Stopping ShardManager shard-manager-config15
11:20:24,37 AM [main] [INFO] ShardManager - Starting ShardManager shard-manager-config16
11:20:24,38 AM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Recovery complete : shard-manager-config16
11:20:24,38 AM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config16: Creating local shard: member-1-shard-default-config16
11:20:24,39 AM [main] [INFO] ShardManager - shard-manager-config16: Received role changed for member-1-shard-default-config16 from Candidate to Leader
11:20:24,39 AM [main] [INFO] ShardManager - shard-manager-config16: Received LeaderStateChanged message: LeaderStateChanged [memberId=member-1-shard-default-config16, leaderId=member-1-shard-default-config16, leaderPayloadVersion=13]
11:20:24,39 AM [main] [INFO] ShardManager - shard-manager-config16: All Shards are ready - data store config16 is ready
11:20:24,141 AM [main] [INFO] TestActorFactory - Killing actor TestActor[akka://test/user/$$j]
11:20:24,151 AM [main] [INFO] ShardManager - Stopping ShardManager shard-manager-config16
11:20:24,154 AM [main] [INFO] ShardManagerTest - testOnCreateShardWithLocalMemberNotInShardConfig starting
11:20:24,156 AM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - Starting ShardManager shard-manager-config17
11:20:24,157 AM [test-akka.actor.default-dispatcher-5] [INFO] ShardManager - Recovery complete : shard-manager-config17
11:20:24,158 AM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1
11:20:24,171 AM [test-akka.actor.default-dispatcher-10] [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@769306a9]
11:20:24,172 AM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config17 doCreateShard: shardId: member-1-shard-foo-config17, memberNames: [MemberName{name=member-5}, MemberName{name=member-6}], peerAddresses: {}, isActiveMember: false
11:20:24,174 AM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config17: findLocalShard : foo
11:20:24,174 AM [test-akka.actor.default-dispatcher-10] [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]
11:20:24,175 AM [test-shard-dispatcher-15] [INFO] Shard - Shard created : member-1-shard-foo-config17, persistent : true
11:20:24,178 AM [test-shard-dispatcher-15] [INFO] Shard - Starting recovery for member-1-shard-foo-config17 with journal batch size 1
11:20:24,179 AM [test-akka.actor.default-dispatcher-10] [INFO] RoleChangeNotifier - RoleChangeNotifier:akka://test@127.0.0.1:2565/user/$i/member-1-shard-foo-config17/member-1-shard-foo-config17-notifier#-2096665945 created and ready for shard:member-1-shard-foo-config17
11:20:24,179 AM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardSnapshotActor - Actor created Actor[akka://test/user/$i/member-1-shard-foo-config17/shard-member-1:snapshot-read#1733973276]
11:20:24,180 AM [test-shard-dispatcher-15] [DEBUG] Shard - member-1-shard-foo-config17: onReceiveRecover: Received message class akka.persistence.RecoveryCompleted$ from Actor[akka://test/deadLetters]
11:20:24,180 AM [test-shard-dispatcher-15] [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
11:20:24,180 AM [test-shard-dispatcher-15] [DEBUG] DataTreeChangeListenerSupport - member-1-shard-foo-config17: onLeadershipChange, isLeader: false, hasLeader : false
11:20:24,180 AM [test-shard-dispatcher-15] [DEBUG] Shard - member-1-shard-foo-config17: onStateChanged: Closing all transaction chains because shard member-1-shard-foo-config17 is no longer the leader
11:20:24,180 AM [test-shard-dispatcher-15] [INFO] DefaultConfigParamsImpl - Trying to use custom RaftPolicy org.opendaylight.controller.cluster.raft.policy.DisableElectionsRaftPolicy
11:20:24,180 AM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - shard-manager-config17: Initializing shard [foo]
11:20:24,180 AM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardInformation - Shard member-1-shard-foo-config17 is initialized
11:20:24,180 AM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardInformation - Shard member-1-shard-foo-config17 is initialized - notifying 1 OnShardInitialized callbacks
11:20:24,181 AM [main] [INFO] ShardManagerTest - testOnCreateShardWithLocalMemberNotInShardConfig ending
11:20:24,181 AM [test-akka.actor.default-dispatcher-11] [INFO] RoleChangeNotifier - RoleChangeNotifier for member-1-shard-foo-config17 , received role change from null to Follower
11:20:24,181 AM [test-akka.actor.default-dispatcher-16] [INFO] RoleChangeNotifier - RoleChangeNotifier for member-1-shard-foo-config17 , registered listener akka://test/user/$i
11:20:24,181 AM [test-akka.actor.default-dispatcher-16] [INFO] ShardManager - shard-manager-config17: Received role changed for member-1-shard-foo-config17 from null to Follower
11:20:24,282 AM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/$i#1055161440]
11:20:24,293 AM [test-shard-dispatcher-15] [INFO] Shard - Stopping Shard member-1-shard-foo-config17
11:20:24,293 AM [test-shard-dispatcher-15] [DEBUG] MessageAssembler - member-1-shard-foo-config17 (Follower): Closing
11:20:24,293 AM [test-shard-dispatcher-15] [DEBUG] Shard - member-1-shard-foo-config17: Aborting 0 pending queued transactions
11:20:24,294 AM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Stopping ShardManager shard-manager-config17
11:20:24,296 AM [main] [INFO] ShardManagerTest - testServerRemovedShardActorNotRunning starting
11:20:24,299 AM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Starting ShardManager shard-manager-config18
11:20:24,300 AM [test-akka.actor.default-dispatcher-16] [INFO] ShardManager - Recovery complete : shard-manager-config18
11:20:24,300 AM [test-akka.actor.default-dispatcher-16] [DEBUG] ShardManager - shard-manager-config18: Creating local shard: member-1-shard-default-config18
11:20:24,300 AM [test-akka.actor.default-dispatcher-16] [DEBUG] ShardManager - shard-manager-config18: Creating local shard: member-1-shard-people-config18
11:20:24,409 AM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config18: findLocalShard : people
11:20:24,409 AM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config18: Returning NotInitializedException for shard people
11:20:24,410 AM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config18: findLocalShard : default
11:20:24,410 AM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config18: Returning NotInitializedException for shard default
11:20:24,412 AM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config18 : Local Shard replica for shard default has been removed
11:20:24,412 AM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config18: persisting the shard list [people]
11:20:24,412 AM [main] [INFO] ShardManagerTest - testServerRemovedShardActorNotRunning ending
11:20:24,420 AM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config18 saved ShardManager snapshot successfully. Deleting the prev snapshot if available
11:20:24,426 AM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config18: Successfully deleted prior snapshots
11:20:24,514 AM [main] [INFO] TestActorFactory - Killing actor TestActor[akka://test/user/$$k]
11:20:24,524 AM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Stopping ShardManager shard-manager-config18
11:20:24,529 AM [test-akka.actor.default-dispatcher-14] [INFO] ShardManager - Starting ShardManager shard-manager-config19
11:20:24,532 AM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Recovery complete : shard-manager-config19
11:20:24,532 AM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config19: Creating local shard: member-1-shard-default-config19
11:20:24,540 AM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1
11:20:24,540 AM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - Creating Shard member-1-shard-default-config19
11:20:24,540 AM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - shard-manager-config19: Initializing shard [default]
11:20:24,540 AM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardInformation - Shard member-1-shard-default-config19 is initialized
11:20:24,540 AM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - shard-manager-config19: In findPrimary: org.opendaylight.controller.cluster.datastore.messages.FindPrimary [shardName=default, waitUntilReady=false]
11:20:24,540 AM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - shard-manager-config19: Returning NoShardLeaderException for shard default
11:20:24,641 AM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/$j#-1224148011]
11:20:24,652 AM [test-akka.actor.default-dispatcher-14] [INFO] ShardManager - Stopping ShardManager shard-manager-config19
11:20:24,654 AM [main] [INFO] ShardManagerTest - testOnReceiveFindPrimaryForFollowerShardWithNoInitialLeaderId starting
11:20:24,663 AM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Starting ShardManager shard-manager-config20
11:20:24,664 AM [test-akka.actor.default-dispatcher-14] [INFO] ShardManager - Recovery complete : shard-manager-config20
11:20:24,664 AM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - shard-manager-config20: Creating local shard: member-1-shard-default-config20
11:20:24,674 AM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1
11:20:24,674 AM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - Creating Shard member-1-shard-default-config20
11:20:24,674 AM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config20: Initializing shard [default]
11:20:24,674 AM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardInformation - Shard member-1-shard-default-config20 is initialized
11:20:24,674 AM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - shard-manager-config20: Received role changed for member-1-shard-default-config20 from Candidate to Follower
11:20:24,674 AM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config20: In findPrimary: org.opendaylight.controller.cluster.datastore.messages.FindPrimary [shardName=default, waitUntilReady=false]
11:20:24,674 AM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config20: Returning NoShardLeaderException for shard default
11:20:24,675 AM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - shard-manager-config20: Received LeaderStateChanged message: LeaderStateChanged [memberId=member-1-shard-default-config20, leaderId=member-1-shard-default-config20, leaderPayloadVersion=13]
11:20:24,675 AM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - shard-manager-config20: All Shards are ready - data store config20 is ready
11:20:24,675 AM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config20: In findPrimary: org.opendaylight.controller.cluster.datastore.messages.FindPrimary [shardName=default, waitUntilReady=false]
11:20:24,675 AM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config20: Found primary for default: LocalPrimaryShardFound [primaryPath=akka://test@127.0.0.1:2565/user/member-1-shard-default-config#-650615970, localShardDataTree=org.opendaylight.yangtools.yang.data.tree.api.DataTree$MockitoMock$mgMIAwg7@55f8b449]
11:20:24,675 AM [main] [INFO] ShardManagerTest - testOnReceiveFindPrimaryForFollowerShardWithNoInitialLeaderId starting
11:20:24,777 AM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/$k#-1389169701]
11:20:24,788 AM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Stopping ShardManager shard-manager-config20
11:20:24,792 AM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Starting ShardManager shard-manager-config21
11:20:24,793 AM [test-akka.actor.default-dispatcher-14] [INFO] ShardManager - Recovery complete : shard-manager-config21
11:20:24,813 AM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1
11:20:24,813 AM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config21: onAddShardReplica: AddShardReplica[ShardName=astronauts]
11:20:24,814 AM [test-akka.actor.default-dispatcher-16] [DEBUG] ShardManager - shard-manager-config21: Sending AddServer message to peer akka://test@127.0.0.1:2565/system/testProbe-570#1237479309 for shard member-1-shard-astronauts-config21
11:20:24,825 AM [test-akka.actor.default-dispatcher-16] [DEBUG] ShardManager - shard-manager-config21: onAddShardReplica: AddShardReplica[ShardName=astronauts]
11:20:24,825 AM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config21: A shard replica operation for astronauts is already in progress
11:20:24,929 AM [main] [INFO] ShardManagerTest - testOnReceiveFindPrimaryWaitForReadyWithCandidateShard starting
11:20:24,935 AM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Starting ShardManager shard-manager-config22
11:20:24,936 AM [test-akka.actor.default-dispatcher-16] [INFO] ShardManager - Recovery complete : shard-manager-config22
11:20:24,936 AM [test-akka.actor.default-dispatcher-16] [DEBUG] ShardManager - shard-manager-config22: Creating local shard: member-1-shard-default-config22
11:20:24,945 AM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1
11:20:24,945 AM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - Creating Shard member-1-shard-default-config22
11:20:24,946 AM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config22: Initializing shard [default]
11:20:24,946 AM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardInformation - Shard member-1-shard-default-config22 is initialized
11:20:24,946 AM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - shard-manager-config22: Received role changed for member-1-shard-default-config22 from null to Candidate
11:20:24,946 AM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config22: In findPrimary: org.opendaylight.controller.cluster.datastore.messages.FindPrimary [shardName=default, waitUntilReady=true]
11:20:24,946 AM [test-akka.actor.default-dispatcher-11] [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]
11:20:26,163 AM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config22: Received ShardNotInitializedTimeout message for shard default
11:20:26,163 AM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config22: Returning NoShardLeaderException for shard default
11:20:26,163 AM [main] [INFO] ShardManagerTest - testOnReceiveFindPrimaryWaitForReadyWithCandidateShard ending
11:20:26,265 AM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/$l#255377700]
11:20:26,276 AM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Stopping ShardManager shard-manager-config22
11:20:26,278 AM [main] [INFO] ShardManagerTest - testAddShardReplicaWithAddServerReplyFailure starting
11:20:26,281 AM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Starting ShardManager shard-manager-config23
11:20:26,282 AM [test-akka.actor.default-dispatcher-16] [INFO] ShardManager - Recovery complete : shard-manager-config23
11:20:26,302 AM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1
11:20:26,313 AM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config23: onAddShardReplica: AddShardReplica[ShardName=astronauts]
11:20:26,314 AM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - shard-manager-config23: Sending AddServer message to peer akka://test@127.0.0.1:2565/system/testProbe-575#-1127663253 for shard member-1-shard-astronauts-config23
11:20:26,315 AM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - shard-manager-config23: Received AddServerReply{status=TIMEOUT} for shard astronauts from leader akka://test@127.0.0.1:2565/system/testProbe-575#-1127663253
11:20:26,315 AM [test-akka.actor.default-dispatcher-14] [WARN] ShardManager - shard-manager-config23: Leader failed to add shard replica astronauts with status TIMEOUT
11:20:26,316 AM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config23: findLocalShard : astronauts
11:20:26,316 AM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config23: Local shard astronauts not found - shards present: []
11:20:26,316 AM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config23: onAddShardReplica: AddShardReplica[ShardName=astronauts]
11:20:26,316 AM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - shard-manager-config23: Sending AddServer message to peer akka://test@127.0.0.1:2565/system/testProbe-575#-1127663253 for shard member-1-shard-astronauts-config23
11:20:26,319 AM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - shard-manager-config23: Received AddServerReply{status=NO_LEADER} for shard astronauts from leader akka://test@127.0.0.1:2565/system/testProbe-575#-1127663253
11:20:26,319 AM [test-akka.actor.default-dispatcher-14] [WARN] ShardManager - shard-manager-config23: Leader failed to add shard replica astronauts with status NO_LEADER
11:20:26,320 AM [main] [INFO] ShardManagerTest - testAddShardReplicaWithAddServerReplyFailure ending
11:20:26,421 AM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/member-1-shard-astronauts-config#875336486]
11:20:26,431 AM [main] [INFO] TestActorFactory - Killing actor TestActor[akka://test/user/shardmanager-config23]
11:20:26,432 AM [test-akka.actor.default-dispatcher-14] [INFO] ShardManager - Stopping ShardManager shard-manager-config23
11:20:26,436 AM [main] [INFO] ShardManager - Starting ShardManager shard-manager-config24
11:20:26,438 AM [test-akka.actor.default-dispatcher-14] [INFO] ShardManager - Recovery complete : shard-manager-config24
11:20:26,438 AM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - shard-manager-config24: Creating local shard: member-1-shard-default-config24
11:20:26,537 AM [main] [INFO] ShardManager - shard-manager-config24: Received role changed for member-1-shard-default-config24 from Candidate to Follower
11:20:26,537 AM [main] [INFO] ShardManager - shard-manager-config24 Received follower initial sync status for member-1-shard-default-config24 status sync done true
11:20:26,537 AM [main] [INFO] ShardManager - shard-manager-config24 Received follower initial sync status for member-1-shard-default-config24 status sync done false
11:20:26,638 AM [main] [INFO] TestActorFactory - Killing actor TestActor[akka://test/user/$$l]
11:20:26,649 AM [main] [INFO] ShardManager - Stopping ShardManager shard-manager-config24
11:20:26,653 AM [main] [INFO] ShardManager - Starting ShardManager shard-manager-config25
11:20:26,655 AM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Recovery complete : shard-manager-config25
11:20:26,655 AM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config25: Creating local shard: member-1-shard-default-config25
11:20:26,655 AM [main] [INFO] ShardManager - shard-manager-config25: Received role changed for unknown from Candidate to Leader
11:20:26,757 AM [main] [INFO] TestActorFactory - Killing actor TestActor[akka://test/user/$$m]
11:20:26,768 AM [main] [INFO] ShardManager - Stopping ShardManager shard-manager-config25
11:20:26,770 AM [main] [INFO] ShardManagerTest - testOnReceiveFindPrimaryWaitForReadyWithUninitializedShard starting
11:20:26,773 AM [test-akka.actor.default-dispatcher-14] [INFO] ShardManager - Starting ShardManager shard-manager-config26
11:20:26,775 AM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Recovery complete : shard-manager-config26
11:20:26,775 AM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config26: Creating local shard: member-1-shard-default-config26
11:20:26,784 AM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1
11:20:26,784 AM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - Creating Shard member-1-shard-default-config26
11:20:26,784 AM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - shard-manager-config26: In findPrimary: org.opendaylight.controller.cluster.datastore.messages.FindPrimary [shardName=default, waitUntilReady=true]
11:20:26,784 AM [test-akka.actor.default-dispatcher-14] [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]
11:20:27,402 AM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - shard-manager-config26: Received ShardNotInitializedTimeout message for shard default
11:20:27,402 AM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - shard-manager-config26: Returning NotInitializedException for shard default
11:20:27,403 AM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - shard-manager-config26: Initializing shard [default]
11:20:27,403 AM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardInformation - Shard member-1-shard-default-config26 is initialized
11:20:27,603 AM [main] [INFO] ShardManagerTest - testOnReceiveFindPrimaryWaitForReadyWithUninitializedShard ending
11:20:27,704 AM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/$m#-2048156684]
11:20:27,715 AM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Stopping ShardManager shard-manager-config26
11:20:27,718 AM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Starting ShardManager shard-manager-config27
11:20:27,719 AM [test-akka.actor.default-dispatcher-14] [INFO] ShardManager - Recovery complete : shard-manager-config27
11:20:27,719 AM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - shard-manager-config27: Creating local shard: member-1-shard-default-config27
11:20:27,729 AM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1
11:20:27,729 AM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - Creating Shard member-1-shard-default-config27
11:20:27,729 AM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config27: Initializing shard [default]
11:20:27,729 AM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardInformation - Shard member-1-shard-default-config27 is initialized
11:20:27,729 AM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config27: findLocalShard : default
11:20:27,831 AM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/$n#965207762]
11:20:27,841 AM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Stopping ShardManager shard-manager-config27
11:20:27,844 AM [main] [INFO] ShardManagerTest - testRegisterForShardLeaderChanges starting
11:20:27,846 AM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Starting ShardManager shard-manager-config28
11:20:27,848 AM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Recovery complete : shard-manager-config28
11:20:27,848 AM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config28: Creating local shard: member-1-shard-default-config28
11:20:27,857 AM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1
11:20:27,857 AM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - Creating Shard member-1-shard-default-config28
11:20:27,857 AM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config28: Initializing shard [default]
11:20:27,857 AM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardInformation - Shard member-1-shard-default-config28 is initialized
11:20:27,857 AM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config28: onRegisterForShardAvailabilityChanges: org.opendaylight.controller.cluster.datastore.shardmanager.RegisterForShardAvailabilityChanges@7471a3ad
11:20:27,859 AM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - shard-manager-config28: Received LeaderStateChanged message: LeaderStateChanged [memberId=member-1-shard-default-config28, leaderId=member-1-shard-default-config28, leaderPayloadVersion=13]
11:20:27,875 AM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - shard-manager-config28: Received LeaderStateChanged message: LeaderStateChanged [memberId=member-1-shard-default-config28, leaderId=member-1-shard-default-config28, leaderPayloadVersion=13]
11:20:28,375 AM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - shard-manager-config28: Received LeaderStateChanged message: LeaderStateChanged [memberId=member-1-shard-default-config28, leaderId=null, leaderPayloadVersion=13]
11:20:28,386 AM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - shard-manager-config28: Received LeaderStateChanged message: LeaderStateChanged [memberId=member-1-shard-default-config28, leaderId=member-2-shard-default-config28, leaderPayloadVersion=13]
11:20:28,398 AM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - shard-manager-config28: Received LeaderStateChanged message: LeaderStateChanged [memberId=member-1-shard-default-config28, leaderId=member-1-shard-default-config28, leaderPayloadVersion=13]
11:20:28,898 AM [main] [INFO] ShardManagerTest - testRegisterForShardLeaderChanges ending
11:20:28,999 AM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/$o#-679611843]
11:20:29,10 AM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Stopping ShardManager shard-manager-config28
11:20:29,14 AM [main] [INFO] ShardManager - Starting ShardManager shard-manager-config29
11:20:29,16 AM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Recovery complete : shard-manager-config29
11:20:29,16 AM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config29: Creating local shard: member-1-shard-default-config29
11:20:29,217 AM [main] [INFO] TestActorFactory - Killing actor TestActor[akka://test/user/$$n]
11:20:29,227 AM [main] [INFO] ShardManager - Stopping ShardManager shard-manager-config29
11:20:29,231 AM [test-akka.actor.default-dispatcher-14] [INFO] ShardManager - Starting ShardManager shard-manager-config30
11:20:29,232 AM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Recovery complete : shard-manager-config30
11:20:29,233 AM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config30: Creating local shard: member-1-shard-default-config30
11:20:29,242 AM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1
11:20:29,242 AM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - Creating Shard member-1-shard-default-config30
11:20:29,242 AM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - shard-manager-config30: In findPrimary: org.opendaylight.controller.cluster.datastore.messages.FindPrimary [shardName=non-existent, waitUntilReady=false]
11:20:29,242 AM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - shard-manager-config30: No shard found for non-existent
11:20:29,343 AM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/$p#-1164932464]
11:20:29,354 AM [test-akka.actor.default-dispatcher-14] [INFO] ShardManager - Stopping ShardManager shard-manager-config30
11:20:29,358 AM [test-akka.actor.default-dispatcher-14] [INFO] ShardManager - Starting ShardManager shard-manager-config31
11:20:29,359 AM [test-akka.actor.default-dispatcher-14] [INFO] ShardManager - Recovery complete : shard-manager-config31
11:20:29,369 AM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config31: onAddShardReplica: AddShardReplica[ShardName=model-inventory]
11:20:29,369 AM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config31: No module configuration exists for shard model-inventory
11:20:29,470 AM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/$q#205305340]
11:20:29,481 AM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Stopping ShardManager shard-manager-config31
11:20:29,483 AM [main] [INFO] ShardManagerTest - testAddShardReplicaWithPreExistingReplicaInRemoteShardLeader starting
11:20:29,485 AM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Starting ShardManager shard-manager-config32
11:20:29,487 AM [test-akka.actor.default-dispatcher-16] [INFO] ShardManager - Recovery complete : shard-manager-config32
11:20:29,487 AM [test-akka.actor.default-dispatcher-16] [DEBUG] ShardManager - shard-manager-config32: Creating local shard: member-1-shard-default-config32
11:20:29,496 AM [test-akka.actor.default-dispatcher-16] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1
11:20:29,496 AM [test-akka.actor.default-dispatcher-16] [DEBUG] ShardManager - Creating Shard member-1-shard-default-config32
11:20:29,496 AM [test-akka.actor.default-dispatcher-16] [DEBUG] ShardManager - shard-manager-config32: Initializing shard [default]
11:20:29,496 AM [test-akka.actor.default-dispatcher-16] [DEBUG] ShardInformation - Shard member-1-shard-default-config32 is initialized
11:20:29,496 AM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - shard-manager-config32: Received MemberUp: memberName: MemberName{name=leader-member}, address: akka://test
11:20:29,497 AM [test-akka.actor.default-dispatcher-11] [INFO] ShardInformation - updatePeerAddress for peer leader-member-shard-default-config32 with address akka://test/user/shardmanager-config32/leader-member-shard-default-config32
11:20:29,497 AM [test-akka.actor.default-dispatcher-11] [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
11:20:29,497 AM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - shard-manager-config32: Received role changed for member-1-shard-default-config32 from Candidate to Follower
11:20:29,497 AM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - shard-manager-config32: Received LeaderStateChanged message: LeaderStateChanged [memberId=member-1-shard-default-config32, leaderId=leader-member-shard-default-config32, leaderPayloadVersion=13]
11:20:29,497 AM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - shard-manager-config32: All Shards are ready - data store config32 is ready
11:20:29,497 AM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config32: onAddShardReplica: AddShardReplica[ShardName=default]
11:20:29,497 AM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config32: In findPrimary: org.opendaylight.controller.cluster.datastore.messages.FindPrimary [shardName=default, waitUntilReady=true]
11:20:29,498 AM [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]
11:20:29,498 AM [test-akka.actor.default-dispatcher-11] [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
11:20:29,498 AM [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
11:20:29,498 AM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config32: Local shard default already exists
11:20:29,547 AM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config32: findLocalShard : default
11:20:29,548 AM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config32: onAddShardReplica: AddShardReplica[ShardName=default]
11:20:29,548 AM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config32: In findPrimary: org.opendaylight.controller.cluster.datastore.messages.FindPrimary [shardName=default, waitUntilReady=true]
11:20:29,548 AM [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]
11:20:29,548 AM [test-akka.actor.default-dispatcher-11] [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
11:20:29,549 AM [test-akka.actor.default-dispatcher-11] [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
11:20:29,549 AM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config32: Local shard default already exists
11:20:29,550 AM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardInformation - Sending new DatastoreContext to member-1-shard-default-config32
11:20:29,550 AM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config32: onAddShardReplica: AddShardReplica[ShardName=default]
11:20:29,550 AM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config32: In findPrimary: org.opendaylight.controller.cluster.datastore.messages.FindPrimary [shardName=default, waitUntilReady=true]
11:20:29,550 AM [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]
11:20:29,550 AM [test-akka.actor.default-dispatcher-11] [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
11:20:29,662 AM [test-akka.actor.default-dispatcher-5] [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.
11:20:29,663 AM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - shard-manager-config32: findLocalShard : default
11:20:29,663 AM [main] [INFO] ShardManagerTest - testAddShardReplicaWithPreExistingReplicaInRemoteShardLeader ending
11:20:29,764 AM [main] [INFO] TestActorFactory - Killing actor TestActor[akka://test/user/shardmanager-config32]
11:20:29,776 AM [test-akka.actor.default-dispatcher-5] [INFO] ShardManager - Stopping ShardManager shard-manager-config32
11:20:29,777 AM [main] [INFO] ShardManagerTest - testOnReceiveFindPrimaryForRemoteShard starting
11:20:29,785 AM [cluster-test-akka.actor.default-dispatcher-5] [INFO] Slf4jLogger - Slf4jLogger started
11:20:29,792 AM [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 [-645190751658231877]
11:20:29,792 AM [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] ...
11:20:29,794 AM [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]
11:20:29,794 AM [cluster-test-akka.actor.default-dispatcher-10] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2558] - Started up successfully
11:20:29,794 AM [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
11:20:29,794 AM [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
11:20:29,807 AM [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
11:20:29,807 AM [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)
11:20:29,807 AM [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]
11:20:29,819 AM [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'.
11:20:29,822 AM [cluster-test-akka.actor.default-dispatcher-10] [INFO] ShardManager - Starting ShardManager shard-manager-config33
11:20:29,824 AM [cluster-test-akka.actor.default-dispatcher-10] [INFO] ShardManager - Recovery complete : shard-manager-config33
11:20:29,824 AM [cluster-test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config33: Creating local shard: member-1-shard-default-config33
11:20:29,824 AM [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
11:20:29,824 AM [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
11:20:29,830 AM [cluster-test-akka.actor.default-dispatcher-6] [INFO] Slf4jLogger - Slf4jLogger started
11:20:29,843 AM [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 [-455691855223313841]
11:20:29,843 AM [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] ...
11:20:29,849 AM [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
11:20:29,849 AM [cluster-test-akka.actor.default-dispatcher-6] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2559] - Started up successfully
11:20:29,851 AM [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
11:20:29,851 AM [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
11:20:29,869 AM [cluster-test-akka.actor.default-dispatcher-13] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1
11:20:29,869 AM [cluster-test-akka.actor.default-dispatcher-13] [DEBUG] ShardManager - Creating Shard member-1-shard-default-config33
11:20:29,869 AM [cluster-test-akka.actor.default-dispatcher-13] [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
11:20:29,869 AM [cluster-test-akka.actor.default-dispatcher-13] [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
11:20:29,869 AM [cluster-test-akka.actor.default-dispatcher-13] [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#-1157557649]
11:20:29,871 AM [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'.
11:20:29,878 AM [cluster-test-akka.actor.default-dispatcher-6] [INFO] ShardManager - Starting ShardManager shard-manager-config33
11:20:29,884 AM [cluster-test-akka.actor.default-dispatcher-14] [INFO] ShardManager - Recovery complete : shard-manager-config33
11:20:29,884 AM [cluster-test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - shard-manager-config33: Creating local shard: member-2-shard-default-config33
11:20:29,884 AM [cluster-test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - shard-manager-config33: Creating local shard: member-2-shard-astronauts-config33
11:20:29,885 AM [cluster-test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1
11:20:29,885 AM [cluster-test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - Creating Shard member-2-shard-default-config33
11:20:29,885 AM [cluster-test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - Creating Shard member-2-shard-astronauts-config33
11:20:29,885 AM [cluster-test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - shard-manager-config33: Initializing shard [astronauts]
11:20:29,885 AM [cluster-test-akka.actor.default-dispatcher-14] [DEBUG] ShardInformation - Shard member-2-shard-astronauts-config33 is initialized
11:20:29,885 AM [cluster-test-akka.actor.default-dispatcher-14] [INFO] ShardManager - shard-manager-config33: Received LeaderStateChanged message: LeaderStateChanged [memberId=member-2-shard-astronauts-config33, leaderId=member-2-shard-astronauts-config33, leaderPayloadVersion=12]
11:20:29,885 AM [cluster-test-akka.actor.default-dispatcher-14] [INFO] ShardManager - shard-manager-config33: Received role changed for member-2-shard-astronauts-config33 from Candidate to Leader
11:20:29,921 AM [cluster-test-akka.actor.default-dispatcher-13] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2558] - Node [akka://cluster-test@127.0.0.1:2559] is JOINING, roles [member-2, dc-default], version [0.0.0]
11:20:29,924 AM [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]
11:20:29,924 AM [cluster-test-akka.actor.default-dispatcher-14] [INFO] ShardManager - shard-manager-config33: Received MemberUp: memberName: MemberName{name=member-1}, address: akka://cluster-test@127.0.0.1:2558
11:20:29,924 AM [cluster-test-akka.actor.default-dispatcher-14] [INFO] ShardInformation - updatePeerAddress for peer member-1-shard-default-config33 with address akka://cluster-test@127.0.0.1:2558/user/shardmanager-config33/member-1-shard-default-config33
11:20:29,924 AM [cluster-test-akka.actor.default-dispatcher-14] [DEBUG] ShardInformation - Sending PeerAddressResolved for peer member-1-shard-default-config33 with address akka://cluster-test@127.0.0.1:2558/user/shardmanager-config33/member-1-shard-default-config33 to akka://cluster-test/user/member-2-shard-astronauts-config
11:20:29,924 AM [cluster-test-akka.actor.default-dispatcher-14] [INFO] ShardInformation - updatePeerAddress for peer member-1-shard-astronauts-config33 with address akka://cluster-test@127.0.0.1:2558/user/shardmanager-config33/member-1-shard-astronauts-config33
11:20:29,924 AM [cluster-test-akka.actor.default-dispatcher-14] [DEBUG] ShardInformation - Sending PeerAddressResolved for peer member-1-shard-astronauts-config33 with address akka://cluster-test@127.0.0.1:2558/user/shardmanager-config33/member-1-shard-astronauts-config33 to akka://cluster-test/user/member-2-shard-astronauts-config
11:20:30,814 AM [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:2559] to [Up]
11:20:30,814 AM [cluster-test-akka.actor.default-dispatcher-13] [INFO] ShardManager - shard-manager-config33: Received MemberUp: memberName: MemberName{name=member-2}, address: akka://cluster-test@127.0.0.1:2559
11:20:30,814 AM [cluster-test-akka.actor.default-dispatcher-13] [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
11:20:30,814 AM [cluster-test-akka.actor.default-dispatcher-13] [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
11:20:30,814 AM [cluster-test-akka.actor.default-dispatcher-13] [DEBUG] ShardManager - shard-manager-config33: In findPrimary: org.opendaylight.controller.cluster.datastore.messages.FindPrimary [shardName=astronauts, waitUntilReady=false]
11:20:30,815 AM [cluster-test-akka.actor.default-dispatcher-13] [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]
11:20:30,822 AM [cluster-test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - shard-manager-config33: In findPrimary: org.opendaylight.controller.cluster.datastore.messages.RemoteFindPrimary [shardName=astronauts, waitUntilReady=false]
11:20:30,822 AM [cluster-test-akka.actor.default-dispatcher-14] [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#1434968615, primaryVersion=12]
11:20:30,825 AM [main] [INFO] ShardManagerTest - testOnReceiveFindPrimaryForRemoteShard ending
11:20:30,877 AM [cluster-test-akka.actor.default-dispatcher-14] [INFO] ShardManager - shard-manager-config33: Received MemberUp: memberName: MemberName{name=member-2}, address: akka://cluster-test@127.0.0.1:2559
11:20:30,877 AM [cluster-test-akka.actor.default-dispatcher-14] [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
11:20:30,877 AM [cluster-test-akka.actor.default-dispatcher-14] [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
11:20:30,877 AM [cluster-test-akka.actor.default-dispatcher-14] [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
11:20:30,877 AM [cluster-test-akka.actor.default-dispatcher-14] [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
11:20:30,927 AM [cluster-test-akka.actor.default-dispatcher-13] [INFO] ShardManager - Stopping ShardManager shard-manager-config33
11:20:30,928 AM [cluster-test-akka.actor.default-dispatcher-10] [INFO] RemoteActorRefProvider$RemotingTerminator - Shutting down remote daemon.
11:20:30,928 AM [cluster-test-akka.actor.default-dispatcher-10] [INFO] RemoteActorRefProvider$RemotingTerminator - Remote daemon shut down; proceeding with flushing remote transports.
11:20:30,938 AM [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
11:20:30,938 AM [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
11:20:30,954 AM [cluster-test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Stopping ShardManager shard-manager-config33
11:20:30,955 AM [cluster-test-akka.actor.default-dispatcher-11] [INFO] RemoteActorRefProvider$RemotingTerminator - Shutting down remote daemon.
11:20:30,955 AM [cluster-test-akka.actor.default-dispatcher-11] [INFO] RemoteActorRefProvider$RemotingTerminator - Remote daemon shut down; proceeding with flushing remote transports.
11:20:31,972 AM [cluster-test-akka.actor.default-dispatcher-11] [INFO] RemoteActorRefProvider$RemotingTerminator - Remoting shut down.
[WARN] [02/27/2024 11:20:31.974] [cluster-test-akka.actor.internal-dispatcher-5] [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
11:20:31,984 AM [test-akka.actor.default-dispatcher-5] [INFO] ShardManager - Starting ShardManager shard-manager-config34
11:20:31,985 AM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Recovery complete : shard-manager-config34
11:20:31,985 AM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config34: Creating local shard: member-1-shard-default-config34
11:20:31,995 AM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config34: findLocalShard : default
11:20:31,995 AM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config34: Returning NotInitializedException for shard default
11:20:32,96 AM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/$r#1113666504]
11:20:32,107 AM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Stopping ShardManager shard-manager-config34
11:20:32,111 AM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Starting ShardManager shard-manager-config35
11:20:32,114 AM [test-akka.actor.default-dispatcher-5] [INFO] ShardManager - Recovery complete : shard-manager-config35
11:20:32,114 AM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - shard-manager-config35: Creating local shard: member-1-shard-default-config35
11:20:32,120 AM [test-akka.actor.default-dispatcher-16] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1
11:20:32,120 AM [test-akka.actor.default-dispatcher-16] [DEBUG] ShardManager - Creating Shard member-1-shard-default-config35
11:20:32,120 AM [test-akka.actor.default-dispatcher-16] [DEBUG] ShardManager - shard-manager-config35: Initializing shard [default]
11:20:32,120 AM [test-akka.actor.default-dispatcher-16] [DEBUG] ShardInformation - Shard member-1-shard-default-config35 is initialized
11:20:32,121 AM [test-akka.actor.default-dispatcher-16] [INFO] ShardManager - shard-manager-config35: Received LeaderStateChanged message: LeaderStateChanged [memberId=member-1-shard-default-config35, leaderId=member-1-shard-default-config35, leaderPayloadVersion=13]
11:20:32,121 AM [test-akka.actor.default-dispatcher-16] [INFO] ShardManager - shard-manager-config35: Received role changed for member-1-shard-default-config35 from Candidate to Leader
11:20:32,121 AM [test-akka.actor.default-dispatcher-16] [INFO] ShardManager - shard-manager-config35: All Shards are ready - data store config35 is ready
11:20:32,121 AM [test-akka.actor.default-dispatcher-16] [DEBUG] ShardManager - shard-manager-config35: onChangeShardServersVotingStatus: ChangeShardMembersVotingStatus [shardName=default, meberVotingStatusMap={member-2=true}]
11:20:32,121 AM [test-akka.actor.default-dispatcher-16] [DEBUG] ShardManager - shard-manager-config35: findLocalShard : default
11:20:32,122 AM [test-akka.actor.default-dispatcher-11] [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
11:20:32,122 AM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config35: Received ServerChangeReply{status=OK} from local shard akka://test/user/member-1-shard-default-config35
11:20:32,122 AM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config35: ChangeServersVotingStatus succeeded for shard default
11:20:32,272 AM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/member-1-shard-default-config35#1544364533]
11:20:32,284 AM [main] [INFO] ShardManagerTest - testShutDown starting
11:20:32,289 AM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Starting ShardManager shard-manager-config36
11:20:32,290 AM [test-akka.actor.default-dispatcher-16] [INFO] ShardManager - Recovery complete : shard-manager-config36
11:20:32,290 AM [test-akka.actor.default-dispatcher-16] [DEBUG] ShardManager - shard-manager-config36: Creating local shard: member-1-shard-shard2-config36
11:20:32,290 AM [test-akka.actor.default-dispatcher-16] [DEBUG] ShardManager - shard-manager-config36: Creating local shard: member-1-shard-shard1-config36
11:20:32,299 AM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1
11:20:32,299 AM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - Creating Shard member-1-shard-shard2-config36
11:20:32,299 AM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - Creating Shard member-1-shard-shard1-config36
11:20:32,300 AM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config36: Initializing shard [shard1]
11:20:32,300 AM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardInformation - Shard member-1-shard-shard1-config36 is initialized
11:20:32,300 AM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config36: Initializing shard [shard2]
11:20:32,300 AM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardInformation - Shard member-1-shard-shard2-config36 is initialized
11:20:32,300 AM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config36: Issuing gracefulStop to shard member-1-shard-shard2-config36
11:20:32,301 AM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config36: Issuing gracefulStop to shard member-1-shard-shard1-config36
11:20:32,301 AM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Shutting down ShardManager shard-manager-config36 - waiting on 2 shards
11:20:32,853 AM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/member-1-shard-shard1-config36#146859983]
11:20:32,853 AM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/member-1-shard-shard2-config36#996002460]
11:20:32,854 AM [test-akka.actor.default-dispatcher-16] [DEBUG] ShardManager - shard-manager-config36: All shards shutdown - sending PoisonPill to self
11:20:32,854 AM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Stopping ShardManager shard-manager-config36
11:20:32,854 AM [main] [INFO] ShardManagerTest - testShutDown ending
11:20:32,956 AM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/$t#1882998831]
11:20:32,968 AM [main] [INFO] ShardManagerTest - testOnReceiveFindPrimaryForNonLocalLeaderShardBeforeMemberUp starting
11:20:32,970 AM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Starting ShardManager shard-manager-config37
11:20:32,972 AM [test-akka.actor.default-dispatcher-16] [INFO] ShardManager - Recovery complete : shard-manager-config37
11:20:32,972 AM [test-akka.actor.default-dispatcher-16] [DEBUG] ShardManager - shard-manager-config37: Creating local shard: member-1-shard-default-config37
11:20:32,981 AM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1
11:20:32,981 AM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - Creating Shard member-1-shard-default-config37
11:20:32,981 AM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config37: Initializing shard [default]
11:20:32,981 AM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardInformation - Shard member-1-shard-default-config37 is initialized
11:20:32,981 AM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - shard-manager-config37: Received role changed for member-1-shard-default-config37 from Candidate to Follower
11:20:32,981 AM [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]
11:20:32,982 AM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config37: In findPrimary: org.opendaylight.controller.cluster.datastore.messages.FindPrimary [shardName=default, waitUntilReady=false]
11:20:32,982 AM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config37: Returning NoShardLeaderException for shard default
11:20:32,982 AM [main] [INFO] ShardManagerTest - testOnReceiveFindPrimaryForNonLocalLeaderShardBeforeMemberUp ending
11:20:33,83 AM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/$u#-2011449073]
11:20:33,94 AM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Stopping ShardManager shard-manager-config37
11:20:33,96 AM [main] [INFO] ShardManagerTest - testOnReceiveFindPrimaryWaitForReadyWithNoRoleShard starting
11:20:33,98 AM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Starting ShardManager shard-manager-config38
11:20:33,99 AM [test-akka.actor.default-dispatcher-16] [INFO] ShardManager - Recovery complete : shard-manager-config38
11:20:33,99 AM [test-akka.actor.default-dispatcher-16] [DEBUG] ShardManager - shard-manager-config38: Creating local shard: member-1-shard-default-config38
11:20:33,109 AM [test-akka.actor.default-dispatcher-16] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1
11:20:33,109 AM [test-akka.actor.default-dispatcher-16] [DEBUG] ShardManager - Creating Shard member-1-shard-default-config38
11:20:33,109 AM [test-akka.actor.default-dispatcher-16] [DEBUG] ShardManager - shard-manager-config38: Initializing shard [default]
11:20:33,109 AM [test-akka.actor.default-dispatcher-16] [DEBUG] ShardInformation - Shard member-1-shard-default-config38 is initialized
11:20:33,109 AM [test-akka.actor.default-dispatcher-16] [DEBUG] ShardManager - shard-manager-config38: In findPrimary: org.opendaylight.controller.cluster.datastore.messages.FindPrimary [shardName=default, waitUntilReady=true]
11:20:33,109 AM [test-akka.actor.default-dispatcher-16] [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]
11:20:34,322 AM [test-akka.actor.default-dispatcher-16] [DEBUG] ShardManager - shard-manager-config38: Received ShardNotInitializedTimeout message for shard default
11:20:34,322 AM [test-akka.actor.default-dispatcher-16] [DEBUG] ShardManager - shard-manager-config38: Returning NoShardLeaderException for shard default
11:20:34,323 AM [main] [INFO] ShardManagerTest - testOnReceiveFindPrimaryWaitForReadyWithNoRoleShard ending
11:20:34,424 AM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/$v#1153619997]
11:20:34,435 AM [test-akka.actor.default-dispatcher-16] [INFO] ShardManager - Stopping ShardManager shard-manager-config38
11:20:34,437 AM [main] [INFO] ShardManagerTest - testShardPersistenceWithRestoredData starting
11:20:34,441 AM [test-akka.actor.default-dispatcher-16] [INFO] ShardManager - Starting ShardManager shard-manager-config39
11:20:34,442 AM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - shard-manager-config39: onSnapshotOffer: ShardManagerSnapshot [ShardList = [default, astronauts] ]
11:20:34,442 AM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - shard-manager-config39: adding shard astronauts
11:20:34,443 AM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - shard-manager-config39: removing shard people
11:20:34,443 AM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Recovery complete : shard-manager-config39
11:20:34,443 AM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config39: Creating local shard: member-1-shard-default-config39
11:20:34,444 AM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config39: Creating local shard: member-1-shard-astronauts-config39
11:20:34,551 AM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - shard-manager-config39: findLocalShard : people
11:20:34,551 AM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - shard-manager-config39: Local shard people not found - shards present: [default, astronauts]
11:20:34,551 AM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - shard-manager-config39: findLocalShard : default
11:20:34,551 AM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - shard-manager-config39: Returning NotInitializedException for shard default
11:20:34,551 AM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - shard-manager-config39: findLocalShard : astronauts
11:20:34,551 AM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - shard-manager-config39: Returning NotInitializedException for shard astronauts
11:20:34,551 AM [main] [INFO] ShardManagerTest - testShardPersistenceWithRestoredData ending
11:20:34,653 AM [main] [INFO] TestActorFactory - Killing actor TestActor[akka://test/user/$$o]
11:20:34,663 AM [test-akka.actor.default-dispatcher-5] [INFO] ShardManager - Stopping ShardManager shard-manager-config39
11:20:34,665 AM [main] [INFO] ShardManagerTest - testOnReceiveFindPrimaryForNonLocalLeaderShard starting
11:20:34,668 AM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Starting ShardManager shard-manager-config40
11:20:34,669 AM [test-akka.actor.default-dispatcher-5] [INFO] ShardManager - Recovery complete : shard-manager-config40
11:20:34,669 AM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - shard-manager-config40: Creating local shard: member-1-shard-default-config40
11:20:34,678 AM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1
11:20:34,678 AM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - Creating Shard member-1-shard-default-config40
11:20:34,678 AM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config40: Initializing shard [default]
11:20:34,678 AM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardInformation - Shard member-1-shard-default-config40 is initialized
11:20:34,678 AM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - shard-manager-config40: Received MemberUp: memberName: MemberName{name=member-2}, address: akka://test
11:20:34,679 AM [test-akka.actor.default-dispatcher-11] [INFO] ShardInformation - updatePeerAddress for peer member-2-shard-default-config40 with address akka://test/user/shardmanager-config40/member-2-shard-default-config40
11:20:34,679 AM [test-akka.actor.default-dispatcher-11] [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
11:20:34,679 AM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - shard-manager-config40: Received role changed for member-1-shard-default-config40 from Candidate to Follower
11:20:34,679 AM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - shard-manager-config40: Received LeaderStateChanged message: LeaderStateChanged [memberId=member-1-shard-default-config40, leaderId=member-2-shard-default-config40, leaderPayloadVersion=12]
11:20:34,679 AM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - shard-manager-config40: All Shards are ready - data store config40 is ready
11:20:34,679 AM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config40: In findPrimary: org.opendaylight.controller.cluster.datastore.messages.FindPrimary [shardName=default, waitUntilReady=false]
11:20:34,679 AM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config40: Found primary for default: RemotePrimaryShardFound [primaryPath=akka://test/user/shardmanager-config40/member-2-shard-default-config40, primaryVersion=12]
11:20:34,679 AM [main] [INFO] ShardManagerTest - testOnReceiveFindPrimaryForNonLocalLeaderShard ending
11:20:34,780 AM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/$w#494464131]
11:20:34,791 AM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Stopping ShardManager shard-manager-config40
11:20:34,793 AM [main] [INFO] ShardManagerTest - testShardAvailabilityOnChangeOfMemberReachability starting
11:20:34,801 AM [cluster-test-akka.actor.default-dispatcher-5] [INFO] Slf4jLogger - Slf4jLogger started
11:20:34,807 AM [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 [-6106733367612090469]
11:20:34,807 AM [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] ...
11:20:34,809 AM [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]
11:20:34,809 AM [cluster-test-akka.actor.default-dispatcher-5] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2558] - Started up successfully
11:20:34,820 AM [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
11:20:34,820 AM [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
11:20:34,821 AM [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
11:20:34,822 AM [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)
11:20:34,822 AM [cluster-test-akka.actor.default-dispatcher-11] [INFO] EmptyLocalActorRef - Message [org.opendaylight.controller.cluster.common.actor.Monitor] from TestActor[akka://cluster-test/user/shardmanager-config41] to Actor[akka://cluster-test/user/termination-monitor] was not delivered. [1] dead letters encountered. If this is not an expected behavior then Actor[akka://cluster-test/user/termination-monitor] may have terminated unexpectedly. This logging can be turned off or adjusted with configuration settings 'akka.log-dead-letters' and 'akka.log-dead-letters-during-shutdown'.
11:20:34,822 AM [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]
11:20:34,824 AM [cluster-test-akka.actor.default-dispatcher-10] [INFO] ShardManager - Starting ShardManager shard-manager-config41
11:20:34,829 AM [cluster-test-akka.actor.default-dispatcher-5] [INFO] Slf4jLogger - Slf4jLogger started
11:20:34,831 AM [cluster-test-akka.actor.default-dispatcher-13] [INFO] ShardManager - Recovery complete : shard-manager-config41
11:20:34,831 AM [cluster-test-akka.actor.default-dispatcher-13] [DEBUG] ShardManager - shard-manager-config41: Creating local shard: member-1-shard-default-config41
11:20:34,831 AM [cluster-test-akka.actor.default-dispatcher-13] [INFO] ShardManager - shard-manager-config41: Received MemberUp: memberName: MemberName{name=member-1}, address: akka://cluster-test@127.0.0.1:2558
11:20:34,831 AM [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
11:20:34,840 AM [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 [4626552534274406543]
11:20:34,840 AM [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] ...
11:20:34,847 AM [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
11:20:34,847 AM [cluster-test-akka.actor.default-dispatcher-5] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2559] - Started up successfully
11:20:34,847 AM [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
11:20:34,847 AM [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
11:20:34,857 AM [cluster-test-akka.actor.default-dispatcher-12] [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'.
11:20:34,858 AM [cluster-test-akka.actor.default-dispatcher-5] [INFO] ShardManager - Starting ShardManager shard-manager-config41
11:20:34,863 AM [cluster-test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Recovery complete : shard-manager-config41
11:20:34,863 AM [cluster-test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config41: Creating local shard: member-2-shard-default-config41
11:20:34,863 AM [cluster-test-akka.actor.default-dispatcher-13] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1
11:20:34,863 AM [cluster-test-akka.actor.default-dispatcher-13] [DEBUG] ShardManager - Creating Shard member-1-shard-default-config41
11:20:34,863 AM [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
11:20:34,863 AM [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
11:20:34,864 AM [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#-930247789]
11:20:34,864 AM [cluster-test-akka.actor.default-dispatcher-13] [DEBUG] ShardManager - shard-manager-config41: Initializing shard [default]
11:20:34,864 AM [cluster-test-akka.actor.default-dispatcher-13] [DEBUG] ShardInformation - Shard member-1-shard-default-config41 is initialized
11:20:34,864 AM [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]
11:20:34,864 AM [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
11:20:34,864 AM [cluster-test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1
11:20:34,864 AM [cluster-test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - Creating Shard member-2-shard-default-config41
11:20:34,864 AM [cluster-test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config41: Initializing shard [default]
11:20:34,864 AM [cluster-test-akka.actor.default-dispatcher-11] [DEBUG] ShardInformation - Shard member-2-shard-default-config41 is initialized
11:20:34,864 AM [cluster-test-akka.actor.default-dispatcher-11] [INFO] ShardManager - shard-manager-config41: Received LeaderStateChanged message: LeaderStateChanged [memberId=member-2-shard-default-config41, leaderId=member-2-shard-default-config41, leaderPayloadVersion=13]
11:20:34,864 AM [cluster-test-akka.actor.default-dispatcher-11] [INFO] ShardManager - shard-manager-config41: Received role changed for member-2-shard-default-config41 from Candidate to Leader
11:20:34,864 AM [cluster-test-akka.actor.default-dispatcher-11] [INFO] ShardManager - shard-manager-config41: All Shards are ready - data store config41 is ready
11:20:34,919 AM [cluster-test-akka.actor.default-dispatcher-12] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2558] - Node [akka://cluster-test@127.0.0.1:2559] is JOINING, roles [member-2, dc-default], version [0.0.0]
11:20:34,923 AM [cluster-test-akka.actor.default-dispatcher-11] [INFO] ShardManager - shard-manager-config41: Received MemberUp: memberName: MemberName{name=member-1}, address: akka://cluster-test@127.0.0.1:2558
11:20:34,923 AM [cluster-test-akka.actor.default-dispatcher-11] [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
11:20:34,923 AM [cluster-test-akka.actor.default-dispatcher-11] [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
11:20:34,923 AM [cluster-test-akka.actor.default-dispatcher-11] [INFO] ShardManager - shard-manager-config41: All Shards are ready - data store config41 is ready
11:20:34,923 AM [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]
11:20:35,830 AM [cluster-test-akka.actor.default-dispatcher-12] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2558] - Leader is moving node [akka://cluster-test@127.0.0.1:2559] to [Up]
11:20:35,830 AM [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
11:20:35,830 AM [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
11:20:35,830 AM [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
11:20:35,830 AM [cluster-test-akka.actor.default-dispatcher-13] [INFO] ShardManager - shard-manager-config41: All Shards are ready - data store config41 is ready
11:20:35,830 AM [cluster-test-akka.actor.default-dispatcher-12] [DEBUG] ShardManager - shard-manager-config41: In findPrimary: org.opendaylight.controller.cluster.datastore.messages.FindPrimary [shardName=default, waitUntilReady=true]
11:20:35,831 AM [cluster-test-akka.actor.default-dispatcher-12] [DEBUG] ShardManager - shard-manager-config41: Found primary for default: RemotePrimaryShardFound [primaryPath=akka://cluster-test@127.0.0.1:2559/user/shardmanager-config41/member-2-shard-default-config41, primaryVersion=13]
11:20:35,832 AM [cluster-test-akka.actor.default-dispatcher-12] [INFO] ShardManager - Received UnreachableMember: memberName MemberName{name=member-2}, address: akka://cluster-test@127.0.0.1:2558
11:20:35,832 AM [cluster-test-akka.actor.default-dispatcher-12] [DEBUG] ShardManager - Marking Leader member-2-shard-default-config41 as unavailable.
11:20:35,833 AM [cluster-test-akka.actor.default-dispatcher-12] [INFO] ShardManager - shard-manager-config41: Received MemberRemoved: memberName: MemberName{name=member-2}, address: akka://cluster-test@127.0.0.1:2558
11:20:35,833 AM [cluster-test-akka.actor.default-dispatcher-12] [DEBUG] ShardManager - shard-manager-config41: In findPrimary: org.opendaylight.controller.cluster.datastore.messages.FindPrimary [shardName=default, waitUntilReady=true]
11:20:35,833 AM [cluster-test-akka.actor.default-dispatcher-12] [DEBUG] ShardManager - shard-manager-config41: Scheduling 1200 ms timer to wait for shard ShardInformation [shardId=member-1-shard-default-config41, leaderAvailable=false, actorInitialized=true, followerSyncStatus=false, role=Follower, leaderId=member-2-shard-default-config41, activeMember=true]
11:20:35,860 AM [cluster-test-akka.actor.default-dispatcher-10] [INFO] ShardManager - shard-manager-config41: Received MemberUp: memberName: MemberName{name=member-2}, address: akka://cluster-test@127.0.0.1:2559
11:20:35,860 AM [cluster-test-akka.actor.default-dispatcher-10] [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
11:20:35,860 AM [cluster-test-akka.actor.default-dispatcher-10] [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
11:20:35,860 AM [cluster-test-akka.actor.default-dispatcher-10] [INFO] ShardManager - shard-manager-config41: All Shards are ready - data store config41 is ready
11:20:37,47 AM [cluster-test-akka.actor.default-dispatcher-12] [DEBUG] ShardManager - shard-manager-config41: Received ShardNotInitializedTimeout message for shard default
11:20:37,47 AM [cluster-test-akka.actor.default-dispatcher-12] [DEBUG] ShardManager - shard-manager-config41: Returning NoShardLeaderException for shard default
11:20:37,48 AM [cluster-test-akka.actor.default-dispatcher-12] [INFO] ShardManager - Received ReachableMember: memberName MemberName{name=member-2}, address: akka://cluster-test@127.0.0.1:2558
11:20:37,48 AM [cluster-test-akka.actor.default-dispatcher-12] [INFO] ShardInformation - updatePeerAddress for peer member-2-shard-default-config41 with address akka://cluster-test@127.0.0.1:2558/user/shardmanager-config41/member-2-shard-default-config41
11:20:37,48 AM [cluster-test-akka.actor.default-dispatcher-12] [DEBUG] ShardInformation - Sending PeerAddressResolved for peer member-2-shard-default-config41 with address akka://cluster-test@127.0.0.1:2558/user/shardmanager-config41/member-2-shard-default-config41 to akka://cluster-test/user/member-1-shard-default-config
11:20:37,48 AM [cluster-test-akka.actor.default-dispatcher-12] [DEBUG] ShardManager - Marking Leader member-2-shard-default-config41 as available.
11:20:37,48 AM [cluster-test-akka.actor.default-dispatcher-12] [DEBUG] ShardManager - shard-manager-config41: In findPrimary: org.opendaylight.controller.cluster.datastore.messages.FindPrimary [shardName=default, waitUntilReady=true]
11:20:37,48 AM [cluster-test-akka.actor.default-dispatcher-12] [DEBUG] ShardManager - shard-manager-config41: Found primary for default: RemotePrimaryShardFound [primaryPath=akka://cluster-test@127.0.0.1:2558/user/shardmanager-config41/member-2-shard-default-config41, primaryVersion=13]
11:20:37,48 AM [cluster-test-akka.actor.default-dispatcher-12] [INFO] ShardManager - shard-manager-config41: Received MemberUp: memberName: MemberName{name=member-2}, address: akka://cluster-test@127.0.0.1:2558
11:20:37,49 AM [cluster-test-akka.actor.default-dispatcher-12] [INFO] ShardInformation - updatePeerAddress for peer member-2-shard-default-config41 with address akka://cluster-test@127.0.0.1:2558/user/shardmanager-config41/member-2-shard-default-config41
11:20:37,49 AM [cluster-test-akka.actor.default-dispatcher-12] [DEBUG] ShardInformation - Sending PeerAddressResolved for peer member-2-shard-default-config41 with address akka://cluster-test@127.0.0.1:2558/user/shardmanager-config41/member-2-shard-default-config41 to akka://cluster-test/user/member-1-shard-default-config
11:20:37,49 AM [cluster-test-akka.actor.default-dispatcher-12] [INFO] ShardManager - shard-manager-config41: All Shards are ready - data store config41 is ready
11:20:37,49 AM [cluster-test-akka.actor.default-dispatcher-12] [INFO] ShardManager - Received UnreachableMember: memberName MemberName{name=member-2}, address: akka://cluster-test@127.0.0.1:2558
11:20:37,49 AM [cluster-test-akka.actor.default-dispatcher-12] [DEBUG] ShardManager - Marking Leader member-2-shard-default-config41 as unavailable.
11:20:37,49 AM [cluster-test-akka.actor.default-dispatcher-12] [DEBUG] ShardManager - shard-manager-config41: In findPrimary: org.opendaylight.controller.cluster.datastore.messages.FindPrimary [shardName=default, waitUntilReady=true]
11:20:37,49 AM [cluster-test-akka.actor.default-dispatcher-12] [DEBUG] ShardManager - shard-manager-config41: Scheduling 1200 ms timer to wait for shard ShardInformation [shardId=member-1-shard-default-config41, leaderAvailable=false, actorInitialized=true, followerSyncStatus=false, role=Follower, leaderId=member-2-shard-default-config41, activeMember=true]
11:20:37,49 AM [cluster-test-akka.actor.default-dispatcher-12] [INFO] ShardManager - Received ReachableMember: memberName MemberName{name=member-2}, address: akka://cluster-test@127.0.0.1:2558
11:20:37,49 AM [cluster-test-akka.actor.default-dispatcher-12] [INFO] ShardInformation - updatePeerAddress for peer member-2-shard-default-config41 with address akka://cluster-test@127.0.0.1:2558/user/shardmanager-config41/member-2-shard-default-config41
11:20:37,49 AM [cluster-test-akka.actor.default-dispatcher-12] [DEBUG] ShardInformation - Sending PeerAddressResolved for peer member-2-shard-default-config41 with address akka://cluster-test@127.0.0.1:2558/user/shardmanager-config41/member-2-shard-default-config41 to akka://cluster-test/user/member-1-shard-default-config
11:20:37,49 AM [cluster-test-akka.actor.default-dispatcher-12] [DEBUG] ShardInformation - Shard member-1-shard-default-config41 is initialized - notifying 1 OnShardInitialized callbacks
11:20:37,49 AM [cluster-test-akka.actor.default-dispatcher-12] [DEBUG] ShardManager - Marking Leader member-2-shard-default-config41 as available.
11:20:37,49 AM [cluster-test-akka.actor.default-dispatcher-12] [DEBUG] ShardInformation - Shard member-1-shard-default-config41 is ready - notifying 1 OnShardInitialized callbacks
11:20:37,49 AM [cluster-test-akka.actor.default-dispatcher-12] [DEBUG] ShardManager - shard-manager-config41: Found primary for default: RemotePrimaryShardFound [primaryPath=akka://cluster-test@127.0.0.1:2558/user/shardmanager-config41/member-2-shard-default-config41, primaryVersion=13]
11:20:37,49 AM [main] [INFO] ShardManagerTest - testShardAvailabilityOnChangeOfMemberReachability ending
11:20:37,151 AM [cluster-test-akka.actor.default-dispatcher-13] [INFO] ShardManager - Stopping ShardManager shard-manager-config41
11:20:37,151 AM [cluster-test-akka.actor.default-dispatcher-13] [INFO] RemoteActorRefProvider$RemotingTerminator - Shutting down remote daemon.
11:20:37,151 AM [cluster-test-akka.actor.default-dispatcher-13] [INFO] RemoteActorRefProvider$RemotingTerminator - Remote daemon shut down; proceeding with flushing remote transports.
11:20:37,160 AM [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
11:20:37,160 AM [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
11:20:37,161 AM [cluster-test-akka.actor.default-dispatcher-14] [INFO] RemoteActorRefProvider$RemotingTerminator - Remoting shut down.
11:20:37,170 AM [cluster-test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Stopping ShardManager shard-manager-config41
11:20:37,171 AM [cluster-test-akka.actor.default-dispatcher-11] [INFO] RemoteActorRefProvider$RemotingTerminator - Shutting down remote daemon.
11:20:37,171 AM [cluster-test-akka.actor.default-dispatcher-11] [INFO] RemoteActorRefProvider$RemotingTerminator - Remote daemon shut down; proceeding with flushing remote transports.
11:20:38,184 AM [cluster-test-akka.actor.default-dispatcher-11] [INFO] RemoteActorRefProvider$RemotingTerminator - Remoting shut down.
[WARN] [02/27/2024 11:20:38.187] [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
11:20:38,209 AM [main] [INFO] ShardManagerTest - testAddShardReplica starting
11:20:38,217 AM [cluster-test-akka.actor.default-dispatcher-5] [INFO] Slf4jLogger - Slf4jLogger started
11:20:38,230 AM [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 [-8691538381819550897]
11:20:38,230 AM [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] ...
11:20:38,239 AM [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]
11:20:38,239 AM [cluster-test-akka.actor.default-dispatcher-5] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2558] - Started up successfully
11:20:38,239 AM [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
11:20:38,239 AM [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
11:20:38,247 AM [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
11:20:38,247 AM [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)
11:20:38,247 AM [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]
11:20:38,249 AM [cluster-test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Starting ShardManager shardmanager-config42
11:20:38,249 AM [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'.
11:20:38,258 AM [cluster-test-akka.actor.default-dispatcher-13] [INFO] ShardManager - Recovery complete : shardmanager-config42
11:20:38,258 AM [cluster-test-akka.actor.default-dispatcher-13] [DEBUG] ShardManager - shardmanager-config42: Creating local shard: member-1-shard-default-config42
11:20:38,259 AM [cluster-test-akka.actor.default-dispatcher-13] [INFO] ShardManager - shardmanager-config42: Received MemberUp: memberName: MemberName{name=member-1}, address: akka://cluster-test@127.0.0.1:2558
11:20:38,259 AM [cluster-test-akka.actor.default-dispatcher-13] [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
11:20:38,267 AM [cluster-test-akka.actor.default-dispatcher-5] [INFO] Slf4jLogger - Slf4jLogger started
11:20:38,283 AM [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 [-1057824723305234684]
11:20:38,283 AM [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] ...
11:20:38,286 AM [cluster-test-akka.actor.default-dispatcher-10] [WARN] Cluster - Could not register Cluster JMX MBean with name=akka:type=Cluster as it is already registered. If you are running multiple clusters in the same JVM, set 'akka.cluster.jmx.multi-mbeans-in-same-jvm = on' in config
11:20:38,286 AM [cluster-test-akka.actor.default-dispatcher-10] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2559] - Started up successfully
11:20:38,295 AM [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
11:20:38,295 AM [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
11:20:38,306 AM [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'.
11:20:38,308 AM [cluster-test-akka.actor.default-dispatcher-5] [INFO] ShardManager - Starting ShardManager shardmanager-config42
11:20:38,309 AM [cluster-test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1
11:20:38,309 AM [cluster-test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - Creating Shard member-1-shard-default-config42
11:20:38,309 AM [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
11:20:38,309 AM [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-1-shard-default-config
11:20:38,309 AM [cluster-test-akka.actor.default-dispatcher-5] [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#-1316221135]
11:20:38,315 AM [cluster-test-akka.actor.default-dispatcher-12] [INFO] ShardManager - Recovery complete : shardmanager-config42
11:20:38,315 AM [cluster-test-akka.actor.default-dispatcher-12] [DEBUG] ShardManager - shardmanager-config42: Creating local shard: member-2-shard-default-config42
11:20:38,315 AM [cluster-test-akka.actor.default-dispatcher-12] [DEBUG] ShardManager - shardmanager-config42: Creating local shard: member-2-shard-astronauts-config42
11:20:38,316 AM [cluster-test-akka.actor.default-dispatcher-12] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1
11:20:38,316 AM [cluster-test-akka.actor.default-dispatcher-12] [DEBUG] ShardManager - Creating Shard member-2-shard-default-config42
11:20:38,316 AM [cluster-test-akka.actor.default-dispatcher-12] [DEBUG] ShardManager - Creating Shard member-2-shard-astronauts-config42
11:20:38,316 AM [cluster-test-akka.actor.default-dispatcher-12] [DEBUG] ShardManager - shardmanager-config42: Initializing shard [astronauts]
11:20:38,316 AM [cluster-test-akka.actor.default-dispatcher-12] [DEBUG] ShardInformation - Shard member-2-shard-astronauts-config42 is initialized
11:20:38,316 AM [cluster-test-akka.actor.default-dispatcher-12] [INFO] ShardManager - shardmanager-config42: Received LeaderStateChanged message: LeaderStateChanged [memberId=member-2-shard-astronauts-config42, leaderId=member-2-shard-astronauts-config42, leaderPayloadVersion=12]
11:20:38,316 AM [cluster-test-akka.actor.default-dispatcher-12] [INFO] ShardManager - shardmanager-config42: Received role changed for member-2-shard-astronauts-config42 from Candidate to Leader
11:20:38,335 AM [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]
11:20:38,340 AM [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]
11:20:38,340 AM [cluster-test-akka.actor.default-dispatcher-12] [INFO] ShardManager - shardmanager-config42: Received MemberUp: memberName: MemberName{name=member-1}, address: akka://cluster-test@127.0.0.1:2558
11:20:38,340 AM [cluster-test-akka.actor.default-dispatcher-12] [INFO] ShardInformation - updatePeerAddress for peer member-1-shard-default-config42 with address akka://cluster-test@127.0.0.1:2558/user/shardmanager-config42/member-1-shard-default-config42
11:20:38,340 AM [cluster-test-akka.actor.default-dispatcher-12] [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
11:20:38,340 AM [cluster-test-akka.actor.default-dispatcher-12] [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
11:20:38,340 AM [cluster-test-akka.actor.default-dispatcher-12] [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
11:20:39,245 AM [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]
11:20:39,245 AM [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
11:20:39,245 AM [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
11:20:39,245 AM [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-1-shard-default-config
11:20:39,248 AM [cluster-test-akka.actor.default-dispatcher-12] [DEBUG] ShardManager - shardmanager-config42: onAddShardReplica: AddShardReplica[ShardName=astronauts]
11:20:39,249 AM [cluster-test-akka.actor.default-dispatcher-12] [DEBUG] ShardManager - shardmanager-config42: In findPrimary: org.opendaylight.controller.cluster.datastore.messages.FindPrimary [shardName=astronauts, waitUntilReady=true]
11:20:39,249 AM [cluster-test-akka.actor.default-dispatcher-12] [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]
11:20:39,253 AM [cluster-test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shardmanager-config42: In findPrimary: org.opendaylight.controller.cluster.datastore.messages.RemoteFindPrimary [shardName=astronauts, waitUntilReady=true]
11:20:39,253 AM [cluster-test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shardmanager-config42: Found primary for astronauts: RemotePrimaryShardFound [primaryPath=akka://cluster-test@127.0.0.1:2559/user/member-2-shard-astronauts-config, primaryVersion=12]
11:20:39,255 AM [cluster-test-akka.actor.default-dispatcher-12] [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
11:20:39,260 AM [cluster-test-akka.actor.default-dispatcher-12] [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
11:20:39,260 AM [cluster-test-akka.actor.default-dispatcher-12] [DEBUG] ShardManager - shardmanager-config42: Leader shard successfully added the replica shard astronauts
11:20:39,261 AM [cluster-test-akka.actor.default-dispatcher-12] [DEBUG] ShardInformation - Sending new DatastoreContext to member-1-shard-astronauts-config42
11:20:39,261 AM [cluster-test-akka.actor.default-dispatcher-12] [DEBUG] ShardManager - shardmanager-config42: persisting the shard list [default, astronauts]
11:20:39,261 AM [cluster-test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - shardmanager-config42 saved ShardManager snapshot successfully. Deleting the prev snapshot if available
11:20:39,261 AM [cluster-test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - shardmanager-config42: Successfully deleted prior snapshots
11:20:39,300 AM [main] [INFO] ShardManagerTest - testAddShardReplica ending
11:20:39,316 AM [cluster-test-akka.actor.default-dispatcher-10] [INFO] ShardManager - shardmanager-config42: Received MemberUp: memberName: MemberName{name=member-2}, address: akka://cluster-test@127.0.0.1:2559
11:20:39,316 AM [cluster-test-akka.actor.default-dispatcher-10] [INFO] ShardInformation - updatePeerAddress for peer member-2-shard-default-config42 with address akka://cluster-test@127.0.0.1:2559/user/shardmanager-config42/member-2-shard-default-config42
11:20:39,316 AM [cluster-test-akka.actor.default-dispatcher-10] [DEBUG] ShardInformation - Sending PeerAddressResolved for peer member-2-shard-default-config42 with address akka://cluster-test@127.0.0.1:2559/user/shardmanager-config42/member-2-shard-default-config42 to akka://cluster-test/user/member-2-shard-astronauts-config
11:20:39,316 AM [cluster-test-akka.actor.default-dispatcher-10] [INFO] ShardInformation - updatePeerAddress for peer member-2-shard-astronauts-config42 with address akka://cluster-test@127.0.0.1:2559/user/shardmanager-config42/member-2-shard-astronauts-config42
11:20:39,316 AM [cluster-test-akka.actor.default-dispatcher-10] [DEBUG] ShardInformation - Sending PeerAddressResolved for peer member-2-shard-astronauts-config42 with address akka://cluster-test@127.0.0.1:2559/user/shardmanager-config42/member-2-shard-astronauts-config42 to akka://cluster-test/user/member-2-shard-astronauts-config
11:20:39,402 AM [cluster-test-akka.actor.default-dispatcher-13] [INFO] ShardManager - Stopping ShardManager shardmanager-config42
11:20:39,404 AM [cluster-test-akka.actor.default-dispatcher-13] [INFO] RemoteActorRefProvider$RemotingTerminator - Shutting down remote daemon.
11:20:39,404 AM [cluster-test-akka.actor.default-dispatcher-13] [INFO] RemoteActorRefProvider$RemotingTerminator - Remote daemon shut down; proceeding with flushing remote transports.
[WARN] [02/27/2024 11:20:39.412] [cluster-test-akka.remote.default-remote-dispatcher-7] [akka.stream.Log(akka://cluster-test/system/Materializers/StreamSupervisor-626)] [outbound connection to [akka://cluster-test@127.0.0.1:2559], control stream] Upstream failed, cause: StreamTcpException: The connection has been aborted
[WARN] [02/27/2024 11:20:39.413] [cluster-test-akka.remote.default-remote-dispatcher-7] [akka.stream.Log(akka://cluster-test/system/Materializers/StreamSupervisor-626)] [outbound connection to [akka://cluster-test@127.0.0.1:2559], message stream] Upstream failed, cause: StreamTcpException: The connection has been aborted
11:20:39,427 AM [cluster-test-akka.actor.default-dispatcher-10] [INFO] ShardManager - Stopping ShardManager shardmanager-config42
11:20:39,428 AM [cluster-test-akka.actor.default-dispatcher-5] [INFO] RemoteActorRefProvider$RemotingTerminator - Shutting down remote daemon.
11:20:39,428 AM [cluster-test-akka.actor.default-dispatcher-5] [INFO] RemoteActorRefProvider$RemotingTerminator - Remote daemon shut down; proceeding with flushing remote transports.
11:20:40,449 AM [cluster-test-akka.actor.default-dispatcher-5] [INFO] RemoteActorRefProvider$RemotingTerminator - Remoting shut down.
[WARN] [02/27/2024 11:20:40.451] [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
11:20:40,467 AM [test-akka.actor.default-dispatcher-5] [INFO] ShardManager - Starting ShardManager shard-manager-config43
11:20:40,468 AM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Recovery complete : shard-manager-config43
11:20:40,469 AM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config43: Creating local shard: member-1-shard-default-config43
11:20:40,477 AM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1
11:20:40,477 AM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - Creating Shard member-1-shard-default-config43
11:20:40,477 AM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - shard-manager-config43: Initializing shard [default]
11:20:40,477 AM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardInformation - Shard member-1-shard-default-config43 is initialized
11:20:40,477 AM [test-akka.actor.default-dispatcher-5] [INFO] ShardManager - shard-manager-config43: Received LeaderStateChanged message: LeaderStateChanged [memberId=member-1-shard-default-config43, leaderId=member-1-shard-default-config43, leaderPayloadVersion=13]
11:20:40,477 AM [test-akka.actor.default-dispatcher-5] [INFO] ShardManager - shard-manager-config43: Received role changed for member-1-shard-default-config43 from Candidate to Leader
11:20:40,477 AM [test-akka.actor.default-dispatcher-5] [INFO] ShardManager - shard-manager-config43: All Shards are ready - data store config43 is ready
11:20:40,477 AM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - shard-manager-config43: onRemoveShardReplica: RemoveShardReplica [shardName=default, memberName=MemberName{name=member-1}]
11:20:40,478 AM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - shard-manager-config43: In findPrimary: org.opendaylight.controller.cluster.datastore.messages.FindPrimary [shardName=default, waitUntilReady=true]
11:20:40,478 AM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - shard-manager-config43: Found primary for default: LocalPrimaryShardFound [primaryPath=akka://test@127.0.0.1:2565/user/member-1-shard-default-config43#-1749055927, localShardDataTree=org.opendaylight.yangtools.yang.data.tree.api.DataTree$MockitoMock$mgMIAwg7@5de7300d]
11:20:40,478 AM [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#-1749055927 for shard member-1-shard-default-config43
11:20:40,479 AM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config43: Received RemoveServerReply{status=OK} for shard default
11:20:40,479 AM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config43: Leader shard successfully removed the replica shard default
11:20:40,630 AM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/member-1-shard-default-config43#-1749055927]
11:20:40,643 AM [main] [INFO] ShardManagerTest - testOnReceiveFindPrimaryWaitForReadyWithIsolatedLeaderShard starting
11:20:40,645 AM [test-akka.actor.default-dispatcher-16] [INFO] ShardManager - Starting ShardManager shard-manager-config44
11:20:40,647 AM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Recovery complete : shard-manager-config44
11:20:40,647 AM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config44: Creating local shard: member-1-shard-default-config44
11:20:40,656 AM [test-akka.actor.default-dispatcher-16] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1
11:20:40,656 AM [test-akka.actor.default-dispatcher-16] [DEBUG] ShardManager - Creating Shard member-1-shard-default-config44
11:20:40,656 AM [test-akka.actor.default-dispatcher-16] [DEBUG] ShardManager - shard-manager-config44: Initializing shard [default]
11:20:40,656 AM [test-akka.actor.default-dispatcher-16] [DEBUG] ShardInformation - Shard member-1-shard-default-config44 is initialized
11:20:40,656 AM [test-akka.actor.default-dispatcher-16] [INFO] ShardManager - shard-manager-config44: Received role changed for member-1-shard-default-config44 from null to IsolatedLeader
11:20:40,656 AM [test-akka.actor.default-dispatcher-16] [DEBUG] ShardManager - shard-manager-config44: In findPrimary: org.opendaylight.controller.cluster.datastore.messages.FindPrimary [shardName=default, waitUntilReady=true]
11:20:40,656 AM [test-akka.actor.default-dispatcher-16] [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]
11:20:41,872 AM [test-akka.actor.default-dispatcher-16] [DEBUG] ShardManager - shard-manager-config44: Received ShardNotInitializedTimeout message for shard default
11:20:41,872 AM [test-akka.actor.default-dispatcher-16] [DEBUG] ShardManager - shard-manager-config44: Returning NoShardLeaderException for shard default
11:20:41,873 AM [main] [INFO] ShardManagerTest - testOnReceiveFindPrimaryWaitForReadyWithIsolatedLeaderShard ending
11:20:41,975 AM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/$y#1433042027]
11:20:41,986 AM [test-akka.actor.default-dispatcher-16] [INFO] ShardManager - Stopping ShardManager shard-manager-config44
11:20:41,990 AM [test-akka.actor.default-dispatcher-16] [INFO] ShardManager - Starting ShardManager shard-manager-config45
11:20:41,991 AM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Recovery complete : shard-manager-config45
11:20:41,991 AM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config45: Creating local shard: member-1-shard-default-config45
11:20:42,1 AM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1
11:20:42,1 AM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - Creating Shard member-1-shard-default-config45
11:20:42,1 AM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config45: findLocalShard : non-existent
11:20:42,1 AM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config45: Local shard non-existent not found - shards present: [default]
11:20:42,103 AM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/$z#1097569147]
11:20:42,114 AM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - Stopping ShardManager shard-manager-config45
11:20:42,117 AM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - Starting ShardManager shard-manager-config46
11:20:42,122 AM [test-akka.actor.default-dispatcher-16] [INFO] ShardManager - Recovery complete : shard-manager-config46
11:20:42,138 AM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1
11:20:42,138 AM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config46: onRemoveShardReplica: RemoveShardReplica [shardName=astronauts, memberName=MemberName{name=member-2}]
11:20:42,139 AM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config46: Sending RemoveServer message to peer akka://test@127.0.0.1:2565/system/testProbe-617#78763425 for shard member-2-shard-astronauts-config46
11:20:42,150 AM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config46: onRemoveShardReplica: RemoveShardReplica [shardName=astronauts, memberName=MemberName{name=member-3}]
11:20:42,150 AM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config46: A shard replica operation for astronauts is already in progress
11:20:42,255 AM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - Starting ShardManager shard-manager-config47
11:20:42,259 AM [test-akka.actor.default-dispatcher-16] [INFO] ShardManager - Recovery complete : shard-manager-config47
11:20:42,259 AM [test-akka.actor.default-dispatcher-16] [DEBUG] ShardManager - shard-manager-config47: Creating local shard: member-1-shard-default-config47
11:20:42,266 AM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config47: In findPrimary: org.opendaylight.controller.cluster.datastore.messages.FindPrimary [shardName=default, waitUntilReady=false]
11:20:42,266 AM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config47: Returning NotInitializedException for shard default
11:20:42,368 AM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/$A#1380301857]
11:20:42,378 AM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - Stopping ShardManager shard-manager-config47
11:20:42,380 AM [main] [INFO] ShardManagerTest - testServerRemovedShardActorRunning starting
11:20:42,384 AM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - Starting ShardManager shard-manager-config48
11:20:42,385 AM [test-akka.actor.default-dispatcher-16] [INFO] ShardManager - Recovery complete : shard-manager-config48
11:20:42,385 AM [test-akka.actor.default-dispatcher-16] [DEBUG] ShardManager - shard-manager-config48: Creating local shard: member-1-shard-default-config48
11:20:42,385 AM [test-akka.actor.default-dispatcher-16] [DEBUG] ShardManager - shard-manager-config48: Creating local shard: member-1-shard-people-config48
11:20:42,397 AM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1
11:20:42,397 AM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - Creating Shard member-1-shard-default-config48
11:20:42,397 AM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - Creating Shard member-1-shard-people-config48
11:20:42,397 AM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config48: Initializing shard [default]
11:20:42,397 AM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardInformation - Shard member-1-shard-default-config48 is initialized
11:20:42,397 AM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config48: findLocalShard : people
11:20:42,398 AM [test-akka.actor.default-dispatcher-10] [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]
11:20:42,400 AM [test-shard-dispatcher-17] [INFO] Shard - Shard created : member-1-shard-people-config48, persistent : true
11:20:42,400 AM [test-akka.actor.default-dispatcher-16] [DEBUG] ShardSnapshotActor - Actor created Actor[akka://test/user/$$p/member-1-shard-people-config48/shard-member-1:snapshot-read#1571676100]
11:20:42,400 AM [test-akka.actor.default-dispatcher-10] [INFO] RoleChangeNotifier - RoleChangeNotifier:akka://test@127.0.0.1:2565/user/$$p/member-1-shard-people-config48/member-1-shard-people-config48-notifier#110007550 created and ready for shard:member-1-shard-people-config48
11:20:42,401 AM [test-shard-dispatcher-17] [INFO] Shard - Starting recovery for member-1-shard-people-config48 with journal batch size 1
11:20:42,402 AM [test-shard-dispatcher-17] [DEBUG] Shard - member-1-shard-people-config48: onReceiveRecover: Received message class akka.persistence.RecoveryCompleted$ from Actor[akka://test/deadLetters]
11:20:42,402 AM [test-shard-dispatcher-17] [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
11:20:42,402 AM [test-akka.actor.default-dispatcher-16] [DEBUG] ShardManager - shard-manager-config48: Initializing shard [people]
11:20:42,402 AM [test-akka.actor.default-dispatcher-16] [DEBUG] ShardInformation - Shard member-1-shard-people-config48 is initialized
11:20:42,402 AM [test-akka.actor.default-dispatcher-16] [DEBUG] ShardInformation - Shard member-1-shard-people-config48 is initialized - notifying 1 OnShardInitialized callbacks
11:20:42,402 AM [test-shard-dispatcher-17] [DEBUG] DataTreeChangeListenerSupport - member-1-shard-people-config48: onLeadershipChange, isLeader: false, hasLeader : false
11:20:42,402 AM [test-shard-dispatcher-17] [DEBUG] Shard - member-1-shard-people-config48: onStateChanged: Closing all transaction chains because shard member-1-shard-people-config48 is no longer the leader
11:20:42,402 AM [test-akka.actor.default-dispatcher-16] [INFO] RoleChangeNotifier - RoleChangeNotifier for member-1-shard-people-config48 , received role change from null to Follower
11:20:42,402 AM [test-akka.actor.default-dispatcher-16] [INFO] RoleChangeNotifier - RoleChangeNotifier for member-1-shard-people-config48 , registered listener akka://test/user/$$p
11:20:42,403 AM [test-akka.actor.default-dispatcher-16] [INFO] ShardManager - shard-manager-config48: Received role changed for member-1-shard-people-config48 from null to Follower
11:20:42,408 AM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - shard-manager-config48: findLocalShard : default
11:20:42,415 AM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - shard-manager-config48 : Sending Shutdown to Shard actor Actor[akka://test/user/member-1-shard-default-config48#749134338] with 10000 ms timeout
11:20:42,417 AM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - shard-manager-config48 : Local Shard replica for shard default has been removed
11:20:42,417 AM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - shard-manager-config48: persisting the shard list [people]
11:20:42,417 AM [main] [INFO] ShardManagerTest - testServerRemovedShardActorRunning ending
11:20:42,417 AM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config48 saved ShardManager snapshot successfully. Deleting the prev snapshot if available
11:20:42,417 AM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config48: Successfully deleted prior snapshots
11:20:42,519 AM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/member-1-shard-default-config48#749134338]
11:20:42,530 AM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - shard-manager-config48 : Successfully shut down Shard actor Actor[akka://test/user/member-1-shard-default-config48#749134338]
11:20:42,531 AM [main] [INFO] TestActorFactory - Killing actor TestActor[akka://test/user/$$p]
11:20:42,531 AM [test-shard-dispatcher-17] [INFO] Shard - Stopping Shard member-1-shard-people-config48
11:20:42,531 AM [test-shard-dispatcher-17] [DEBUG] MessageAssembler - member-1-shard-people-config48 (Follower): Closing
11:20:42,531 AM [test-shard-dispatcher-17] [DEBUG] Shard - member-1-shard-people-config48: Aborting 0 pending queued transactions
11:20:42,532 AM [test-akka.actor.default-dispatcher-5] [INFO] ShardManager - Stopping ShardManager shard-manager-config48
11:20:42,536 AM [main] [INFO] ShardManager - Starting ShardManager shard-manager-config49
11:20:42,537 AM [test-akka.actor.default-dispatcher-5] [INFO] ShardManager - Recovery complete : shard-manager-config49
11:20:42,537 AM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - shard-manager-config49: Creating local shard: member-1-shard-default-config49
11:20:42,537 AM [main] [INFO] ShardManager - shard-manager-config49: Received role changed for member-1-shard-default-config49 from null to Follower
11:20:42,538 AM [main] [INFO] ShardManager - shard-manager-config49: Received LeaderStateChanged message: LeaderStateChanged [memberId=member-1-shard-default-config49, leaderId=member-2-shard-default-config49, leaderPayloadVersion=13]
11:20:42,548 AM [main] [INFO] ShardManager - shard-manager-config49: Received MemberUp: memberName: MemberName{name=member-2}, address: akka://test
11:20:42,548 AM [main] [INFO] ShardInformation - updatePeerAddress for peer member-2-shard-default-config49 with address akka://test/user/shardmanager-config49/member-2-shard-default-config49
11:20:42,548 AM [main] [INFO] ShardManager - shard-manager-config49: All Shards are ready - data store config49 is ready
11:20:42,650 AM [main] [INFO] TestActorFactory - Killing actor TestActor[akka://test/user/$$q]
11:20:42,660 AM [main] [INFO] ShardManager - Stopping ShardManager shard-manager-config49
11:20:42,662 AM [main] [INFO] ShardManagerTest - testRestoreFromSnapshot starting
11:20:42,665 AM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Starting ShardManager shard-manager-config50
11:20:42,666 AM [test-akka.actor.default-dispatcher-5] [INFO] ShardManager - Recovery complete : shard-manager-config50
11:20:42,666 AM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - shard-manager-config50: Restoring from ShardManagerSnapshot: ShardManagerSnapshot [ShardList = [shard1, shard2, astronauts] ]
11:20:42,666 AM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - shard-manager-config50: onSnapshotOffer: ShardManagerSnapshot [ShardList = [shard1, shard2, astronauts] ]
11:20:42,666 AM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - shard-manager-config50: adding shard shard1
11:20:42,666 AM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - shard-manager-config50: adding shard shard2
11:20:42,666 AM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - shard-manager-config50: adding shard astronauts
11:20:42,666 AM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - shard-manager-config50: Creating local shard: member-1-shard-shard2-config50
11:20:42,666 AM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - shard-manager-config50: Creating local shard: member-1-shard-astronauts-config50
11:20:42,667 AM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - shard-manager-config50: Creating local shard: member-1-shard-shard1-config50
11:20:42,667 AM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1
11:20:42,667 AM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - Creating Shard member-1-shard-shard2-config50
11:20:42,667 AM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - Creating Shard member-1-shard-astronauts-config50
11:20:42,668 AM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - Creating Shard member-1-shard-shard1-config50
11:20:42,668 AM [test-shard-dispatcher-17] [INFO] Shard - Shard created : member-1-shard-shard2-config50, persistent : true
11:20:42,669 AM [test-shard-dispatcher-17] [INFO] Shard - Starting recovery for member-1-shard-shard2-config50 with journal batch size 1
11:20:42,670 AM [test-shard-dispatcher-19] [INFO] Shard - Shard created : member-1-shard-astronauts-config50, persistent : true
11:20:42,670 AM [test-shard-dispatcher-17] [INFO] Shard - Shard created : member-1-shard-shard1-config50, persistent : true
11:20:42,670 AM [test-akka.actor.default-dispatcher-5] [INFO] RoleChangeNotifier - RoleChangeNotifier:akka://test@127.0.0.1:2565/user/$$r/member-1-shard-shard2-config50/member-1-shard-shard2-config50-notifier#-1850329851 created and ready for shard:member-1-shard-shard2-config50
11:20:42,670 AM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardSnapshotActor - Actor created Actor[akka://test/user/$$r/member-1-shard-shard2-config50/shard-member-1:snapshot-read#-580503286]
11:20:42,670 AM [test-akka.actor.default-dispatcher-10] [INFO] RoleChangeNotifier - RoleChangeNotifier:akka://test@127.0.0.1:2565/user/$$r/member-1-shard-shard1-config50/member-1-shard-shard1-config50-notifier#-367796545 created and ready for shard:member-1-shard-shard1-config50
11:20:42,670 AM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardSnapshotActor - Actor created Actor[akka://test/user/$$r/member-1-shard-shard1-config50/shard-member-1:snapshot-read#-1777927848]
11:20:42,670 AM [test-akka.actor.default-dispatcher-11] [INFO] RoleChangeNotifier - RoleChangeNotifier:akka://test@127.0.0.1:2565/user/$$r/member-1-shard-astronauts-config50/member-1-shard-astronauts-config50-notifier#-199170725 created and ready for shard:member-1-shard-astronauts-config50
11:20:42,670 AM [test-shard-dispatcher-17] [INFO] Shard - Starting recovery for member-1-shard-shard1-config50 with journal batch size 1
11:20:42,672 AM [test-shard-dispatcher-21] [DEBUG] Shard - member-1-shard-shard2-config50: onReceiveRecover: Received message class akka.persistence.RecoveryCompleted$ from Actor[akka://test/deadLetters]
11:20:42,672 AM [test-shard-dispatcher-21] [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
11:20:42,672 AM [test-shard-dispatcher-17] [DEBUG] Shard - member-1-shard-shard1-config50: onReceiveRecover: Received message class akka.persistence.RecoveryCompleted$ from Actor[akka://test/deadLetters]
11:20:42,672 AM [test-shard-dispatcher-17] [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
11:20:42,672 AM [test-shard-dispatcher-21] [DEBUG] DataTreeChangeListenerSupport - member-1-shard-shard2-config50: onLeadershipChange, isLeader: false, hasLeader : false
11:20:42,672 AM [test-shard-dispatcher-21] [DEBUG] Shard - member-1-shard-shard2-config50: onStateChanged: Closing all transaction chains because shard member-1-shard-shard2-config50 is no longer the leader
11:20:42,672 AM [test-shard-dispatcher-17] [DEBUG] DataTreeChangeListenerSupport - member-1-shard-shard1-config50: onLeadershipChange, isLeader: false, hasLeader : false
11:20:42,672 AM [test-shard-dispatcher-17] [DEBUG] Shard - member-1-shard-shard1-config50: onStateChanged: Closing all transaction chains because shard member-1-shard-shard1-config50 is no longer the leader
11:20:42,672 AM [test-shard-dispatcher-21] [DEBUG] Shard - member-1-shard-shard2-config50 (Follower): Received TimeoutNow - switching to Candidate
11:20:42,672 AM [test-shard-dispatcher-21] [DEBUG] Shard - member-1-shard-shard2-config50 (Candidate): Election: Candidate has following voting peers: []
11:20:42,672 AM [test-shard-dispatcher-21] [DEBUG] Shard - member-1-shard-shard2-config50: Set currentTerm=1, votedFor=member-1-shard-shard2-config50
11:20:42,672 AM [test-shard-dispatcher-17] [DEBUG] Shard - member-1-shard-shard1-config50 (Follower): Received TimeoutNow - switching to Candidate
11:20:42,672 AM [test-shard-dispatcher-17] [DEBUG] Shard - member-1-shard-shard1-config50 (Candidate): Election: Candidate has following voting peers: []
11:20:42,672 AM [test-shard-dispatcher-21] [INFO] Shard - member-1-shard-shard2-config50 (Candidate): Starting new election term 1
11:20:42,672 AM [test-shard-dispatcher-17] [DEBUG] Shard - member-1-shard-shard1-config50: Set currentTerm=1, votedFor=member-1-shard-shard1-config50
11:20:42,672 AM [test-shard-dispatcher-21] [INFO] Shard - member-1-shard-shard2-config50 (Follower) :- Switching from behavior Follower to Candidate, election term: 1
11:20:42,672 AM [test-shard-dispatcher-21] [DEBUG] MessageAssembler - member-1-shard-shard2-config50 (Follower): Closing
11:20:42,672 AM [test-shard-dispatcher-21] [DEBUG] DataTreeChangeListenerSupport - member-1-shard-shard2-config50: onLeadershipChange, isLeader: false, hasLeader : false
11:20:42,672 AM [test-shard-dispatcher-21] [DEBUG] Shard - member-1-shard-shard2-config50: onStateChanged: Closing all transaction chains because shard member-1-shard-shard2-config50 is no longer the leader
11:20:42,672 AM [test-shard-dispatcher-17] [INFO] Shard - member-1-shard-shard1-config50 (Candidate): Starting new election term 1
11:20:42,672 AM [test-shard-dispatcher-17] [INFO] Shard - member-1-shard-shard1-config50 (Follower) :- Switching from behavior Follower to Candidate, election term: 1
11:20:42,672 AM [test-shard-dispatcher-17] [DEBUG] MessageAssembler - member-1-shard-shard1-config50 (Follower): Closing
11:20:42,672 AM [test-shard-dispatcher-17] [DEBUG] DataTreeChangeListenerSupport - member-1-shard-shard1-config50: onLeadershipChange, isLeader: false, hasLeader : false
11:20:42,672 AM [test-shard-dispatcher-17] [DEBUG] Shard - member-1-shard-shard1-config50: onStateChanged: Closing all transaction chains because shard member-1-shard-shard1-config50 is no longer the leader
11:20:42,672 AM [test-akka.actor.default-dispatcher-18] [INFO] RoleChangeNotifier - RoleChangeNotifier for member-1-shard-shard1-config50 , received role change from null to Follower
11:20:42,672 AM [test-akka.actor.default-dispatcher-18] [INFO] RoleChangeNotifier - RoleChangeNotifier for member-1-shard-shard1-config50 , received role change from Follower to Candidate
11:20:42,672 AM [test-akka.actor.default-dispatcher-18] [DEBUG] ShardSnapshotActor - Actor created Actor[akka://test/user/$$r/member-1-shard-astronauts-config50/shard-member-1:snapshot-read#398830562]
11:20:42,673 AM [test-akka.actor.default-dispatcher-18] [DEBUG] ShardManager - shard-manager-config50: Initializing shard [shard2]
11:20:42,673 AM [test-akka.actor.default-dispatcher-18] [DEBUG] ShardInformation - Shard member-1-shard-shard2-config50 is initialized
11:20:42,673 AM [test-akka.actor.default-dispatcher-18] [DEBUG] ShardManager - shard-manager-config50: Initializing shard [shard1]
11:20:42,673 AM [test-akka.actor.default-dispatcher-18] [DEBUG] ShardInformation - Shard member-1-shard-shard1-config50 is initialized
11:20:42,673 AM [test-shard-dispatcher-19] [INFO] Shard - Starting recovery for member-1-shard-astronauts-config50 with journal batch size 1
11:20:42,673 AM [test-akka.actor.default-dispatcher-5] [INFO] RoleChangeNotifier - RoleChangeNotifier for member-1-shard-shard2-config50 , received role change from null to Follower
11:20:42,673 AM [test-akka.actor.default-dispatcher-5] [INFO] RoleChangeNotifier - RoleChangeNotifier for member-1-shard-shard2-config50 , received role change from Follower to Candidate
11:20:42,674 AM [test-shard-dispatcher-21] [DEBUG] Shard - member-1-shard-shard2-config50 (Candidate): Received ElectionTimeout
11:20:42,674 AM [test-shard-dispatcher-21] [DEBUG] Shard - member-1-shard-shard2-config50 (Leader): Election: Leader has following peers: []
11:20:42,674 AM [test-shard-dispatcher-21] [INFO] Shard - member-1-shard-shard2-config50 (Candidate) :- Switching from behavior Candidate to Leader, election term: 1
11:20:42,674 AM [test-shard-dispatcher-21] [DEBUG] DataTreeChangeListenerSupport - member-1-shard-shard2-config50: onLeadershipChange, isLeader: true, hasLeader : true
11:20:42,674 AM [test-shard-dispatcher-21] [DEBUG] Shard - member-1-shard-shard2-config50: became leader with frontend state for []
11:20:42,674 AM [test-akka.actor.default-dispatcher-5] [INFO] RoleChangeNotifier - RoleChangeNotifier for member-1-shard-shard2-config50 , received role change from Candidate to Leader
11:20:42,674 AM [test-akka.actor.default-dispatcher-5] [INFO] RoleChangeNotifier - RoleChangeNotifier for member-1-shard-shard2-config50 , registered listener akka://test/user/$$r
11:20:42,674 AM [test-akka.actor.default-dispatcher-5] [INFO] ShardManager - shard-manager-config50: Received LeaderStateChanged message: LeaderStateChanged [memberId=member-1-shard-shard2-config50, leaderId=member-1-shard-shard2-config50, leaderPayloadVersion=13]
11:20:42,674 AM [test-akka.actor.default-dispatcher-5] [INFO] ShardManager - shard-manager-config50: Received role changed for member-1-shard-shard2-config50 from Candidate to Leader
11:20:42,674 AM [test-shard-dispatcher-17] [DEBUG] Shard - member-1-shard-astronauts-config50: onReceiveRecover: Received message class akka.persistence.RecoveryCompleted$ from Actor[akka://test/deadLetters]
11:20:42,675 AM [test-shard-dispatcher-17] [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
11:20:42,675 AM [test-shard-dispatcher-17] [DEBUG] DataTreeChangeListenerSupport - member-1-shard-astronauts-config50: onLeadershipChange, isLeader: false, hasLeader : false
11:20:42,675 AM [test-shard-dispatcher-17] [DEBUG] Shard - member-1-shard-astronauts-config50: onStateChanged: Closing all transaction chains because shard member-1-shard-astronauts-config50 is no longer the leader
11:20:42,675 AM [test-shard-dispatcher-17] [DEBUG] Shard - member-1-shard-astronauts-config50 (Follower): Received TimeoutNow - switching to Candidate
11:20:42,675 AM [test-akka.actor.default-dispatcher-23] [DEBUG] ShardManager - shard-manager-config50: Initializing shard [astronauts]
11:20:42,675 AM [test-shard-dispatcher-17] [DEBUG] Shard - member-1-shard-astronauts-config50 (Candidate): Election: Candidate has following voting peers: []
11:20:42,675 AM [test-akka.actor.default-dispatcher-23] [DEBUG] ShardInformation - Shard member-1-shard-astronauts-config50 is initialized
11:20:42,675 AM [test-shard-dispatcher-17] [DEBUG] Shard - member-1-shard-astronauts-config50: Set currentTerm=1, votedFor=member-1-shard-astronauts-config50
11:20:42,675 AM [test-akka.actor.default-dispatcher-23] [INFO] RoleChangeNotifier - RoleChangeNotifier for member-1-shard-astronauts-config50 , received role change from null to Follower
11:20:42,675 AM [test-shard-dispatcher-17] [INFO] Shard - member-1-shard-astronauts-config50 (Candidate): Starting new election term 1
11:20:42,675 AM [test-shard-dispatcher-17] [INFO] Shard - member-1-shard-astronauts-config50 (Follower) :- Switching from behavior Follower to Candidate, election term: 1
11:20:42,675 AM [test-shard-dispatcher-17] [DEBUG] MessageAssembler - member-1-shard-astronauts-config50 (Follower): Closing
11:20:42,675 AM [test-shard-dispatcher-17] [DEBUG] DataTreeChangeListenerSupport - member-1-shard-astronauts-config50: onLeadershipChange, isLeader: false, hasLeader : false
11:20:42,675 AM [test-shard-dispatcher-17] [DEBUG] Shard - member-1-shard-astronauts-config50: onStateChanged: Closing all transaction chains because shard member-1-shard-astronauts-config50 is no longer the leader
11:20:42,675 AM [test-akka.actor.default-dispatcher-10] [INFO] RoleChangeNotifier - RoleChangeNotifier for member-1-shard-astronauts-config50 , received role change from Follower to Candidate
11:20:42,677 AM [test-shard-dispatcher-19] [DEBUG] Shard - member-1-shard-astronauts-config50 (Candidate): Received ElectionTimeout
11:20:42,677 AM [test-shard-dispatcher-17] [DEBUG] Shard - member-1-shard-shard1-config50 (Candidate): Received ElectionTimeout
11:20:42,677 AM [test-shard-dispatcher-19] [DEBUG] Shard - member-1-shard-astronauts-config50 (Leader): Election: Leader has following peers: []
11:20:42,677 AM [test-shard-dispatcher-19] [INFO] Shard - member-1-shard-astronauts-config50 (Candidate) :- Switching from behavior Candidate to Leader, election term: 1
11:20:42,677 AM [test-shard-dispatcher-19] [DEBUG] DataTreeChangeListenerSupport - member-1-shard-astronauts-config50: onLeadershipChange, isLeader: true, hasLeader : true
11:20:42,677 AM [test-shard-dispatcher-17] [DEBUG] Shard - member-1-shard-shard1-config50 (Leader): Election: Leader has following peers: []
11:20:42,677 AM [test-shard-dispatcher-19] [DEBUG] Shard - member-1-shard-astronauts-config50: became leader with frontend state for []
11:20:42,677 AM [test-shard-dispatcher-17] [INFO] Shard - member-1-shard-shard1-config50 (Candidate) :- Switching from behavior Candidate to Leader, election term: 1
11:20:42,677 AM [test-akka.actor.default-dispatcher-10] [INFO] RoleChangeNotifier - RoleChangeNotifier for member-1-shard-astronauts-config50 , received role change from Candidate to Leader
11:20:42,677 AM [test-shard-dispatcher-17] [DEBUG] DataTreeChangeListenerSupport - member-1-shard-shard1-config50: onLeadershipChange, isLeader: true, hasLeader : true
11:20:42,677 AM [test-shard-dispatcher-17] [DEBUG] Shard - member-1-shard-shard1-config50: became leader with frontend state for []
11:20:42,677 AM [test-akka.actor.default-dispatcher-10] [INFO] RoleChangeNotifier - RoleChangeNotifier for member-1-shard-astronauts-config50 , registered listener akka://test/user/$$r
11:20:42,677 AM [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]
11:20:42,677 AM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - shard-manager-config50: Received role changed for member-1-shard-astronauts-config50 from Candidate to Leader
11:20:42,677 AM [test-akka.actor.default-dispatcher-10] [INFO] RoleChangeNotifier - RoleChangeNotifier for member-1-shard-shard1-config50 , received role change from Candidate to Leader
11:20:42,677 AM [test-akka.actor.default-dispatcher-10] [INFO] RoleChangeNotifier - RoleChangeNotifier for member-1-shard-shard1-config50 , registered listener akka://test/user/$$r
11:20:42,677 AM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - shard-manager-config50: Received LeaderStateChanged message: LeaderStateChanged [memberId=member-1-shard-shard1-config50, leaderId=member-1-shard-shard1-config50, leaderPayloadVersion=13]
11:20:42,677 AM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - shard-manager-config50: Received role changed for member-1-shard-shard1-config50 from Candidate to Leader
11:20:42,677 AM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - shard-manager-config50: All Shards are ready - data store config50 is ready
11:20:42,677 AM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - shard-manager-config50: findLocalShard : shard1
11:20:42,677 AM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - shard-manager-config50: findLocalShard : shard2
11:20:42,677 AM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - shard-manager-config50: findLocalShard : astronauts
11:20:42,678 AM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - shard-manager-config50: onGetSnapshot
11:20:42,678 AM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManagerGetSnapshotReplyActor - shard-manager-config50: Expecting 3 shard snapshot replies
11:20:42,678 AM [test-shard-dispatcher-17] [DEBUG] Shard - member-1-shard-shard2-config50: onGetSnapshot
11:20:42,678 AM [test-shard-dispatcher-19] [DEBUG] Shard - member-1-shard-astronauts-config50: onGetSnapshot
11:20:42,678 AM [test-shard-dispatcher-21] [DEBUG] Shard - member-1-shard-shard1-config50: onGetSnapshot
11:20:42,678 AM [test-shard-dispatcher-21] [DEBUG] Shard - member-1-shard-shard1-config50: Capturing Snapshot : lastLogEntry is null. Using snapshot values lastAppliedIndex -1 and lastAppliedTerm -1 instead.
11:20:42,678 AM [test-shard-dispatcher-19] [DEBUG] Shard - member-1-shard-astronauts-config50: Capturing Snapshot : lastLogEntry is null. Using snapshot values lastAppliedIndex -1 and lastAppliedTerm -1 instead.
11:20:42,678 AM [test-shard-dispatcher-17] [DEBUG] Shard - member-1-shard-shard2-config50: Capturing Snapshot : lastLogEntry is null. Using snapshot values lastAppliedIndex -1 and lastAppliedTerm -1 instead.
11:20:42,682 AM [test-shard-dispatcher-19] [DEBUG] Shard - member-1-shard-astronauts-config50: requesting serialization of snapshot MetadataShardDataTreeSnapshot{metadata={class org.opendaylight.controller.cluster.datastore.persisted.FrontendShardDataTreeSnapshotMetadata=FrontendShardDataTreeSnapshotMetadata{clients=[]}}}
11:20:42,682 AM [test-shard-dispatcher-21] [DEBUG] Shard - member-1-shard-shard1-config50: requesting serialization of snapshot MetadataShardDataTreeSnapshot{metadata={class org.opendaylight.controller.cluster.datastore.persisted.FrontendShardDataTreeSnapshotMetadata=FrontendShardDataTreeSnapshotMetadata{clients=[]}}}
11:20:42,682 AM [test-shard-dispatcher-17] [DEBUG] Shard - member-1-shard-shard2-config50: requesting serialization of snapshot MetadataShardDataTreeSnapshot{metadata={class org.opendaylight.controller.cluster.datastore.persisted.FrontendShardDataTreeSnapshotMetadata=FrontendShardDataTreeSnapshotMetadata{clients=[]}}}
11:20:42,682 AM [test-akka.actor.default-dispatcher-18] [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@697cd273, electionTerm=1, electionVotedFor=member-1-shard-astronauts-config50, ServerConfigPayload=null]]
11:20:42,683 AM [test-akka.actor.default-dispatcher-18] [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@14db7b7f, electionTerm=1, electionVotedFor=member-1-shard-shard1-config50, ServerConfigPayload=null]]
11:20:42,683 AM [test-akka.actor.default-dispatcher-18] [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@38c1744b, electionTerm=1, electionVotedFor=member-1-shard-shard2-config50, ServerConfigPayload=null]]
11:20:42,683 AM [test-akka.actor.default-dispatcher-18] [DEBUG] ShardManagerGetSnapshotReplyActor - shard-manager-config50: All shard snapshots received
11:20:42,683 AM [main] [INFO] ShardManagerTest - testRestoreFromSnapshot ending
11:20:42,785 AM [main] [INFO] TestActorFactory - Killing actor TestActor[akka://test/user/$$r]
11:20:42,786 AM [test-shard-dispatcher-17] [INFO] Shard - Stopping Shard member-1-shard-shard1-config50
11:20:42,786 AM [test-shard-dispatcher-21] [INFO] Shard - Stopping Shard member-1-shard-shard2-config50
11:20:42,786 AM [test-shard-dispatcher-19] [INFO] Shard - Stopping Shard member-1-shard-astronauts-config50
11:20:42,786 AM [test-shard-dispatcher-17] [DEBUG] MessageSlicer - member-1-shard-shard1-config50 (Leader)_slicer-id-232: Closing
11:20:42,786 AM [test-shard-dispatcher-21] [DEBUG] MessageSlicer - member-1-shard-shard2-config50 (Leader)_slicer-id-230: Closing
11:20:42,786 AM [test-shard-dispatcher-19] [DEBUG] MessageSlicer - member-1-shard-astronauts-config50 (Leader)_slicer-id-231: Closing
11:20:42,787 AM [test-shard-dispatcher-19] [DEBUG] Shard - member-1-shard-astronauts-config50: Aborting 0 pending queued transactions
11:20:42,787 AM [test-shard-dispatcher-21] [DEBUG] Shard - member-1-shard-shard2-config50: Aborting 0 pending queued transactions
11:20:42,786 AM [test-shard-dispatcher-17] [DEBUG] Shard - member-1-shard-shard1-config50: Aborting 0 pending queued transactions
11:20:42,788 AM [test-akka.actor.default-dispatcher-23] [INFO] ShardManager - Stopping ShardManager shard-manager-config50
11:20:42,789 AM [main] [INFO] ShardManagerTest - testOnCreateShardWithNoInitialSchemaContext starting
11:20:42,792 AM [test-akka.actor.default-dispatcher-23] [INFO] ShardManager - Starting ShardManager shard-manager-config51
11:20:42,793 AM [test-akka.actor.default-dispatcher-14] [INFO] ShardManager - Recovery complete : shard-manager-config51
11:20:42,803 AM [test-akka.actor.default-dispatcher-23] [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@43afba81]
11:20:42,803 AM [test-akka.actor.default-dispatcher-23] [DEBUG] ShardManager - shard-manager-config51 doCreateShard: shardId: member-1-shard-foo-config51, memberNames: [MemberName{name=member-1}], peerAddresses: {}, isActiveMember: true
11:20:42,803 AM [test-akka.actor.default-dispatcher-23] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1
11:20:42,803 AM [test-akka.actor.default-dispatcher-23] [DEBUG] ShardManager - Creating Shard member-1-shard-foo-config51
11:20:42,804 AM [test-akka.actor.default-dispatcher-23] [DEBUG] ShardManager - shard-manager-config51: findLocalShard : foo
11:20:42,804 AM [test-akka.actor.default-dispatcher-23] [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]
11:20:42,804 AM [test-shard-dispatcher-17] [INFO] Shard - Shard created : member-1-shard-foo-config51, persistent : true
11:20:42,805 AM [test-akka.actor.default-dispatcher-23] [INFO] RoleChangeNotifier - RoleChangeNotifier:akka://test@127.0.0.1:2565/user/$B/member-1-shard-foo-config51/member-1-shard-foo-config51-notifier#669774299 created and ready for shard:member-1-shard-foo-config51
11:20:42,805 AM [test-shard-dispatcher-17] [INFO] Shard - Starting recovery for member-1-shard-foo-config51 with journal batch size 1
11:20:42,806 AM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardSnapshotActor - Actor created Actor[akka://test/user/$B/member-1-shard-foo-config51/shard-member-1:snapshot-read#-1515335903]
11:20:42,807 AM [test-shard-dispatcher-17] [DEBUG] Shard - member-1-shard-foo-config51: onReceiveRecover: Received message class akka.persistence.RecoveryCompleted$ from Actor[akka://test/deadLetters]
11:20:42,807 AM [test-shard-dispatcher-17] [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
11:20:42,807 AM [test-akka.actor.default-dispatcher-23] [DEBUG] ShardManager - shard-manager-config51: Initializing shard [foo]
11:20:42,807 AM [test-akka.actor.default-dispatcher-23] [DEBUG] ShardInformation - Shard member-1-shard-foo-config51 is initialized
11:20:42,807 AM [test-akka.actor.default-dispatcher-23] [DEBUG] ShardInformation - Shard member-1-shard-foo-config51 is initialized - notifying 1 OnShardInitialized callbacks
11:20:42,807 AM [test-shard-dispatcher-17] [DEBUG] DataTreeChangeListenerSupport - member-1-shard-foo-config51: onLeadershipChange, isLeader: false, hasLeader : false
11:20:42,807 AM [test-shard-dispatcher-17] [DEBUG] Shard - member-1-shard-foo-config51: onStateChanged: Closing all transaction chains because shard member-1-shard-foo-config51 is no longer the leader
11:20:42,807 AM [main] [INFO] ShardManagerTest - testOnCreateShardWithNoInitialSchemaContext ending
11:20:42,807 AM [test-akka.actor.default-dispatcher-23] [INFO] RoleChangeNotifier - RoleChangeNotifier for member-1-shard-foo-config51 , received role change from null to Follower
11:20:42,807 AM [test-shard-dispatcher-17] [DEBUG] Shard - member-1-shard-foo-config51 (Follower): Received TimeoutNow - switching to Candidate
11:20:42,807 AM [test-shard-dispatcher-17] [DEBUG] Shard - member-1-shard-foo-config51 (Candidate): Election: Candidate has following voting peers: []
11:20:42,807 AM [test-shard-dispatcher-17] [DEBUG] Shard - member-1-shard-foo-config51: Set currentTerm=1, votedFor=member-1-shard-foo-config51
11:20:42,807 AM [test-shard-dispatcher-17] [INFO] Shard - member-1-shard-foo-config51 (Candidate): Starting new election term 1
11:20:42,807 AM [test-shard-dispatcher-17] [INFO] Shard - member-1-shard-foo-config51 (Follower) :- Switching from behavior Follower to Candidate, election term: 1
11:20:42,807 AM [test-shard-dispatcher-17] [DEBUG] MessageAssembler - member-1-shard-foo-config51 (Follower): Closing
11:20:42,807 AM [test-shard-dispatcher-17] [DEBUG] DataTreeChangeListenerSupport - member-1-shard-foo-config51: onLeadershipChange, isLeader: false, hasLeader : false
11:20:42,807 AM [test-shard-dispatcher-17] [DEBUG] Shard - member-1-shard-foo-config51: onStateChanged: Closing all transaction chains because shard member-1-shard-foo-config51 is no longer the leader
11:20:42,808 AM [test-akka.actor.default-dispatcher-10] [INFO] RoleChangeNotifier - RoleChangeNotifier for member-1-shard-foo-config51 , received role change from Follower to Candidate
11:20:42,808 AM [test-shard-dispatcher-17] [DEBUG] Shard - member-1-shard-foo-config51 (Candidate): Received ElectionTimeout
11:20:42,808 AM [test-shard-dispatcher-17] [DEBUG] Shard - member-1-shard-foo-config51 (Leader): Election: Leader has following peers: []
11:20:42,809 AM [test-shard-dispatcher-17] [INFO] Shard - member-1-shard-foo-config51 (Candidate) :- Switching from behavior Candidate to Leader, election term: 1
11:20:42,809 AM [test-shard-dispatcher-17] [DEBUG] DataTreeChangeListenerSupport - member-1-shard-foo-config51: onLeadershipChange, isLeader: true, hasLeader : true
11:20:42,809 AM [test-shard-dispatcher-17] [DEBUG] Shard - member-1-shard-foo-config51: became leader with frontend state for []
11:20:42,809 AM [test-akka.actor.default-dispatcher-10] [INFO] RoleChangeNotifier - RoleChangeNotifier for member-1-shard-foo-config51 , received role change from Candidate to Leader
11:20:42,809 AM [test-akka.actor.default-dispatcher-10] [INFO] RoleChangeNotifier - RoleChangeNotifier for member-1-shard-foo-config51 , registered listener akka://test/user/$B
11:20:42,809 AM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - shard-manager-config51: Received LeaderStateChanged message: LeaderStateChanged [memberId=member-1-shard-foo-config51, leaderId=member-1-shard-foo-config51, leaderPayloadVersion=13]
11:20:42,809 AM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - shard-manager-config51: Received role changed for member-1-shard-foo-config51 from Candidate to Leader
11:20:42,809 AM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - shard-manager-config51: All Shards are ready - data store config51 is ready
11:20:42,908 AM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/$B#108271613]
11:20:42,920 AM [test-shard-dispatcher-17] [INFO] Shard - Stopping Shard member-1-shard-foo-config51
11:20:42,920 AM [test-shard-dispatcher-17] [DEBUG] MessageSlicer - member-1-shard-foo-config51 (Leader)_slicer-id-234: Closing
11:20:42,920 AM [test-shard-dispatcher-17] [DEBUG] Shard - member-1-shard-foo-config51: Aborting 0 pending queued transactions
11:20:42,920 AM [test-akka.actor.default-dispatcher-23] [INFO] ShardManager - Stopping ShardManager shard-manager-config51
11:20:42,922 AM [main] [INFO] ShardManagerTest - testGetSnapshot starting
11:20:42,924 AM [test-akka.actor.default-dispatcher-23] [INFO] ShardManager - Starting ShardManager shard-manager-config52
11:20:42,925 AM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - Recovery complete : shard-manager-config52
11:20:42,925 AM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config52: Creating local shard: member-1-shard-shard2-config52
11:20:42,926 AM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config52: Creating local shard: member-1-shard-shard1-config52
11:20:42,935 AM [test-akka.actor.default-dispatcher-23] [DEBUG] ShardManager - shard-manager-config52: onGetSnapshot
11:20:42,935 AM [test-akka.actor.default-dispatcher-23] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1
11:20:42,935 AM [test-akka.actor.default-dispatcher-23] [DEBUG] ShardManager - Creating Shard member-1-shard-shard2-config52
11:20:42,936 AM [test-akka.actor.default-dispatcher-23] [DEBUG] ShardManager - Creating Shard member-1-shard-shard1-config52
11:20:42,936 AM [test-akka.actor.default-dispatcher-23] [DEBUG] ShardManager - shard-manager-config52: findLocalShard : shard1
11:20:42,936 AM [test-akka.actor.default-dispatcher-23] [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]
11:20:42,936 AM [test-shard-dispatcher-17] [INFO] Shard - Shard created : member-1-shard-shard2-config52, persistent : true
11:20:42,937 AM [test-shard-dispatcher-19] [INFO] Shard - Shard created : member-1-shard-shard1-config52, persistent : true
11:20:42,937 AM [test-shard-dispatcher-17] [INFO] Shard - Starting recovery for member-1-shard-shard2-config52 with journal batch size 1
11:20:42,937 AM [test-akka.actor.default-dispatcher-10] [INFO] RoleChangeNotifier - RoleChangeNotifier:akka://test@127.0.0.1:2565/user/$$s/member-1-shard-shard2-config52/member-1-shard-shard2-config52-notifier#1882849231 created and ready for shard:member-1-shard-shard2-config52
11:20:42,937 AM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardSnapshotActor - Actor created Actor[akka://test/user/$$s/member-1-shard-shard2-config52/shard-member-1:snapshot-read#-898849309]
11:20:42,938 AM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardSnapshotActor - Actor created Actor[akka://test/user/$$s/member-1-shard-shard1-config52/shard-member-1:snapshot-read#1055029903]
11:20:42,938 AM [test-shard-dispatcher-19] [INFO] Shard - Starting recovery for member-1-shard-shard1-config52 with journal batch size 1
11:20:42,939 AM [test-akka.actor.default-dispatcher-14] [INFO] RoleChangeNotifier - RoleChangeNotifier:akka://test@127.0.0.1:2565/user/$$s/member-1-shard-shard1-config52/member-1-shard-shard1-config52-notifier#-112951282 created and ready for shard:member-1-shard-shard1-config52
11:20:42,939 AM [test-shard-dispatcher-17] [DEBUG] Shard - member-1-shard-shard2-config52: onReceiveRecover: Received message class akka.persistence.RecoveryCompleted$ from Actor[akka://test/deadLetters]
11:20:42,939 AM [test-shard-dispatcher-17] [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
11:20:42,940 AM [test-shard-dispatcher-19] [DEBUG] Shard - member-1-shard-shard1-config52: onReceiveRecover: Received message class akka.persistence.RecoveryCompleted$ from Actor[akka://test/deadLetters]
11:20:42,940 AM [test-shard-dispatcher-19] [INFO] Shard - member-1-shard-shard1-config52: Recovery completed  - Switching actor to Follower - last log index = -1, last log term = -1, snapshot index = -1, snapshot term = -1, journal size = 0
11:20:42,940 AM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - shard-manager-config52: Initializing shard [shard2]
11:20:42,940 AM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardInformation - Shard member-1-shard-shard2-config52 is initialized
11:20:42,940 AM [test-shard-dispatcher-17] [DEBUG] DataTreeChangeListenerSupport - member-1-shard-shard2-config52: onLeadershipChange, isLeader: false, hasLeader : false
11:20:42,940 AM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - shard-manager-config52: Initializing shard [shard1]
11:20:42,940 AM [test-shard-dispatcher-17] [DEBUG] Shard - member-1-shard-shard2-config52: onStateChanged: Closing all transaction chains because shard member-1-shard-shard2-config52 is no longer the leader
11:20:42,940 AM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardInformation - Shard member-1-shard-shard1-config52 is initialized
11:20:42,940 AM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardInformation - Shard member-1-shard-shard1-config52 is initialized - notifying 1 OnShardInitialized callbacks
11:20:42,940 AM [test-shard-dispatcher-19] [DEBUG] DataTreeChangeListenerSupport - member-1-shard-shard1-config52: onLeadershipChange, isLeader: false, hasLeader : false
11:20:42,940 AM [test-shard-dispatcher-19] [DEBUG] Shard - member-1-shard-shard1-config52: onStateChanged: Closing all transaction chains because shard member-1-shard-shard1-config52 is no longer the leader
11:20:42,940 AM [test-shard-dispatcher-17] [DEBUG] Shard - member-1-shard-shard2-config52 (Follower): Received TimeoutNow - switching to Candidate
11:20:42,940 AM [test-akka.actor.default-dispatcher-14] [INFO] RoleChangeNotifier - RoleChangeNotifier for member-1-shard-shard2-config52 , received role change from null to Follower
11:20:42,940 AM [test-shard-dispatcher-17] [DEBUG] Shard - member-1-shard-shard2-config52 (Candidate): Election: Candidate has following voting peers: []
11:20:42,940 AM [test-shard-dispatcher-19] [DEBUG] Shard - member-1-shard-shard1-config52 (Follower): Received TimeoutNow - switching to Candidate
11:20:42,940 AM [test-shard-dispatcher-17] [DEBUG] Shard - member-1-shard-shard2-config52: Set currentTerm=1, votedFor=member-1-shard-shard2-config52
11:20:42,940 AM [test-akka.actor.default-dispatcher-14] [INFO] RoleChangeNotifier - RoleChangeNotifier for member-1-shard-shard1-config52 , received role change from null to Follower
11:20:42,940 AM [test-shard-dispatcher-19] [DEBUG] Shard - member-1-shard-shard1-config52 (Candidate): Election: Candidate has following voting peers: []
11:20:42,940 AM [test-shard-dispatcher-17] [INFO] Shard - member-1-shard-shard2-config52 (Candidate): Starting new election term 1
11:20:42,940 AM [test-shard-dispatcher-19] [DEBUG] Shard - member-1-shard-shard1-config52: Set currentTerm=1, votedFor=member-1-shard-shard1-config52
11:20:42,940 AM [test-shard-dispatcher-17] [INFO] Shard - member-1-shard-shard2-config52 (Follower) :- Switching from behavior Follower to Candidate, election term: 1
11:20:42,940 AM [test-shard-dispatcher-17] [DEBUG] MessageAssembler - member-1-shard-shard2-config52 (Follower): Closing
11:20:42,940 AM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config52: findLocalShard : shard2
11:20:42,940 AM [test-shard-dispatcher-17] [DEBUG] DataTreeChangeListenerSupport - member-1-shard-shard2-config52: onLeadershipChange, isLeader: false, hasLeader : false
11:20:42,940 AM [test-shard-dispatcher-17] [DEBUG] Shard - member-1-shard-shard2-config52: onStateChanged: Closing all transaction chains because shard member-1-shard-shard2-config52 is no longer the leader
11:20:42,940 AM [test-shard-dispatcher-19] [INFO] Shard - member-1-shard-shard1-config52 (Candidate): Starting new election term 1
11:20:42,940 AM [test-shard-dispatcher-19] [INFO] Shard - member-1-shard-shard1-config52 (Follower) :- Switching from behavior Follower to Candidate, election term: 1
11:20:42,940 AM [test-shard-dispatcher-19] [DEBUG] MessageAssembler - member-1-shard-shard1-config52 (Follower): Closing
11:20:42,940 AM [test-akka.actor.default-dispatcher-10] [INFO] RoleChangeNotifier - RoleChangeNotifier for member-1-shard-shard2-config52 , received role change from Follower to Candidate
11:20:42,940 AM [test-shard-dispatcher-19] [DEBUG] DataTreeChangeListenerSupport - member-1-shard-shard1-config52: onLeadershipChange, isLeader: false, hasLeader : false
11:20:42,940 AM [test-shard-dispatcher-19] [DEBUG] Shard - member-1-shard-shard1-config52: onStateChanged: Closing all transaction chains because shard member-1-shard-shard1-config52 is no longer the leader
11:20:42,940 AM [test-akka.actor.default-dispatcher-10] [INFO] RoleChangeNotifier - RoleChangeNotifier for member-1-shard-shard1-config52 , received role change from Follower to Candidate
11:20:42,940 AM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config52: onGetSnapshot
11:20:42,941 AM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManagerGetSnapshotReplyActor - shard-manager-config52: Expecting 2 shard snapshot replies
11:20:42,941 AM [test-shard-dispatcher-19] [DEBUG] Shard - member-1-shard-shard2-config52 (Candidate): Received ElectionTimeout
11:20:42,941 AM [test-shard-dispatcher-19] [DEBUG] Shard - member-1-shard-shard2-config52 (Leader): Election: Leader has following peers: []
11:20:42,941 AM [test-shard-dispatcher-17] [DEBUG] Shard - member-1-shard-shard1-config52 (Candidate): Received ElectionTimeout
11:20:42,941 AM [test-shard-dispatcher-19] [INFO] Shard - member-1-shard-shard2-config52 (Candidate) :- Switching from behavior Candidate to Leader, election term: 1
11:20:42,941 AM [test-shard-dispatcher-19] [DEBUG] DataTreeChangeListenerSupport - member-1-shard-shard2-config52: onLeadershipChange, isLeader: true, hasLeader : true
11:20:42,941 AM [test-shard-dispatcher-17] [DEBUG] Shard - member-1-shard-shard1-config52 (Leader): Election: Leader has following peers: []
11:20:42,941 AM [test-shard-dispatcher-19] [DEBUG] Shard - member-1-shard-shard2-config52: became leader with frontend state for []
11:20:42,942 AM [test-shard-dispatcher-17] [INFO] Shard - member-1-shard-shard1-config52 (Candidate) :- Switching from behavior Candidate to Leader, election term: 1
11:20:42,942 AM [test-akka.actor.default-dispatcher-14] [INFO] RoleChangeNotifier - RoleChangeNotifier for member-1-shard-shard2-config52 , received role change from Candidate to Leader
11:20:42,942 AM [test-shard-dispatcher-17] [DEBUG] DataTreeChangeListenerSupport - member-1-shard-shard1-config52: onLeadershipChange, isLeader: true, hasLeader : true
11:20:42,942 AM [test-shard-dispatcher-19] [DEBUG] Shard - member-1-shard-shard2-config52: onGetSnapshot
11:20:42,942 AM [test-akka.actor.default-dispatcher-14] [INFO] RoleChangeNotifier - RoleChangeNotifier for member-1-shard-shard2-config52 , registered listener akka://test/user/$$s
11:20:42,942 AM [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.
11:20:42,942 AM [test-shard-dispatcher-17] [DEBUG] Shard - member-1-shard-shard1-config52: became leader with frontend state for []
11:20:42,942 AM [test-akka.actor.default-dispatcher-14] [INFO] ShardManager - shard-manager-config52: Received LeaderStateChanged message: LeaderStateChanged [memberId=member-1-shard-shard2-config52, leaderId=member-1-shard-shard2-config52, leaderPayloadVersion=13]
11:20:42,942 AM [test-akka.actor.default-dispatcher-14] [INFO] ShardManager - shard-manager-config52: Received role changed for member-1-shard-shard2-config52 from Candidate to Leader
11:20:42,942 AM [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=[]}}}
11:20:42,942 AM [test-shard-dispatcher-17] [DEBUG] Shard - member-1-shard-shard1-config52: onGetSnapshot
11:20:42,942 AM [test-shard-dispatcher-17] [DEBUG] Shard - member-1-shard-shard1-config52: Capturing Snapshot : lastLogEntry is null. Using snapshot values lastAppliedIndex -1 and lastAppliedTerm -1 instead.
11:20:42,942 AM [test-akka.actor.default-dispatcher-23] [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@6863db68, electionTerm=1, electionVotedFor=member-1-shard-shard2-config52, ServerConfigPayload=null]]
11:20:42,942 AM [test-akka.actor.default-dispatcher-23] [INFO] RoleChangeNotifier - RoleChangeNotifier for member-1-shard-shard1-config52 , received role change from Candidate to Leader
11:20:42,942 AM [test-akka.actor.default-dispatcher-23] [INFO] RoleChangeNotifier - RoleChangeNotifier for member-1-shard-shard1-config52 , registered listener akka://test/user/$$s
11:20:42,943 AM [test-akka.actor.default-dispatcher-23] [INFO] ShardManager - shard-manager-config52: Received LeaderStateChanged message: LeaderStateChanged [memberId=member-1-shard-shard1-config52, leaderId=member-1-shard-shard1-config52, leaderPayloadVersion=13]
11:20:42,943 AM [test-shard-dispatcher-17] [DEBUG] Shard - member-1-shard-shard1-config52: requesting serialization of snapshot MetadataShardDataTreeSnapshot{metadata={class org.opendaylight.controller.cluster.datastore.persisted.FrontendShardDataTreeSnapshotMetadata=FrontendShardDataTreeSnapshotMetadata{clients=[]}}}
11:20:42,943 AM [test-akka.actor.default-dispatcher-23] [INFO] ShardManager - shard-manager-config52: Received role changed for member-1-shard-shard1-config52 from Candidate to Leader
11:20:42,943 AM [test-akka.actor.default-dispatcher-23] [INFO] ShardManager - shard-manager-config52: All Shards are ready - data store config52 is ready
11:20:42,943 AM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManagerGetSnapshotReplyActor - shard-manager-config52: Received GetSnapshotReply [id=member-1-shard-shard1-config52, snapshot=Snapshot [lastIndex=-1, lastTerm=-1, lastAppliedIndex=-1, lastAppliedTerm=-1, unAppliedEntries size=0, state=org.opendaylight.controller.cluster.datastore.persisted.ShardSnapshotState@5aa5b8a3, electionTerm=1, electionVotedFor=member-1-shard-shard1-config52, ServerConfigPayload=null]]
11:20:42,943 AM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManagerGetSnapshotReplyActor - shard-manager-config52: All shard snapshots received
11:20:42,954 AM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - shard-manager-config52: onAddShardReplica: AddShardReplica[ShardName=astronauts]
11:20:42,954 AM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - shard-manager-config52: Sending AddServer message to peer akka://test@127.0.0.1:2565/system/testProbe-631#-203079938 for shard member-1-shard-astronauts-config52
11:20:42,955 AM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - shard-manager-config52: Received AddServerReply{status=OK, leaderHint=} for shard astronauts from leader akka://test@127.0.0.1:2565/system/testProbe-631#-203079938
11:20:42,955 AM [test-shard-dispatcher-17] [INFO] Shard - Shard created : member-1-shard-astronauts-config52, persistent : true
11:20:42,955 AM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - shard-manager-config52: Leader shard successfully added the replica shard astronauts
11:20:42,955 AM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardInformation - Sending new DatastoreContext to member-1-shard-astronauts-config52
11:20:42,955 AM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - shard-manager-config52: persisting the shard list [shard2, astronauts, shard1]
11:20:42,956 AM [test-akka.actor.default-dispatcher-14] [INFO] RoleChangeNotifier - RoleChangeNotifier:akka://test@127.0.0.1:2565/user/$$s/member-1-shard-astronauts-config52/member-1-shard-astronauts-config52-notifier#1559453726 created and ready for shard:member-1-shard-astronauts-config52
11:20:42,956 AM [test-akka.actor.default-dispatcher-16] [DEBUG] ShardSnapshotActor - Actor created Actor[akka://test/user/$$s/member-1-shard-astronauts-config52/shard-member-1:snapshot-read#-650852380]
11:20:42,956 AM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - shard-manager-config52 saved ShardManager snapshot successfully. Deleting the prev snapshot if available
11:20:42,956 AM [test-shard-dispatcher-17] [INFO] Shard - Starting recovery for member-1-shard-astronauts-config52 with journal batch size 1
11:20:42,956 AM [test-akka.actor.default-dispatcher-16] [DEBUG] ShardManager - shard-manager-config52: findLocalShard : astronauts
11:20:42,956 AM [test-akka.actor.default-dispatcher-16] [DEBUG] ShardManager - shard-manager-config52: Scheduling 600 ms timer to wait for shard ShardInformation [shardId=member-1-shard-astronauts-config52, leaderAvailable=false, actorInitialized=false, followerSyncStatus=false, role=null, leaderId=null, activeMember=true]
11:20:42,956 AM [test-akka.actor.default-dispatcher-22] [DEBUG] ShardManager - shard-manager-config52: Successfully deleted prior snapshots
11:20:42,957 AM [test-shard-dispatcher-17] [DEBUG] Shard - member-1-shard-astronauts-config52: onReceiveRecover: Received message class akka.persistence.RecoveryCompleted$ from Actor[akka://test/deadLetters]
11:20:42,957 AM [test-shard-dispatcher-17] [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
11:20:42,957 AM [test-akka.actor.default-dispatcher-22] [DEBUG] ShardManager - shard-manager-config52: Initializing shard [astronauts]
11:20:42,957 AM [test-akka.actor.default-dispatcher-22] [DEBUG] ShardInformation - Shard member-1-shard-astronauts-config52 is initialized
11:20:42,957 AM [test-akka.actor.default-dispatcher-22] [DEBUG] ShardInformation - Shard member-1-shard-astronauts-config52 is initialized - notifying 1 OnShardInitialized callbacks
11:20:42,957 AM [test-shard-dispatcher-17] [DEBUG] DataTreeChangeListenerSupport - member-1-shard-astronauts-config52: onLeadershipChange, isLeader: false, hasLeader : false
11:20:42,957 AM [test-shard-dispatcher-17] [DEBUG] Shard - member-1-shard-astronauts-config52: onStateChanged: Closing all transaction chains because shard member-1-shard-astronauts-config52 is no longer the leader
11:20:42,957 AM [test-akka.actor.default-dispatcher-22] [INFO] RoleChangeNotifier - RoleChangeNotifier for member-1-shard-astronauts-config52 , received role change from null to Follower
11:20:42,957 AM [test-akka.actor.default-dispatcher-22] [DEBUG] ShardManager - shard-manager-config52: onGetSnapshot
11:20:42,957 AM [test-shard-dispatcher-17] [INFO] DefaultConfigParamsImpl - Trying to use custom RaftPolicy org.opendaylight.controller.cluster.raft.policy.DisableElectionsRaftPolicy
11:20:42,958 AM [test-shard-dispatcher-17] [DEBUG] Shard - member-1-shard-astronauts-config52: RaftPolicy used with prev.config org.opendaylight.controller.cluster.raft.policy.DisableElectionsRaftPolicy, RaftPolicy used with newConfig null
11:20:42,958 AM [test-shard-dispatcher-17] [DEBUG] Shard - member-1-shard-astronauts-config52: Re-initializing to Follower with previous leaderId null
11:20:42,958 AM [test-shard-dispatcher-17] [DEBUG] MessageAssembler - member-1-shard-astronauts-config52 (Follower): Closing
11:20:42,958 AM [test-shard-dispatcher-17] [DEBUG] DataTreeChangeListenerSupport - member-1-shard-astronauts-config52: onLeadershipChange, isLeader: false, hasLeader : false
11:20:42,958 AM [test-shard-dispatcher-17] [DEBUG] Shard - member-1-shard-astronauts-config52: onStateChanged: Closing all transaction chains because shard member-1-shard-astronauts-config52 is no longer the leader
11:20:42,958 AM [test-shard-dispatcher-17] [DEBUG] Shard - member-1-shard-astronauts-config52 (Follower): Received TimeoutNow - switching to Candidate
11:20:42,958 AM [test-shard-dispatcher-17] [DEBUG] Shard - member-1-shard-astronauts-config52 (Candidate): Election: Candidate has following voting peers: []
11:20:42,958 AM [test-shard-dispatcher-17] [DEBUG] Shard - member-1-shard-astronauts-config52: Set currentTerm=1, votedFor=member-1-shard-astronauts-config52
11:20:42,958 AM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardManagerGetSnapshotReplyActor - shard-manager-config52: Expecting 3 shard snapshot replies
11:20:42,958 AM [test-shard-dispatcher-17] [INFO] Shard - member-1-shard-astronauts-config52 (Candidate): Starting new election term 1
11:20:42,958 AM [test-shard-dispatcher-19] [DEBUG] Shard - member-1-shard-shard2-config52: onGetSnapshot
11:20:42,958 AM [test-shard-dispatcher-17] [INFO] Shard - member-1-shard-astronauts-config52 (Follower) :- Switching from behavior Follower to Candidate, election term: 1
11:20:42,958 AM [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.
11:20:42,958 AM [test-shard-dispatcher-17] [DEBUG] MessageAssembler - member-1-shard-astronauts-config52 (Follower): Closing
11:20:42,958 AM [test-shard-dispatcher-17] [DEBUG] DataTreeChangeListenerSupport - member-1-shard-astronauts-config52: onLeadershipChange, isLeader: false, hasLeader : false
11:20:42,958 AM [test-shard-dispatcher-17] [DEBUG] Shard - member-1-shard-astronauts-config52: onStateChanged: Closing all transaction chains because shard member-1-shard-astronauts-config52 is no longer the leader
11:20:42,958 AM [test-shard-dispatcher-21] [DEBUG] Shard - member-1-shard-shard1-config52: onGetSnapshot
11:20:42,958 AM [test-shard-dispatcher-21] [DEBUG] Shard - member-1-shard-shard1-config52: Capturing Snapshot : lastLogEntry is null. Using snapshot values lastAppliedIndex -1 and lastAppliedTerm -1 instead.
11:20:42,958 AM [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=[]}}}
11:20:42,958 AM [test-akka.actor.default-dispatcher-11] [INFO] RoleChangeNotifier - RoleChangeNotifier for member-1-shard-astronauts-config52 , received role change from Follower to Candidate
11:20:42,959 AM [test-shard-dispatcher-21] [DEBUG] Shard - member-1-shard-shard1-config52: requesting serialization of snapshot MetadataShardDataTreeSnapshot{metadata={class org.opendaylight.controller.cluster.datastore.persisted.FrontendShardDataTreeSnapshotMetadata=FrontendShardDataTreeSnapshotMetadata{clients=[]}}}
11:20:42,959 AM [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@6262372e, electionTerm=1, electionVotedFor=member-1-shard-shard2-config52, ServerConfigPayload=null]]
11:20:42,959 AM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManagerGetSnapshotReplyActor - shard-manager-config52: Received GetSnapshotReply [id=member-1-shard-shard1-config52, snapshot=Snapshot [lastIndex=-1, lastTerm=-1, lastAppliedIndex=-1, lastAppliedTerm=-1, unAppliedEntries size=0, state=org.opendaylight.controller.cluster.datastore.persisted.ShardSnapshotState@91940ee, electionTerm=1, electionVotedFor=member-1-shard-shard1-config52, ServerConfigPayload=null]]
11:20:42,959 AM [test-shard-dispatcher-20] [DEBUG] Shard - member-1-shard-astronauts-config52 (Candidate): Received ElectionTimeout
11:20:42,959 AM [test-shard-dispatcher-20] [DEBUG] Shard - member-1-shard-astronauts-config52 (Leader): Election: Leader has following peers: []
11:20:42,959 AM [test-shard-dispatcher-20] [INFO] Shard - member-1-shard-astronauts-config52 (Candidate) :- Switching from behavior Candidate to Leader, election term: 1
11:20:42,959 AM [test-shard-dispatcher-20] [DEBUG] DataTreeChangeListenerSupport - member-1-shard-astronauts-config52: onLeadershipChange, isLeader: true, hasLeader : true
11:20:42,959 AM [test-shard-dispatcher-20] [DEBUG] Shard - member-1-shard-astronauts-config52: became leader with frontend state for []
11:20:42,959 AM [test-akka.actor.default-dispatcher-11] [INFO] RoleChangeNotifier - RoleChangeNotifier for member-1-shard-astronauts-config52 , received role change from Candidate to Leader
11:20:42,960 AM [test-shard-dispatcher-20] [DEBUG] Shard - member-1-shard-astronauts-config52: onGetSnapshot
11:20:42,960 AM [test-akka.actor.default-dispatcher-11] [INFO] RoleChangeNotifier - RoleChangeNotifier for member-1-shard-astronauts-config52 , registered listener akka://test/user/$$s
11:20:42,960 AM [test-shard-dispatcher-20] [DEBUG] Shard - member-1-shard-astronauts-config52: Capturing Snapshot : lastLogEntry is null. Using snapshot values lastAppliedIndex -1 and lastAppliedTerm -1 instead.
11:20:42,960 AM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - shard-manager-config52: Received LeaderStateChanged message: LeaderStateChanged [memberId=member-1-shard-astronauts-config52, leaderId=member-1-shard-astronauts-config52, leaderPayloadVersion=13]
11:20:42,960 AM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - shard-manager-config52: Received role changed for member-1-shard-astronauts-config52 from Candidate to Leader
11:20:42,960 AM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - shard-manager-config52: All Shards are ready - data store config52 is ready
11:20:42,960 AM [test-shard-dispatcher-20] [DEBUG] Shard - member-1-shard-astronauts-config52: requesting serialization of snapshot MetadataShardDataTreeSnapshot{metadata={class org.opendaylight.controller.cluster.datastore.persisted.FrontendShardDataTreeSnapshotMetadata=FrontendShardDataTreeSnapshotMetadata{clients=[]}}}
11:20:42,960 AM [test-akka.actor.default-dispatcher-22] [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@16f04ef1, electionTerm=1, electionVotedFor=member-1-shard-astronauts-config52, ServerConfigPayload=null]]
11:20:42,960 AM [test-akka.actor.default-dispatcher-22] [DEBUG] ShardManagerGetSnapshotReplyActor - shard-manager-config52: All shard snapshots received
11:20:42,963 AM [main] [INFO] ShardManagerTest - testGetSnapshot ending
11:20:43,65 AM [main] [INFO] TestActorFactory - Killing actor TestActor[akka://test/user/$$s]
11:20:43,77 AM [test-shard-dispatcher-20] [INFO] Shard - Stopping Shard member-1-shard-shard1-config52
11:20:43,77 AM [test-shard-dispatcher-19] [INFO] Shard - Stopping Shard member-1-shard-astronauts-config52
11:20:43,77 AM [test-shard-dispatcher-20] [DEBUG] MessageSlicer - member-1-shard-shard1-config52 (Leader)_slicer-id-238: Closing
11:20:43,77 AM [test-shard-dispatcher-19] [DEBUG] MessageSlicer - member-1-shard-astronauts-config52 (Leader)_slicer-id-240: Closing
11:20:43,77 AM [test-shard-dispatcher-17] [INFO] Shard - Stopping Shard member-1-shard-shard2-config52
11:20:43,77 AM [test-shard-dispatcher-17] [DEBUG] MessageSlicer - member-1-shard-shard2-config52 (Leader)_slicer-id-237: Closing
11:20:43,77 AM [test-shard-dispatcher-20] [DEBUG] Shard - member-1-shard-shard1-config52: Aborting 0 pending queued transactions
11:20:43,77 AM [test-shard-dispatcher-19] [DEBUG] Shard - member-1-shard-astronauts-config52: Aborting 0 pending queued transactions
11:20:43,77 AM [test-shard-dispatcher-17] [DEBUG] Shard - member-1-shard-shard2-config52: Aborting 0 pending queued transactions
11:20:43,77 AM [test-akka.actor.default-dispatcher-22] [INFO] ShardManager - Stopping ShardManager shard-manager-config52
11:20:43,79 AM [main] [INFO] ShardManagerTest - testWhenMultipleShardsPresentSyncStatusMustBeTrueForAllShards starting
11:20:43,83 AM [main] [INFO] ShardManager - Starting ShardManager shard-manager-config53
11:20:43,84 AM [test-akka.actor.default-dispatcher-22] [INFO] ShardManager - Recovery complete : shard-manager-config53
11:20:43,84 AM [test-akka.actor.default-dispatcher-22] [DEBUG] ShardManager - shard-manager-config53: Creating local shard: member-1-shard-default-config53
11:20:43,85 AM [test-akka.actor.default-dispatcher-22] [DEBUG] ShardManager - shard-manager-config53: Creating local shard: member-1-shard-astronauts-config53
11:20:43,85 AM [main] [INFO] ShardManager - shard-manager-config53: Received role changed for member-1-shard-default-config53 from Follower to Leader
11:20:43,85 AM [main] [INFO] ShardManager - shard-manager-config53: Received role changed for member-1-shard-astronauts-config53 from Follower to Leader
11:20:43,85 AM [main] [INFO] ShardManager - shard-manager-config53: Received role changed for member-1-shard-astronauts-config53 from Leader to Follower
11:20:43,85 AM [main] [INFO] ShardManager - shard-manager-config53 Received follower initial sync status for member-1-shard-astronauts-config53 status sync done true
11:20:43,85 AM [main] [INFO] ShardManagerTest - testWhenMultipleShardsPresentSyncStatusMustBeTrueForAllShards ending
11:20:43,186 AM [main] [INFO] TestActorFactory - Killing actor TestActor[akka://test/user/$$t]
11:20:43,197 AM [main] [INFO] ShardManager - Stopping ShardManager shard-manager-config53
11:20:43,199 AM [main] [INFO] ShardManagerTest - testAddShardReplicaWithFindPrimaryTimeout starting
11:20:43,201 AM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Starting ShardManager shard-manager-config54
11:20:43,204 AM [test-akka.actor.default-dispatcher-22] [INFO] ShardManager - Recovery complete : shard-manager-config54
11:20:43,212 AM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1
11:20:43,212 AM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - shard-manager-config54: Received MemberUp: memberName: MemberName{name=member-2}, address: akka://non-existent@127.0.0.1:5
11:20:43,212 AM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - shard-manager-config54: All Shards are ready - data store config54 is ready
11:20:43,212 AM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config54: onAddShardReplica: AddShardReplica[ShardName=astronauts]
11:20:43,212 AM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config54: In findPrimary: org.opendaylight.controller.cluster.datastore.messages.FindPrimary [shardName=astronauts, waitUntilReady=true]
11:20:43,212 AM [test-akka.actor.default-dispatcher-11] [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]
11:20:43,225 AM [test-akka.actor.default-dispatcher-11] [WARN] Materializer - [outbound connection to [akka://non-existent@127.0.0.1:5], message stream] Upstream failed, cause: StreamTcpException: Tcp command [Connect(127.0.0.1/<unresolved>:5,None,List(),Some(5000 milliseconds),true)] failed because of java.net.ConnectException: Connection refused
11:20:43,229 AM [test-akka.actor.default-dispatcher-11] [WARN] Materializer - [outbound connection to [akka://non-existent@127.0.0.1:5], control stream] Upstream failed, cause: StreamTcpException: Tcp command [Connect(127.0.0.1/<unresolved>:5,None,List(),Some(5000 milliseconds),true)] failed because of java.net.ConnectException: Connection refused
11:20:43,423 AM [test-akka.actor.default-dispatcher-11] [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#-1394746970]] 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.
11:20:43,423 AM [main] [INFO] ShardManagerTest - testAddShardReplicaWithFindPrimaryTimeout ending
11:20:43,525 AM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/shardmanager-config54#-1394746970]
11:20:43,536 AM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Stopping ShardManager shard-manager-config54
11:20:43,537 AM [main] [INFO] ShardManagerTest - testOnCreateShard starting
11:20:43,539 AM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Starting ShardManager shard-manager-config55
11:20:43,541 AM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Recovery complete : shard-manager-config55
11:20:43,541 AM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1
11:20:43,551 AM [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@51c40bfe]
11:20:43,551 AM [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
11:20:43,552 AM [test-shard-dispatcher-17] [INFO] Shard - Shard created : member-1-shard-foo-config55, persistent : false
11:20:43,554 AM [test-shard-dispatcher-17] [INFO] Shard - Starting recovery for member-1-shard-foo-config55 with journal batch size 1
11:20:43,555 AM [test-akka.actor.default-dispatcher-22] [DEBUG] ShardSnapshotActor - Actor created Actor[akka://test/user/$C/member-1-shard-foo-config55/shard-member-1:snapshot-read#-1655486356]
11:20:43,555 AM [test-akka.actor.default-dispatcher-11] [INFO] RoleChangeNotifier - RoleChangeNotifier:akka://test@127.0.0.1:2565/user/$C/member-1-shard-foo-config55/member-1-shard-foo-config55-notifier#-92575537 created and ready for shard:member-1-shard-foo-config55
11:20:43,556 AM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config55: findLocalShard : foo
11:20:43,556 AM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config55: Scheduling 300000 ms timer to wait for shard ShardInformation [shardId=member-1-shard-foo-config55, leaderAvailable=false, actorInitialized=false, followerSyncStatus=false, role=null, leaderId=null, activeMember=true]
11:20:43,561 AM [test-shard-dispatcher-17] [DEBUG] Shard - member-1-shard-foo-config55: onReceiveRecover: Received message class akka.persistence.RecoveryCompleted$ from Actor[akka://test/deadLetters]
11:20:43,561 AM [test-shard-dispatcher-17] [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
11:20:43,561 AM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config55: Initializing shard [foo]
11:20:43,561 AM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardInformation - Shard member-1-shard-foo-config55 is initialized
11:20:43,561 AM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardInformation - Shard member-1-shard-foo-config55 is initialized - notifying 1 OnShardInitialized callbacks
11:20:43,561 AM [test-shard-dispatcher-17] [DEBUG] DataTreeChangeListenerSupport - member-1-shard-foo-config55: onLeadershipChange, isLeader: false, hasLeader : false
11:20:43,561 AM [test-shard-dispatcher-17] [DEBUG] Shard - member-1-shard-foo-config55: onStateChanged: Closing all transaction chains because shard member-1-shard-foo-config55 is no longer the leader
11:20:43,561 AM [test-akka.actor.default-dispatcher-11] [INFO] RoleChangeNotifier - RoleChangeNotifier for member-1-shard-foo-config55 , received role change from null to Follower
11:20:43,561 AM [test-akka.actor.default-dispatcher-18] [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@51c40bfe]
11:20:43,561 AM [test-akka.actor.default-dispatcher-11] [INFO] RoleChangeNotifier - RoleChangeNotifier for member-1-shard-foo-config55 , registered listener akka://test/user/$C
11:20:43,561 AM [test-akka.actor.default-dispatcher-18] [DEBUG] ShardManager - shard-manager-config55: Shard foo already exists
11:20:43,561 AM [main] [INFO] ShardManagerTest - testOnCreateShard ending
11:20:43,561 AM [test-akka.actor.default-dispatcher-18] [INFO] ShardManager - shard-manager-config55: Received role changed for member-1-shard-foo-config55 from null to Follower
11:20:43,663 AM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/$C#1323388752]
11:20:43,674 AM [test-shard-dispatcher-17] [INFO] Shard - Stopping Shard member-1-shard-foo-config55
11:20:43,674 AM [test-shard-dispatcher-17] [DEBUG] MessageAssembler - member-1-shard-foo-config55 (Follower): Closing
11:20:43,674 AM [test-shard-dispatcher-17] [DEBUG] Shard - member-1-shard-foo-config55: Aborting 0 pending queued transactions
11:20:43,674 AM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Stopping ShardManager shard-manager-config55
11:20:43,680 AM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Stopping ShardManager shard-manager-config1
11:20:43,680 AM [test-akka.actor.default-dispatcher-18] [INFO] ShardManager - Stopping ShardManager shard-manager-config35
11:20:43,680 AM [test-akka.actor.default-dispatcher-22] [INFO] ShardManager - Stopping ShardManager shard-manager-config43
11:20:43,680 AM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Stopping ShardManager shard-manager-config11
11:20:43,680 AM [test-akka.actor.default-dispatcher-18] [INFO] ShardManager - Stopping ShardManager shard-manager-config21
11:20:43,680 AM [test-akka.actor.default-dispatcher-22] [INFO] ShardManager - Stopping ShardManager shard-manager-config46
11:20:43,683 AM [test-akka.actor.default-dispatcher-23] [INFO] RemoteActorRefProvider$RemotingTerminator - Shutting down remote daemon.
11:20:43,683 AM [test-akka.actor.default-dispatcher-23] [INFO] RemoteActorRefProvider$RemotingTerminator - Remote daemon shut down; proceeding with flushing remote transports.
11:20:43,688 AM [test-akka.actor.default-dispatcher-23] [INFO] RemoteActorRefProvider$RemotingTerminator - Remoting shut down.
[WARN] [02/27/2024 11:20:43.690] [test-akka.actor.internal-dispatcher-9] [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