01:35:28,209 PM [test-akka.actor.default-dispatcher-5] [INFO] Slf4jLogger - Slf4jLogger started
01:35:28,220 PM [test-akka.actor.default-dispatcher-5] [INFO] ArteryTransport - Remoting started with transport [Artery tcp]; listening on address [akka://test@127.0.0.1:2565] with UID [-6273165740086919239]
01:35:28,221 PM [test-akka.actor.default-dispatcher-5] [INFO] Cluster - Cluster Node [akka://test@127.0.0.1:2565] - Starting up, Akka version [2.6.21] ...
01:35:28,228 PM [test-akka.actor.default-dispatcher-5] [INFO] Cluster - Cluster Node [akka://test@127.0.0.1:2565] - Registered cluster JMX MBean [akka:type=Cluster]
01:35:28,228 PM [test-akka.actor.default-dispatcher-5] [INFO] Cluster - Cluster Node [akka://test@127.0.0.1:2565] - Started up successfully
01:35:28,239 PM [test-akka.actor.default-dispatcher-5] [INFO] Cluster - Cluster Node [akka://test@127.0.0.1:2565] - No downing-provider-class configured, manual cluster downing required, see https://doc.akka.io/docs/akka/current/typed/cluster.html#downing
01:35:28,239 PM [test-akka.actor.default-dispatcher-5] [INFO] Cluster - Cluster Node [akka://test@127.0.0.1:2565] - No seed-nodes configured, manual cluster join required, see https://doc.akka.io/docs/akka/current/typed/cluster.html#joining
01:35:28,350 PM [test-akka.actor.default-dispatcher-10] [INFO] EmptyLocalActorRef - Message [org.opendaylight.controller.cluster.common.actor.Monitor] from Actor[akka://test/user/$a#-981354724] to Actor[akka://test/user/termination-monitor] was not delivered. [1] dead letters encountered. If this is not an expected behavior then Actor[akka://test/user/termination-monitor] may have terminated unexpectedly. This logging can be turned off or adjusted with configuration settings 'akka.log-dead-letters' and 'akka.log-dead-letters-during-shutdown'.
01:35:28,351 PM [test-akka.actor.default-dispatcher-5] [INFO] ShardManager - Starting ShardManager shard-manager-config1
01:35:28,358 PM [test-akka.actor.default-dispatcher-5] [INFO] ShardManager - Recovery complete : shard-manager-config1
01:35:28,358 PM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - shard-manager-config1: Creating local shard: member-1-shard-default-config1
01:35:28,359 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1
01:35:28,359 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - Creating Shard member-1-shard-default-config1
01:35:28,359 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config1: Initializing shard [default]
01:35:28,359 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardInformation - Shard member-1-shard-default-config1 is initialized
01:35:28,359 PM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - shard-manager-config1: Received role changed for member-1-shard-default-config1 from null to Follower
01:35:28,359 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config1: onChangeShardServersVotingStatus: ChangeShardMembersVotingStatus [shardName=default, meberVotingStatusMap={member-2=true}]
01:35:28,363 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config1: findLocalShard : default
01:35:28,365 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config1: Sending ChangeServersVotingStatus message ChangeServersVotingStatus [serverVotingStatusMap={member-2-shard-default-config1=true}, serversVisited=[]] to local shard akka://test/user/member-1-shard-default-config1
01:35:28,366 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config1: Received ServerChangeReply{status=NO_LEADER} from local shard akka://test/user/member-1-shard-default-config1
01:35:28,366 PM [test-akka.actor.default-dispatcher-10] [WARN] ShardManager - shard-manager-config1: ChangeServersVotingStatus failed for shard default with status NO_LEADER
01:35:28,514 PM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/member-1-shard-default-config1#-1165682123]
01:35:28,528 PM [main] [INFO] ShardManagerTest - testOnReceiveFindPrimaryWaitForShardLeader starting
01:35:28,531 PM [test-akka.actor.default-dispatcher-11] [INFO] EmptyLocalActorRef - Message [org.opendaylight.controller.cluster.common.actor.Monitor] from Actor[akka://test/user/$b#-294339091] to Actor[akka://test/user/termination-monitor] was not delivered. [2] dead letters encountered. If this is not an expected behavior then Actor[akka://test/user/termination-monitor] may have terminated unexpectedly. This logging can be turned off or adjusted with configuration settings 'akka.log-dead-letters' and 'akka.log-dead-letters-during-shutdown'.
01:35:28,531 PM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - Starting ShardManager shard-manager-config2
01:35:28,532 PM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Recovery complete : shard-manager-config2
01:35:28,532 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config2: Creating local shard: member-1-shard-default-config2
01:35:28,542 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1
01:35:28,542 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - Creating Shard member-1-shard-default-config2
01:35:28,542 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config2: In findPrimary: org.opendaylight.controller.cluster.datastore.messages.FindPrimary [shardName=default, waitUntilReady=true]
01:35:28,542 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config2: Scheduling 10000 ms timer to wait for shard ShardInformation [shardId=member-1-shard-default-config2, leaderAvailable=false, actorInitialized=false, followerSyncStatus=false, role=null, leaderId=null, activeMember=true]
01:35:28,692 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config2: Initializing shard [default]
01:35:28,692 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardInformation - Shard member-1-shard-default-config2 is initialized
01:35:28,692 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardInformation - Shard member-1-shard-default-config2 is initialized - notifying 1 OnShardInitialized callbacks
01:35:28,842 PM [test-akka.actor.default-dispatcher-14] [INFO] ShardManager - shard-manager-config2: Received role changed for member-1-shard-default-config2 from Candidate to Leader
01:35:28,842 PM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardInformation - Shard member-1-shard-default-config2 is initialized - notifying 1 OnShardInitialized callbacks
01:35:28,993 PM [test-akka.actor.default-dispatcher-14] [INFO] ShardManager - shard-manager-config2: Received LeaderStateChanged message: LeaderStateChanged [memberId=member-1-shard-default-config2, leaderId=member-1-shard-default-config2, leaderPayloadVersion=13]
01:35:28,993 PM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardInformation - Shard member-1-shard-default-config2 is ready - notifying 1 OnShardInitialized callbacks
01:35:28,993 PM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - shard-manager-config2: Found primary for default: LocalPrimaryShardFound [primaryPath=akka://test@127.0.0.1:2565/user/member-1-shard-default-config#1922729857, localShardDataTree=org.opendaylight.yangtools.yang.data.tree.api.DataTree$MockitoMock$yZQhsnCX@483f70bf]
01:35:28,993 PM [test-akka.actor.default-dispatcher-14] [INFO] ShardManager - shard-manager-config2: All Shards are ready - data store config2 is ready
01:35:29,193 PM [main] [INFO] ShardManagerTest - testOnReceiveFindPrimaryWaitForShardLeader ending
01:35:29,295 PM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/$b#-294339091]
01:35:29,306 PM [test-akka.actor.default-dispatcher-14] [INFO] ShardManager - Stopping ShardManager shard-manager-config2
01:35:29,313 PM [main] [INFO] ShardManager - Starting ShardManager shard-manager-config3
01:35:29,313 PM [test-akka.actor.default-dispatcher-10] [INFO] EmptyLocalActorRef - Message [org.opendaylight.controller.cluster.common.actor.Monitor] from TestActor[akka://test/user/$$b] to Actor[akka://test/user/termination-monitor] was not delivered. [3] dead letters encountered. If this is not an expected behavior then Actor[akka://test/user/termination-monitor] may have terminated unexpectedly. This logging can be turned off or adjusted with configuration settings 'akka.log-dead-letters' and 'akka.log-dead-letters-during-shutdown'.
01:35:29,316 PM [test-akka.actor.default-dispatcher-14] [INFO] ShardManager - Recovery complete : shard-manager-config3
01:35:29,316 PM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - shard-manager-config3: Creating local shard: member-1-shard-default-config3
01:35:29,415 PM [main] [INFO] ShardManager - shard-manager-config3: Received role changed for member-1-shard-default-config3 from Follower to Candidate
01:35:29,415 PM [main] [INFO] ShardManager - shard-manager-config3 Received follower initial sync status for member-1-shard-default-config3 status sync done true
01:35:29,517 PM [main] [INFO] TestActorFactory - Killing actor TestActor[akka://test/user/$$b]
01:35:29,528 PM [main] [INFO] ShardManager - Stopping ShardManager shard-manager-config3
01:35:29,539 PM [cluster-test-akka.actor.default-dispatcher-6] [INFO] Slf4jLogger - Slf4jLogger started
01:35:29,558 PM [cluster-test-akka.actor.default-dispatcher-6] [INFO] ArteryTransport - Remoting started with transport [Artery tcp]; listening on address [akka://cluster-test@127.0.0.1:2558] with UID [2725374904892953031]
01:35:29,558 PM [cluster-test-akka.actor.default-dispatcher-6] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2558] - Starting up, Akka version [2.6.21] ...
01:35:29,563 PM [cluster-test-akka.actor.default-dispatcher-6] [WARN] Cluster - Could not register Cluster JMX MBean with name=akka:type=Cluster as it is already registered. If you are running multiple clusters in the same JVM, set 'akka.cluster.jmx.multi-mbeans-in-same-jvm = on' in config
01:35:29,563 PM [cluster-test-akka.actor.default-dispatcher-6] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2558] - Started up successfully
01:35:29,564 PM [cluster-test-akka.actor.default-dispatcher-6] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2558] - No downing-provider-class configured, manual cluster downing required, see https://doc.akka.io/docs/akka/current/typed/cluster.html#downing
01:35:29,564 PM [cluster-test-akka.actor.default-dispatcher-6] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2558] - No seed-nodes configured, manual cluster join required, see https://doc.akka.io/docs/akka/current/typed/cluster.html#joining
01:35:29,581 PM [cluster-test-akka.actor.default-dispatcher-6] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2558] - Node [akka://cluster-test@127.0.0.1:2558] is JOINING itself (with roles [member-1, dc-default], version [0.0.0]) and forming new cluster
01:35:29,584 PM [cluster-test-akka.actor.default-dispatcher-6] [INFO] ShardManager - Starting ShardManager shard-manager-config4
01:35:29,585 PM [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'.
01:35:29,586 PM [cluster-test-akka.actor.default-dispatcher-6] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2558] - is the new leader among reachable nodes (more leaders may exist)
01:35:29,586 PM [cluster-test-akka.actor.default-dispatcher-6] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2558] - Leader is moving node [akka://cluster-test@127.0.0.1:2558] to [Up]
01:35:29,595 PM [cluster-test-akka.actor.default-dispatcher-15] [INFO] ShardManager - Recovery complete : shard-manager-config4
01:35:29,595 PM [cluster-test-akka.actor.default-dispatcher-15] [DEBUG] ShardManager - shard-manager-config4: Creating local shard: member-1-shard-default-config4
01:35:29,596 PM [cluster-test-akka.actor.default-dispatcher-15] [DEBUG] ShardManager - shard-manager-config4: Creating local shard: member-1-shard-astronauts-config4
01:35:29,596 PM [cluster-test-akka.actor.default-dispatcher-15] [INFO] ShardManager - shard-manager-config4: Received MemberUp: memberName: MemberName{name=member-1}, address: akka://cluster-test@127.0.0.1:2558
01:35:29,596 PM [cluster-test-akka.actor.default-dispatcher-15] [INFO] ShardInformation - updatePeerAddress for peer member-1-shard-default-config4 with address akka://cluster-test@127.0.0.1:2558/user/shardmanager-config4/member-1-shard-default-config4
01:35:29,596 PM [cluster-test-akka.actor.default-dispatcher-15] [INFO] ShardInformation - updatePeerAddress for peer member-1-shard-astronauts-config4 with address akka://cluster-test@127.0.0.1:2558/user/shardmanager-config4/member-1-shard-astronauts-config4
01:35:29,606 PM [cluster-test-akka.actor.default-dispatcher-6] [INFO] Slf4jLogger - Slf4jLogger started
01:35:29,639 PM [cluster-test-akka.actor.default-dispatcher-6] [INFO] ArteryTransport - Remoting started with transport [Artery tcp]; listening on address [akka://cluster-test@127.0.0.1:2559] with UID [9019783312534177466]
01:35:29,640 PM [cluster-test-akka.actor.default-dispatcher-6] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2559] - Starting up, Akka version [2.6.21] ...
01:35:29,642 PM [cluster-test-akka.actor.default-dispatcher-6] [WARN] Cluster - Could not register Cluster JMX MBean with name=akka:type=Cluster as it is already registered. If you are running multiple clusters in the same JVM, set 'akka.cluster.jmx.multi-mbeans-in-same-jvm = on' in config
01:35:29,642 PM [cluster-test-akka.actor.default-dispatcher-6] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2559] - Started up successfully
01:35:29,644 PM [cluster-test-akka.actor.default-dispatcher-10] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2559] - No downing-provider-class configured, manual cluster downing required, see https://doc.akka.io/docs/akka/current/typed/cluster.html#downing
01:35:29,644 PM [cluster-test-akka.actor.default-dispatcher-10] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2559] - No seed-nodes configured, manual cluster join required, see https://doc.akka.io/docs/akka/current/typed/cluster.html#joining
01:35:29,655 PM [main] [ERROR] ShardManagerTest - Mock Shard Leader Actor : TestActor[akka://cluster-test/user/member-2-shard-default-config4]
01:35:29,659 PM [cluster-test-akka.actor.default-dispatcher-10] [INFO] EmptyLocalActorRef - Message [org.opendaylight.controller.cluster.common.actor.Monitor] from TestActor[akka://cluster-test/user/shardmanager-config4] to Actor[akka://cluster-test/user/termination-monitor] was not delivered. [1] dead letters encountered. If this is not an expected behavior then Actor[akka://cluster-test/user/termination-monitor] may have terminated unexpectedly. This logging can be turned off or adjusted with configuration settings 'akka.log-dead-letters' and 'akka.log-dead-letters-during-shutdown'.
01:35:29,661 PM [cluster-test-akka.actor.default-dispatcher-6] [INFO] ShardManager - Starting ShardManager shard-manager-config4
01:35:29,662 PM [main] [ERROR] ShardManagerTest - Forwarding actor : Actor[akka://cluster-test/user/shardmanager-config4/member-2-shard-default-config4#563438602]
01:35:29,674 PM [cluster-test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1
01:35:29,674 PM [cluster-test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - Creating Shard member-1-shard-default-config4
01:35:29,674 PM [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
01:35:29,674 PM [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
01:35:29,674 PM [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#1724176866]
01:35:29,674 PM [cluster-test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - Creating Shard member-1-shard-astronauts-config4
01:35:29,674 PM [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
01:35:29,674 PM [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
01:35:29,674 PM [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#1724176866]
01:35:29,674 PM [cluster-test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config4: Initializing shard [default]
01:35:29,674 PM [cluster-test-akka.actor.default-dispatcher-11] [DEBUG] ShardInformation - Shard member-1-shard-default-config4 is initialized
01:35:29,674 PM [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]
01:35:29,675 PM [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
01:35:29,681 PM [cluster-test-akka.actor.default-dispatcher-6] [INFO] ShardManager - Recovery complete : shard-manager-config4
01:35:29,681 PM [cluster-test-akka.actor.default-dispatcher-6] [DEBUG] ShardManager - shard-manager-config4: Creating local shard: member-2-shard-default-config4
01:35:29,681 PM [cluster-test-akka.actor.default-dispatcher-6] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1
01:35:29,681 PM [cluster-test-akka.actor.default-dispatcher-6] [DEBUG] ShardManager - Creating Shard member-2-shard-default-config4
01:35:29,681 PM [cluster-test-akka.actor.default-dispatcher-6] [DEBUG] ShardManager - shard-manager-config4: Initializing shard [default]
01:35:29,681 PM [cluster-test-akka.actor.default-dispatcher-6] [DEBUG] ShardInformation - Shard member-2-shard-default-config4 is initialized
01:35:29,682 PM [cluster-test-akka.actor.default-dispatcher-6] [INFO] ShardManager - shard-manager-config4: Received LeaderStateChanged message: LeaderStateChanged [memberId=member-2-shard-default-config4, leaderId=member-2-shard-default-config4, leaderPayloadVersion=12]
01:35:29,682 PM [cluster-test-akka.actor.default-dispatcher-6] [INFO] ShardManager - shard-manager-config4: Received role changed for member-2-shard-default-config4 from Candidate to Leader
01:35:29,682 PM [cluster-test-akka.actor.default-dispatcher-6] [INFO] ShardManager - shard-manager-config4: All Shards are ready - data store config4 is ready
01:35:29,986 PM [cluster-test-akka.actor.default-dispatcher-12] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2558] - Node [akka://cluster-test@127.0.0.1:2559] is JOINING, roles [member-2, dc-default], version [0.0.0]
01:35:29,996 PM [Cleaner-0] [DEBUG] ProxyHistory - Proxy org.opendaylight.controller.cluster.databroker.actors.dds.ProxyHistory$LocalSingle@54012e83 aborted transaction LocalReadOnlyProxyTransaction{identifier=member-1-datastore-testWriteTransactionWithMultipleShards-fe-0-txn-3-1, state=OPEN}
01:35:29,996 PM [Cleaner-0] [DEBUG] AbstractProxyTransaction - Transaction proxy LocalReadOnlyProxyTransaction{identifier=member-1-datastore-testWriteTransactionWithMultipleShards-fe-0-txn-3-1, state=OPEN} sending request AbortLocalTransactionRequest{target=member-1-datastore-testWriteTransactionWithMultipleShards-fe-0-txn-3-1, sequence=0, replyTo=Actor[akka://cluster-test/user/$a#1814461290]} callback org.opendaylight.controller.cluster.databroker.actors.dds.AbstractProxyTransaction$$Lambda$1520/0x00000008014a6f40@7bc6f613
01:35:29,996 PM [Cleaner-0] [DEBUG] AbstractClientConnection - member-1-frontend-datastore-testWriteTransactionWithMultipleShards: timer already scheduled on ConnectedClientConnection{client=ClientIdentifier{frontend=member-1-frontend-datastore-testWriteTransactionWithMultipleShards, generation=0}, cookie=1, backend=ShardBackendInfo{actor=Actor[akka://cluster-test/user/shardmanager-testWriteTransactionWithMultipleShards/member-1-shard-cars-1-testWriteTransactionWithMultipleShards#534835736], sessionId=0, version=POTASSIUM, maxMessages=1000, cookie=1, shard=cars-1, dataTree=present}}
01:35:29,996 PM [Cleaner-0] [DEBUG] ProxyHistory - Proxy org.opendaylight.controller.cluster.databroker.actors.dds.ProxyHistory$LocalSingle@7114834f aborted transaction LocalReadOnlyProxyTransaction{identifier=member-1-datastore-testWriteTransactionWithMultipleShards-fe-0-txn-3-2, state=OPEN}
01:35:29,996 PM [Cleaner-0] [DEBUG] AbstractProxyTransaction - Transaction proxy LocalReadOnlyProxyTransaction{identifier=member-1-datastore-testWriteTransactionWithMultipleShards-fe-0-txn-3-2, state=OPEN} sending request AbortLocalTransactionRequest{target=member-1-datastore-testWriteTransactionWithMultipleShards-fe-0-txn-3-2, sequence=0, replyTo=Actor[akka://cluster-test/user/$a#1814461290]} callback org.opendaylight.controller.cluster.databroker.actors.dds.AbstractProxyTransaction$$Lambda$1520/0x00000008014a6f40@4ebac9ab
01:35:29,996 PM [Cleaner-0] [DEBUG] TransmitQueue - Queue org.opendaylight.controller.cluster.access.client.TransmitQueue$Transmitting@294b8122 transmitting entry ConnectionEntry{request=AbortLocalTransactionRequest{target=member-1-datastore-testWriteTransactionWithMultipleShards-fe-0-txn-3-2, sequence=0, replyTo=Actor[akka://cluster-test/user/$a#1814461290]}, enqueuedTicks=557276484776}
01:35:29,997 PM [Cleaner-0] [INFO] ClientBackedTransaction - Aborted orphan transaction ClientSnapshot{identifier=member-1-datastore-testWriteTransactionWithMultipleShards-fe-0-txn-3-0}
01:35:30,49 PM [cluster-test-akka.actor.default-dispatcher-6] [INFO] ShardManager - shard-manager-config4: Received MemberUp: memberName: MemberName{name=member-1}, address: akka://cluster-test@127.0.0.1:2558
01:35:30,49 PM [cluster-test-akka.actor.default-dispatcher-6] [INFO] ShardInformation - updatePeerAddress for peer member-1-shard-default-config4 with address akka://cluster-test@127.0.0.1:2558/user/shardmanager-config4/member-1-shard-default-config4
01:35:30,49 PM [cluster-test-akka.actor.default-dispatcher-6] [DEBUG] ShardInformation - Sending PeerAddressResolved for peer member-1-shard-default-config4 with address akka://cluster-test@127.0.0.1:2558/user/shardmanager-config4/member-1-shard-default-config4 to akka://cluster-test/user/member-2-shard-default-config4
01:35:30,49 PM [cluster-test-akka.actor.default-dispatcher-6] [INFO] ShardManager - shard-manager-config4: All Shards are ready - data store config4 is ready
01:35:30,49 PM [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:2558]
01:35:30,581 PM [cluster-test-akka.actor.default-dispatcher-11] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2558] - Leader is moving node [akka://cluster-test@127.0.0.1:2559] to [Up]
01:35:30,583 PM [cluster-test-akka.actor.default-dispatcher-11] [INFO] ShardManager - shard-manager-config4: Received MemberUp: memberName: MemberName{name=member-2}, address: akka://cluster-test@127.0.0.1:2559
01:35:30,583 PM [cluster-test-akka.actor.default-dispatcher-11] [INFO] ShardInformation - updatePeerAddress for peer member-2-shard-default-config4 with address akka://cluster-test@127.0.0.1:2559/user/shardmanager-config4/member-2-shard-default-config4
01:35:30,583 PM [cluster-test-akka.actor.default-dispatcher-11] [DEBUG] ShardInformation - Sending PeerAddressResolved for peer member-2-shard-default-config4 with address akka://cluster-test@127.0.0.1:2559/user/shardmanager-config4/member-2-shard-default-config4 to akka://cluster-test/user/member-1-shard-default-config
01:35:30,583 PM [cluster-test-akka.actor.default-dispatcher-11] [INFO] ShardInformation - updatePeerAddress for peer member-2-shard-astronauts-config4 with address akka://cluster-test@127.0.0.1:2559/user/shardmanager-config4/member-2-shard-astronauts-config4
01:35:30,583 PM [cluster-test-akka.actor.default-dispatcher-11] [DEBUG] ShardInformation - Sending PeerAddressResolved for peer member-2-shard-astronauts-config4 with address akka://cluster-test@127.0.0.1:2559/user/shardmanager-config4/member-2-shard-astronauts-config4 to akka://cluster-test/user/member-1-shard-default-config
01:35:30,585 PM [cluster-test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config4: onRemoveShardReplica: RemoveShardReplica [shardName=default, memberName=MemberName{name=member-1}]
01:35:30,588 PM [cluster-test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config4: In findPrimary: org.opendaylight.controller.cluster.datastore.messages.FindPrimary [shardName=default, waitUntilReady=true]
01:35:30,588 PM [cluster-test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config4: Found primary for default: RemotePrimaryShardFound [primaryPath=akka://cluster-test@127.0.0.1:2559/user/shardmanager-config4/member-2-shard-default-config4, primaryVersion=12]
01:35:30,589 PM [cluster-test-akka.actor.default-dispatcher-12] [DEBUG] ShardManager - shard-manager-config4: Sending RemoveServer message to peer akka://cluster-test@127.0.0.1:2559/user/shardmanager-config4/member-2-shard-default-config4 for shard member-1-shard-default-config4
01:35:30,606 PM [cluster-test-akka.actor.default-dispatcher-12] [DEBUG] ShardManager - shard-manager-config4: Received RemoveServerReply{status=OK, leaderHint=member-2-shard-default-config4} for shard default
01:35:30,606 PM [cluster-test-akka.actor.default-dispatcher-12] [DEBUG] ShardManager - shard-manager-config4: Leader shard successfully removed the replica shard default
01:35:30,674 PM [cluster-test-akka.actor.default-dispatcher-10] [INFO] ShardManager - shard-manager-config4: Received MemberUp: memberName: MemberName{name=member-2}, address: akka://cluster-test@127.0.0.1:2559
01:35:30,675 PM [cluster-test-akka.actor.default-dispatcher-10] [INFO] ShardInformation - updatePeerAddress for peer member-2-shard-default-config4 with address akka://cluster-test@127.0.0.1:2559/user/shardmanager-config4/member-2-shard-default-config4
01:35:30,675 PM [cluster-test-akka.actor.default-dispatcher-10] [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
01:35:30,675 PM [cluster-test-akka.actor.default-dispatcher-10] [INFO] ShardManager - shard-manager-config4: All Shards are ready - data store config4 is ready
01:35:30,737 PM [cluster-test-akka.actor.default-dispatcher-12] [INFO] ShardManager - Stopping ShardManager shard-manager-config4
01:35:30,738 PM [cluster-test-akka.actor.default-dispatcher-12] [INFO] RemoteActorRefProvider$RemotingTerminator - Shutting down remote daemon.
01:35:30,738 PM [cluster-test-akka.actor.default-dispatcher-12] [INFO] RemoteActorRefProvider$RemotingTerminator - Remote daemon shut down; proceeding with flushing remote transports.
01:35:30,770 PM [cluster-test-akka.actor.default-dispatcher-12] [WARN] Materializer - [outbound connection to [akka://cluster-test@127.0.0.1:2559], message stream] Upstream failed, cause: StreamTcpException: The connection has been aborted
01:35:30,770 PM [cluster-test-akka.actor.default-dispatcher-12] [WARN] Materializer - [outbound connection to [akka://cluster-test@127.0.0.1:2559], control stream] Upstream failed, cause: StreamTcpException: The connection has been aborted
01:35:30,775 PM [cluster-test-akka.actor.default-dispatcher-12] [INFO] RemoteActorRefProvider$RemotingTerminator - Remoting shut down.
01:35:30,809 PM [cluster-test-akka.actor.default-dispatcher-6] [INFO] ShardManager - Stopping ShardManager shard-manager-config4
01:35:30,811 PM [cluster-test-akka.actor.default-dispatcher-6] [INFO] RemoteActorRefProvider$RemotingTerminator - Shutting down remote daemon.
01:35:30,811 PM [cluster-test-akka.actor.default-dispatcher-6] [INFO] RemoteActorRefProvider$RemotingTerminator - Remote daemon shut down; proceeding with flushing remote transports.
[WARN] [03/11/2024 13:35:31.827] [cluster-test-akka.actor.internal-dispatcher-3] [Cluster(akka://cluster-test)] Could not unregister Cluster JMX MBean with name=akka:type=Cluster as it was not found. If you are running multiple clusters in the same JVM, set 'akka.cluster.jmx.multi-mbeans-in-same-jvm = on' in config
01:35:31,850 PM [test-akka.actor.default-dispatcher-14] [INFO] EmptyLocalActorRef - Message [org.opendaylight.controller.cluster.common.actor.Monitor] from Actor[akka://test/user/$c#-1532176099] to Actor[akka://test/user/termination-monitor] was not delivered. [4] dead letters encountered. If this is not an expected behavior then Actor[akka://test/user/termination-monitor] may have terminated unexpectedly. This logging can be turned off or adjusted with configuration settings 'akka.log-dead-letters' and 'akka.log-dead-letters-during-shutdown'.
01:35:31,850 PM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Starting ShardManager shard-manager-config5
01:35:31,852 PM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - Recovery complete : shard-manager-config5
01:35:31,852 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config5: Creating local shard: member-1-shard-default-config5
01:35:31,865 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1
01:35:31,865 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - Creating Shard member-1-shard-default-config5
01:35:31,865 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config5: Initializing shard [default]
01:35:31,865 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardInformation - Shard member-1-shard-default-config5 is initialized
01:35:32,17 PM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/$c#-1532176099]
01:35:32,28 PM [test-akka.actor.default-dispatcher-14] [INFO] ShardManager - Stopping ShardManager shard-manager-config5
01:35:32,34 PM [test-akka.actor.default-dispatcher-14] [INFO] EmptyLocalActorRef - Message [org.opendaylight.controller.cluster.common.actor.Monitor] from TestActor[akka://test/user/$$c] to Actor[akka://test/user/termination-monitor] was not delivered. [5] dead letters encountered. If this is not an expected behavior then Actor[akka://test/user/termination-monitor] may have terminated unexpectedly. This logging can be turned off or adjusted with configuration settings 'akka.log-dead-letters' and 'akka.log-dead-letters-during-shutdown'.
01:35:32,34 PM [main] [INFO] ShardManager - Starting ShardManager shard-manager-config6
01:35:32,38 PM [test-akka.actor.default-dispatcher-14] [INFO] ShardManager - Recovery complete : shard-manager-config6
01:35:32,38 PM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - shard-manager-config6: Creating local shard: member-1-shard-default-config6
01:35:32,38 PM [main] [INFO] ShardManager - shard-manager-config6: Received role changed for member-1-shard-default-config6 from null to Follower
01:35:32,49 PM [main] [INFO] ShardManager - shard-manager-config6: Received MemberUp: memberName: MemberName{name=member-2}, address: akka://test
01:35:32,49 PM [main] [INFO] ShardInformation - updatePeerAddress for peer member-2-shard-default-config6 with address akka://test/user/shardmanager-config6/member-2-shard-default-config6
01:35:32,49 PM [main] [INFO] ShardManager - shard-manager-config6: Received LeaderStateChanged message: LeaderStateChanged [memberId=member-1-shard-default-config6, leaderId=member-2-shard-default-config6, leaderPayloadVersion=13]
01:35:32,49 PM [main] [INFO] ShardManager - shard-manager-config6: All Shards are ready - data store config6 is ready
01:35:32,151 PM [main] [INFO] TestActorFactory - Killing actor TestActor[akka://test/user/$$c]
01:35:32,162 PM [main] [INFO] ShardManager - Stopping ShardManager shard-manager-config6
01:35:32,170 PM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Starting ShardManager shard-manager-config7
01:35:32,170 PM [test-akka.actor.default-dispatcher-11] [INFO] EmptyLocalActorRef - Message [org.opendaylight.controller.cluster.common.actor.Monitor] from Actor[akka://test/user/$d#-434276346] to Actor[akka://test/user/termination-monitor] was not delivered. [6] dead letters encountered. If this is not an expected behavior then Actor[akka://test/user/termination-monitor] may have terminated unexpectedly. This logging can be turned off or adjusted with configuration settings 'akka.log-dead-letters' and 'akka.log-dead-letters-during-shutdown'.
01:35:32,172 PM [test-akka.actor.default-dispatcher-14] [INFO] ShardManager - Recovery complete : shard-manager-config7
01:35:32,181 PM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - shard-manager-config7: onRemoveShardReplica: RemoveShardReplica [shardName=model-inventory, memberName=MemberName{name=member-1}]
01:35:32,181 PM [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]
01:35:32,181 PM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - shard-manager-config7: No shard found for model-inventory
01:35:32,181 PM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - shard-manager-config7: Failed to find leader for shard model-inventory: received response: {}
org.opendaylight.controller.cluster.datastore.exceptions.PrimaryNotFoundException: No primary shard found for model-inventory.
	at org.opendaylight.controller.cluster.datastore.shardmanager.ShardManager.findPrimary(ShardManager.java:1051)
	at org.opendaylight.controller.cluster.datastore.shardmanager.ShardManager.handleCommand(ShardManager.java:207)
	at org.opendaylight.controller.cluster.datastore.shardmanager.ShardManagerTest$TestShardManager.handleCommand(ShardManagerTest.java:2198)
	at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:24)
	at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:20)
	at scala.PartialFunction.applyOrElse(PartialFunction.scala:214)
	at scala.PartialFunction.applyOrElse$(PartialFunction.scala:213)
	at akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:20)
	at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:269)
	at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:270)
	at akka.actor.Actor.aroundReceive(Actor.scala:537)
	at akka.actor.Actor.aroundReceive$(Actor.scala:535)
	at akka.persistence.AbstractPersistentActor.akka$persistence$Eventsourced$$super$aroundReceive(PersistentActor.scala:295)
	at akka.persistence.Eventsourced$$anon$4.stateReceive(Eventsourced.scala:917)
	at akka.persistence.Eventsourced.aroundReceive(Eventsourced.scala:245)
	at akka.persistence.Eventsourced.aroundReceive$(Eventsourced.scala:244)
	at akka.persistence.AbstractPersistentActor.aroundReceive(PersistentActor.scala:295)
	at akka.actor.ActorCell.receiveMessage(ActorCell.scala:579)
	at akka.actor.ActorCell.invoke(ActorCell.scala:547)
	at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:270)
	at akka.dispatch.Mailbox.run(Mailbox.scala:231)
	at akka.dispatch.Mailbox.exec(Mailbox.scala:243)
	at java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:373)
	at java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1182)
	at java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1655)
	at java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1622)
	at java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:165)
01:35:32,283 PM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/$d#-434276346]
01:35:32,295 PM [test-akka.actor.default-dispatcher-5] [INFO] ShardManager - Stopping ShardManager shard-manager-config7
01:35:32,298 PM [main] [INFO] ShardManagerTest - testAddShardReplicaWithPreExistingLocalReplicaLeader starting
01:35:32,301 PM [test-akka.actor.default-dispatcher-5] [INFO] EmptyLocalActorRef - Message [org.opendaylight.controller.cluster.common.actor.Monitor] from Actor[akka://test/user/$e#-975546024] to Actor[akka://test/user/termination-monitor] was not delivered. [7] dead letters encountered. If this is not an expected behavior then Actor[akka://test/user/termination-monitor] may have terminated unexpectedly. This logging can be turned off or adjusted with configuration settings 'akka.log-dead-letters' and 'akka.log-dead-letters-during-shutdown'.
01:35:32,301 PM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Starting ShardManager shard-manager-config8
01:35:32,304 PM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - Recovery complete : shard-manager-config8
01:35:32,304 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config8: Creating local shard: member-1-shard-default-config8
01:35:32,312 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1
01:35:32,312 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - Creating Shard member-1-shard-default-config8
01:35:32,312 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config8: Initializing shard [default]
01:35:32,312 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardInformation - Shard member-1-shard-default-config8 is initialized
01:35:32,312 PM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - shard-manager-config8: Received LeaderStateChanged message: LeaderStateChanged [memberId=member-1-shard-default-config8, leaderId=member-1-shard-default-config8, leaderPayloadVersion=13]
01:35:32,312 PM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - shard-manager-config8: Received role changed for member-1-shard-default-config8 from Candidate to Leader
01:35:32,312 PM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - shard-manager-config8: All Shards are ready - data store config8 is ready
01:35:32,313 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config8: onAddShardReplica: AddShardReplica[ShardName=default]
01:35:32,314 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config8: In findPrimary: org.opendaylight.controller.cluster.datastore.messages.FindPrimary [shardName=default, waitUntilReady=true]
01:35:32,314 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config8: Found primary for default: LocalPrimaryShardFound [primaryPath=akka://test@127.0.0.1:2565/user/member-1-shard-default-config#-1842767139, localShardDataTree=org.opendaylight.yangtools.yang.data.tree.api.DataTree$MockitoMock$yZQhsnCX@21545457]
01:35:32,314 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config8: Local shard default already exists
01:35:32,315 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config8: findLocalShard : default
01:35:32,315 PM [main] [INFO] ShardManagerTest - testAddShardReplicaWithPreExistingLocalReplicaLeader ending
01:35:32,417 PM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/$e#-975546024]
01:35:32,428 PM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Stopping ShardManager shard-manager-config8
01:35:32,431 PM [main] [INFO] ShardManagerTest - testOnReceiveFindLocalShardWaitForShardInitialized starting
01:35:32,433 PM [test-akka.actor.default-dispatcher-5] [INFO] EmptyLocalActorRef - Message [org.opendaylight.controller.cluster.common.actor.Monitor] from Actor[akka://test/user/$f#-205038766] to Actor[akka://test/user/termination-monitor] was not delivered. [8] dead letters encountered. If this is not an expected behavior then Actor[akka://test/user/termination-monitor] may have terminated unexpectedly. This logging can be turned off or adjusted with configuration settings 'akka.log-dead-letters' and 'akka.log-dead-letters-during-shutdown'.
01:35:32,434 PM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Starting ShardManager shard-manager-config9
01:35:32,435 PM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - Recovery complete : shard-manager-config9
01:35:32,435 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config9: Creating local shard: member-1-shard-default-config9
01:35:32,445 PM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1
01:35:32,445 PM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - Creating Shard member-1-shard-default-config9
01:35:32,445 PM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - shard-manager-config9: findLocalShard : default
01:35:32,445 PM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - shard-manager-config9: Scheduling 600 ms timer to wait for shard ShardInformation [shardId=member-1-shard-default-config9, leaderAvailable=false, actorInitialized=false, followerSyncStatus=false, role=null, leaderId=null, activeMember=true]
01:35:32,445 PM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - shard-manager-config9: Initializing shard [default]
01:35:32,445 PM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardInformation - Shard member-1-shard-default-config9 is initialized
01:35:32,445 PM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardInformation - Shard member-1-shard-default-config9 is initialized - notifying 1 OnShardInitialized callbacks
01:35:32,449 PM [main] [INFO] ShardManagerTest - testOnReceiveFindLocalShardWaitForShardInitialized starting
01:35:32,550 PM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/$f#-205038766]
01:35:32,562 PM [test-akka.actor.default-dispatcher-5] [INFO] ShardManager - Stopping ShardManager shard-manager-config9
01:35:32,564 PM [main] [INFO] ShardManagerTest - testShardAvailabilityChangeOnMemberUnreachableAndLeadershipChange starting
01:35:32,576 PM [cluster-test-akka.actor.default-dispatcher-6] [INFO] Slf4jLogger - Slf4jLogger started
01:35:32,585 PM [cluster-test-akka.actor.default-dispatcher-6] [INFO] ArteryTransport - Remoting started with transport [Artery tcp]; listening on address [akka://cluster-test@127.0.0.1:2558] with UID [839211617379014424]
01:35:32,585 PM [cluster-test-akka.actor.default-dispatcher-6] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2558] - Starting up, Akka version [2.6.21] ...
01:35:32,588 PM [cluster-test-akka.actor.default-dispatcher-6] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2558] - Registered cluster JMX MBean [akka:type=Cluster]
01:35:32,588 PM [cluster-test-akka.actor.default-dispatcher-6] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2558] - Started up successfully
01:35:32,607 PM [cluster-test-akka.actor.default-dispatcher-6] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2558] - No downing-provider-class configured, manual cluster downing required, see https://doc.akka.io/docs/akka/current/typed/cluster.html#downing
01:35:32,607 PM [cluster-test-akka.actor.default-dispatcher-6] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2558] - No seed-nodes configured, manual cluster join required, see https://doc.akka.io/docs/akka/current/typed/cluster.html#joining
01:35:32,607 PM [cluster-test-akka.actor.default-dispatcher-6] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2558] - Node [akka://cluster-test@127.0.0.1:2558] is JOINING itself (with roles [member-1, dc-default], version [0.0.0]) and forming new cluster
01:35:32,607 PM [cluster-test-akka.actor.default-dispatcher-6] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2558] - is the new leader among reachable nodes (more leaders may exist)
01:35:32,607 PM [cluster-test-akka.actor.default-dispatcher-6] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2558] - Leader is moving node [akka://cluster-test@127.0.0.1:2558] to [Up]
01:35:32,613 PM [cluster-test-akka.actor.default-dispatcher-6] [INFO] ShardManager - Starting ShardManager shard-manager-config10
01:35:32,618 PM [cluster-test-akka.actor.default-dispatcher-10] [INFO] EmptyLocalActorRef - Message [org.opendaylight.controller.cluster.common.actor.Monitor] from TestActor[akka://cluster-test/user/shardmanager-config10] to Actor[akka://cluster-test/user/termination-monitor] was not delivered. [1] dead letters encountered. If this is not an expected behavior then Actor[akka://cluster-test/user/termination-monitor] may have terminated unexpectedly. This logging can be turned off or adjusted with configuration settings 'akka.log-dead-letters' and 'akka.log-dead-letters-during-shutdown'.
01:35:32,637 PM [cluster-test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Recovery complete : shard-manager-config10
01:35:32,637 PM [cluster-test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config10: Creating local shard: member-1-shard-default-config10
01:35:32,637 PM [cluster-test-akka.actor.default-dispatcher-11] [INFO] ShardManager - shard-manager-config10: Received MemberUp: memberName: MemberName{name=member-1}, address: akka://cluster-test@127.0.0.1:2558
01:35:32,637 PM [cluster-test-akka.actor.default-dispatcher-11] [INFO] ShardInformation - updatePeerAddress for peer member-1-shard-default-config10 with address akka://cluster-test@127.0.0.1:2558/user/shardmanager-config10/member-1-shard-default-config10
01:35:32,640 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] Slf4jLogger - Slf4jLogger started
01:35:32,650 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] ArteryTransport - Remoting started with transport [Artery tcp]; listening on address [akka://cluster-test@127.0.0.1:2559] with UID [7172884710758201548]
01:35:32,650 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2559] - Starting up, Akka version [2.6.21] ...
01:35:32,656 PM [cluster-test-akka.actor.default-dispatcher-5] [WARN] Cluster - Could not register Cluster JMX MBean with name=akka:type=Cluster as it is already registered. If you are running multiple clusters in the same JVM, set 'akka.cluster.jmx.multi-mbeans-in-same-jvm = on' in config
01:35:32,656 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2559] - Started up successfully
01:35:32,659 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2559] - No downing-provider-class configured, manual cluster downing required, see https://doc.akka.io/docs/akka/current/typed/cluster.html#downing
01:35:32,659 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2559] - No seed-nodes configured, manual cluster join required, see https://doc.akka.io/docs/akka/current/typed/cluster.html#joining
01:35:32,675 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] ShardManager - Starting ShardManager shard-manager-config10
01:35:32,679 PM [cluster-test-akka.actor.default-dispatcher-15] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1
01:35:32,679 PM [cluster-test-akka.actor.default-dispatcher-15] [DEBUG] ShardManager - Creating Shard member-1-shard-default-config10
01:35:32,679 PM [cluster-test-akka.actor.default-dispatcher-15] [INFO] ShardInformation - updatePeerAddress for peer member-1-shard-default-config10 with address akka://cluster-test@127.0.0.1:2558/user/shardmanager-config10/member-1-shard-default-config10
01:35:32,679 PM [cluster-test-akka.actor.default-dispatcher-15] [DEBUG] ShardInformation - Sending PeerAddressResolved for peer member-1-shard-default-config10 with address akka://cluster-test@127.0.0.1:2558/user/shardmanager-config10/member-1-shard-default-config10 to akka://cluster-test/user/member-1-shard-default-config
01:35:32,679 PM [cluster-test-akka.actor.default-dispatcher-15] [DEBUG] ShardManager - shard-manager-config10: updated peer member-1-shard-default-config10 on member MemberName{name=member-1} with address akka://cluster-test@127.0.0.1:2558/user/shardmanager-config10/member-1-shard-default-config10 on shard member-1-shard-default-config10 whose actor address is Actor[akka://cluster-test/user/member-1-shard-default-config#-957471684]
01:35:32,679 PM [cluster-test-akka.actor.default-dispatcher-15] [DEBUG] ShardManager - shard-manager-config10: Initializing shard [default]
01:35:32,679 PM [cluster-test-akka.actor.default-dispatcher-15] [DEBUG] ShardInformation - Shard member-1-shard-default-config10 is initialized
01:35:32,679 PM [cluster-test-akka.actor.default-dispatcher-15] [INFO] ShardManager - shard-manager-config10: Received LeaderStateChanged message: LeaderStateChanged [memberId=member-1-shard-default-config10, leaderId=member-2-shard-default-config10, leaderPayloadVersion=13]
01:35:32,679 PM [cluster-test-akka.actor.default-dispatcher-15] [INFO] ShardManager - shard-manager-config10: Received role changed for member-1-shard-default-config10 from Candidate to Follower
01:35:32,692 PM [cluster-test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Recovery complete : shard-manager-config10
01:35:32,692 PM [cluster-test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config10: Creating local shard: member-2-shard-default-config10
01:35:32,692 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] EmptyLocalActorRef - Message [org.opendaylight.controller.cluster.common.actor.Monitor] from TestActor[akka://cluster-test/user/shardmanager-config10] to Actor[akka://cluster-test/user/termination-monitor] was not delivered. [1] dead letters encountered. If this is not an expected behavior then Actor[akka://cluster-test/user/termination-monitor] may have terminated unexpectedly. This logging can be turned off or adjusted with configuration settings 'akka.log-dead-letters' and 'akka.log-dead-letters-during-shutdown'.
01:35:32,692 PM [cluster-test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1
01:35:32,692 PM [cluster-test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - Creating Shard member-2-shard-default-config10
01:35:32,692 PM [cluster-test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config10: Initializing shard [default]
01:35:32,692 PM [cluster-test-akka.actor.default-dispatcher-11] [DEBUG] ShardInformation - Shard member-2-shard-default-config10 is initialized
01:35:32,692 PM [cluster-test-akka.actor.default-dispatcher-11] [INFO] ShardManager - shard-manager-config10: Received LeaderStateChanged message: LeaderStateChanged [memberId=member-2-shard-default-config10, leaderId=member-2-shard-default-config10, leaderPayloadVersion=13]
01:35:32,693 PM [cluster-test-akka.actor.default-dispatcher-11] [INFO] ShardManager - shard-manager-config10: Received role changed for member-2-shard-default-config10 from Candidate to Leader
01:35:32,693 PM [cluster-test-akka.actor.default-dispatcher-11] [INFO] ShardManager - shard-manager-config10: All Shards are ready - data store config10 is ready
01:35:32,765 PM [cluster-test-akka.actor.default-dispatcher-16] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2558] - Node [akka://cluster-test@127.0.0.1:2559] is JOINING, roles [member-2, dc-default], version [0.0.0]
01:35:32,780 PM [cluster-test-akka.actor.default-dispatcher-13] [INFO] ShardManager - shard-manager-config10: Received MemberUp: memberName: MemberName{name=member-1}, address: akka://cluster-test@127.0.0.1:2558
01:35:32,780 PM [cluster-test-akka.actor.default-dispatcher-13] [INFO] ShardInformation - updatePeerAddress for peer member-1-shard-default-config10 with address akka://cluster-test@127.0.0.1:2558/user/shardmanager-config10/member-1-shard-default-config10
01:35:32,780 PM [cluster-test-akka.actor.default-dispatcher-13] [DEBUG] ShardInformation - Sending PeerAddressResolved for peer member-1-shard-default-config10 with address akka://cluster-test@127.0.0.1:2558/user/shardmanager-config10/member-1-shard-default-config10 to akka://cluster-test/user/member-2-shard-default-config
01:35:32,780 PM [cluster-test-akka.actor.default-dispatcher-13] [INFO] ShardManager - shard-manager-config10: All Shards are ready - data store config10 is ready
01:35:32,780 PM [cluster-test-akka.actor.default-dispatcher-13] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2559] - Welcome from [akka://cluster-test@127.0.0.1:2558]
01:35:33,612 PM [cluster-test-akka.actor.default-dispatcher-11] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2558] - Leader is moving node [akka://cluster-test@127.0.0.1:2559] to [Up]
01:35:33,612 PM [cluster-test-akka.actor.default-dispatcher-11] [INFO] ShardManager - shard-manager-config10: Received MemberUp: memberName: MemberName{name=member-2}, address: akka://cluster-test@127.0.0.1:2559
01:35:33,612 PM [cluster-test-akka.actor.default-dispatcher-11] [INFO] ShardInformation - updatePeerAddress for peer member-2-shard-default-config10 with address akka://cluster-test@127.0.0.1:2559/user/shardmanager-config10/member-2-shard-default-config10
01:35:33,612 PM [cluster-test-akka.actor.default-dispatcher-11] [DEBUG] ShardInformation - Sending PeerAddressResolved for peer member-2-shard-default-config10 with address akka://cluster-test@127.0.0.1:2559/user/shardmanager-config10/member-2-shard-default-config10 to akka://cluster-test/user/member-1-shard-default-config
01:35:33,612 PM [cluster-test-akka.actor.default-dispatcher-11] [INFO] ShardManager - shard-manager-config10: All Shards are ready - data store config10 is ready
01:35:33,613 PM [cluster-test-akka.actor.default-dispatcher-15] [DEBUG] ShardManager - shard-manager-config10: In findPrimary: org.opendaylight.controller.cluster.datastore.messages.FindPrimary [shardName=default, waitUntilReady=true]
01:35:33,613 PM [cluster-test-akka.actor.default-dispatcher-15] [DEBUG] ShardManager - shard-manager-config10: Found primary for default: RemotePrimaryShardFound [primaryPath=akka://cluster-test@127.0.0.1:2559/user/shardmanager-config10/member-2-shard-default-config10, primaryVersion=13]
01:35:33,614 PM [cluster-test-akka.actor.default-dispatcher-15] [INFO] ShardManager - Received UnreachableMember: memberName MemberName{name=member-2}, address: akka://cluster-test@127.0.0.1:2558
01:35:33,614 PM [cluster-test-akka.actor.default-dispatcher-15] [DEBUG] ShardManager - Marking Leader member-2-shard-default-config10 as unavailable.
01:35:33,614 PM [cluster-test-akka.actor.default-dispatcher-15] [DEBUG] ShardManager - shard-manager-config10: In findPrimary: org.opendaylight.controller.cluster.datastore.messages.FindPrimary [shardName=default, waitUntilReady=true]
01:35:33,614 PM [cluster-test-akka.actor.default-dispatcher-15] [DEBUG] ShardManager - shard-manager-config10: Scheduling 1200 ms timer to wait for shard ShardInformation [shardId=member-1-shard-default-config10, leaderAvailable=false, actorInitialized=true, followerSyncStatus=false, role=Follower, leaderId=member-2-shard-default-config10, activeMember=true]
01:35:33,684 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] ShardManager - shard-manager-config10: Received MemberUp: memberName: MemberName{name=member-2}, address: akka://cluster-test@127.0.0.1:2559
01:35:33,684 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] ShardInformation - updatePeerAddress for peer member-2-shard-default-config10 with address akka://cluster-test@127.0.0.1:2559/user/shardmanager-config10/member-2-shard-default-config10
01:35:33,684 PM [cluster-test-akka.actor.default-dispatcher-5] [DEBUG] ShardInformation - Sending PeerAddressResolved for peer member-2-shard-default-config10 with address akka://cluster-test@127.0.0.1:2559/user/shardmanager-config10/member-2-shard-default-config10 to akka://cluster-test/user/member-2-shard-default-config
01:35:33,684 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] ShardManager - shard-manager-config10: All Shards are ready - data store config10 is ready
01:35:34,830 PM [cluster-test-akka.actor.default-dispatcher-15] [DEBUG] ShardManager - shard-manager-config10: Received ShardNotInitializedTimeout message for shard default
01:35:34,830 PM [cluster-test-akka.actor.default-dispatcher-15] [DEBUG] ShardManager - shard-manager-config10: Returning NoShardLeaderException for shard default
01:35:34,830 PM [cluster-test-akka.actor.default-dispatcher-15] [INFO] ShardManager - shard-manager-config10: Received LeaderStateChanged message: LeaderStateChanged [memberId=member-1-shard-default-config10, leaderId=member-1-shard-default-config10, leaderPayloadVersion=13]
01:35:34,831 PM [cluster-test-akka.actor.default-dispatcher-15] [INFO] ShardManager - shard-manager-config10: All Shards are ready - data store config10 is ready
01:35:34,831 PM [cluster-test-akka.actor.default-dispatcher-15] [INFO] ShardManager - shard-manager-config10: Received role changed for member-1-shard-default-config10 from Follower to Leader
01:35:34,831 PM [cluster-test-akka.actor.default-dispatcher-15] [INFO] ShardManager - shard-manager-config10: All Shards are ready - data store config10 is ready
01:35:34,831 PM [cluster-test-akka.actor.default-dispatcher-15] [DEBUG] ShardManager - shard-manager-config10: In findPrimary: org.opendaylight.controller.cluster.datastore.messages.FindPrimary [shardName=default, waitUntilReady=true]
01:35:34,831 PM [cluster-test-akka.actor.default-dispatcher-15] [DEBUG] ShardManager - shard-manager-config10: Found primary for default: LocalPrimaryShardFound [primaryPath=akka://cluster-test@127.0.0.1:2558/user/member-1-shard-default-config#-957471684, localShardDataTree=org.opendaylight.yangtools.yang.data.tree.api.DataTree$MockitoMock$yZQhsnCX@18c35c73]
01:35:34,831 PM [main] [INFO] ShardManagerTest - testShardAvailabilityChangeOnMemberUnreachableAndLeadershipChange ending
01:35:34,933 PM [cluster-test-akka.actor.default-dispatcher-16] [INFO] ShardManager - Stopping ShardManager shard-manager-config10
01:35:34,935 PM [cluster-test-akka.actor.default-dispatcher-15] [INFO] RemoteActorRefProvider$RemotingTerminator - Shutting down remote daemon.
01:35:34,935 PM [cluster-test-akka.actor.default-dispatcher-15] [INFO] RemoteActorRefProvider$RemotingTerminator - Remote daemon shut down; proceeding with flushing remote transports.
01:35:34,946 PM [cluster-test-akka.actor.default-dispatcher-15] [WARN] Materializer - [outbound connection to [akka://cluster-test@127.0.0.1:2559], control stream] Upstream failed, cause: StreamTcpException: The connection has been aborted
01:35:34,947 PM [cluster-test-akka.actor.default-dispatcher-15] [WARN] Materializer - [outbound connection to [akka://cluster-test@127.0.0.1:2559], message stream] Upstream failed, cause: StreamTcpException: The connection has been aborted
01:35:34,950 PM [cluster-test-akka.actor.default-dispatcher-15] [INFO] RemoteActorRefProvider$RemotingTerminator - Remoting shut down.
01:35:34,963 PM [cluster-test-akka.actor.default-dispatcher-13] [INFO] ShardManager - Stopping ShardManager shard-manager-config10
01:35:34,964 PM [cluster-test-akka.actor.default-dispatcher-13] [INFO] RemoteActorRefProvider$RemotingTerminator - Shutting down remote daemon.
01:35:34,964 PM [cluster-test-akka.actor.default-dispatcher-13] [INFO] RemoteActorRefProvider$RemotingTerminator - Remote daemon shut down; proceeding with flushing remote transports.
01:35:35,997 PM [cluster-test-akka.actor.default-dispatcher-13] [INFO] RemoteActorRefProvider$RemotingTerminator - Remoting shut down.
[WARN] [03/11/2024 13:35:35.999] [cluster-test-akka.actor.internal-dispatcher-2] [Cluster(akka://cluster-test)] Could not unregister Cluster JMX MBean with name=akka:type=Cluster as it was not found. If you are running multiple clusters in the same JVM, set 'akka.cluster.jmx.multi-mbeans-in-same-jvm = on' in config
01:35:36,20 PM [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'.
01:35:36,21 PM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Starting ShardManager shard-manager-config11
01:35:36,22 PM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - Recovery complete : shard-manager-config11
01:35:36,43 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1
01:35:36,43 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config11: onAddShardReplica: AddShardReplica[ShardName=astronauts]
01:35:36,44 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config11: Sending AddServer message to peer akka://test@127.0.0.1:2565/system/testProbe-27#284513931 for shard member-1-shard-astronauts-config11
01:35:36,55 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config11: onRemoveShardReplica: RemoveShardReplica [shardName=astronauts, memberName=MemberName{name=member-2}]
01:35:36,56 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config11: A shard replica operation for astronauts is already in progress
01:35:36,160 PM [main] [INFO] ShardManagerTest - testPerShardDatastoreContext starting
01:35:36,168 PM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Starting ShardManager shard-manager-config12
01:35:36,168 PM [test-akka.actor.default-dispatcher-11] [INFO] EmptyLocalActorRef - Message [org.opendaylight.controller.cluster.common.actor.Monitor] from Actor[akka://test/user/$g#802431703] to Actor[akka://test/user/termination-monitor] was not delivered. [10] dead letters encountered, no more dead letters will be logged in next [5.000 min]. If this is not an expected behavior then Actor[akka://test/user/termination-monitor] may have terminated unexpectedly. This logging can be turned off or adjusted with configuration settings 'akka.log-dead-letters' and 'akka.log-dead-letters-during-shutdown'.
01:35:36,169 PM [test-akka.actor.default-dispatcher-5] [INFO] ShardManager - Recovery complete : shard-manager-config12
01:35:36,169 PM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - shard-manager-config12: Creating local shard: member-1-shard-default-config12
01:35:36,170 PM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - shard-manager-config12: Creating local shard: member-1-shard-topology-config12
01:35:36,178 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1
01:35:36,178 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - Creating Shard member-1-shard-default-config12
01:35:36,178 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - Creating Shard member-1-shard-topology-config12
01:35:36,180 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardInformation - Sending new DatastoreContext to member-1-shard-default-config12
01:35:36,180 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardInformation - Sending new DatastoreContext to member-1-shard-topology-config12
01:35:36,231 PM [main] [INFO] ShardManagerTest - testPerShardDatastoreContext ending
01:35:36,332 PM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/default1#-5966297]
01:35:36,343 PM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/topology2#-692757388]
01:35:36,344 PM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/$g#802431703]
01:35:36,344 PM [test-akka.actor.default-dispatcher-5] [INFO] ShardManager - Stopping ShardManager shard-manager-config12
01:35:36,347 PM [main] [INFO] ShardManagerTest - testOnReceiveFindPrimaryForLocalLeaderShard starting
01:35:36,350 PM [test-akka.actor.default-dispatcher-5] [INFO] ShardManager - Starting ShardManager shard-manager-config13
01:35:36,352 PM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Recovery complete : shard-manager-config13
01:35:36,352 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config13: Creating local shard: member-1-shard-default-config13
01:35:36,362 PM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1
01:35:36,362 PM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - Creating Shard member-1-shard-default-config13
01:35:36,362 PM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - shard-manager-config13: Initializing shard [default]
01:35:36,362 PM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardInformation - Shard member-1-shard-default-config13 is initialized
01:35:36,362 PM [test-akka.actor.default-dispatcher-5] [INFO] ShardManager - shard-manager-config13: Received LeaderStateChanged message: LeaderStateChanged [memberId=member-1-shard-default-config13, leaderId=member-1-shard-default-config13, leaderPayloadVersion=13]
01:35:36,413 PM [test-akka.actor.default-dispatcher-5] [INFO] ShardManager - shard-manager-config13: Received role changed for member-1-shard-default-config13 from Candidate to Leader
01:35:36,413 PM [test-akka.actor.default-dispatcher-5] [INFO] ShardManager - shard-manager-config13: All Shards are ready - data store config13 is ready
01:35:36,413 PM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - shard-manager-config13: In findPrimary: org.opendaylight.controller.cluster.datastore.messages.FindPrimary [shardName=default, waitUntilReady=false]
01:35:36,413 PM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - shard-manager-config13: Found primary for default: LocalPrimaryShardFound [primaryPath=akka://test@127.0.0.1:2565/user/member-1-shard-default-config#-586693026, localShardDataTree=org.opendaylight.yangtools.yang.data.tree.api.DataTree$MockitoMock$yZQhsnCX@52e54aaa]
01:35:36,413 PM [main] [INFO] ShardManagerTest - testOnReceiveFindPrimaryForLocalLeaderShard ending
01:35:36,515 PM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/$h#-2019266739]
01:35:36,526 PM [test-akka.actor.default-dispatcher-5] [INFO] ShardManager - Stopping ShardManager shard-manager-config13
01:35:36,529 PM [main] [INFO] ShardManagerTest - testShardAvailabilityChangeOnMemberWithNameContainedInLeaderIdUnreachable starting
01:35:36,538 PM [cluster-test-akka.actor.default-dispatcher-4] [INFO] Slf4jLogger - Slf4jLogger started
01:35:36,552 PM [cluster-test-akka.actor.default-dispatcher-4] [INFO] ArteryTransport - Remoting started with transport [Artery tcp]; listening on address [akka://cluster-test@127.0.0.1:2562] with UID [-7761817050266524988]
01:35:36,552 PM [cluster-test-akka.actor.default-dispatcher-4] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2562] - Starting up, Akka version [2.6.21] ...
01:35:36,559 PM [cluster-test-akka.actor.default-dispatcher-4] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2562] - Registered cluster JMX MBean [akka:type=Cluster]
01:35:36,559 PM [cluster-test-akka.actor.default-dispatcher-4] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2562] - Started up successfully
01:35:36,569 PM [cluster-test-akka.actor.default-dispatcher-10] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2562] - No downing-provider-class configured, manual cluster downing required, see https://doc.akka.io/docs/akka/current/typed/cluster.html#downing
01:35:36,569 PM [cluster-test-akka.actor.default-dispatcher-10] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2562] - No seed-nodes configured, manual cluster join required, see https://doc.akka.io/docs/akka/current/typed/cluster.html#joining
01:35:36,578 PM [cluster-test-akka.actor.default-dispatcher-10] [INFO] ShardManager - Starting ShardManager shard-manager-config14
01:35:36,578 PM [cluster-test-akka.actor.default-dispatcher-4] [INFO] EmptyLocalActorRef - Message [org.opendaylight.controller.cluster.common.actor.Monitor] from TestActor[akka://cluster-test/user/shardmanager-config14] to Actor[akka://cluster-test/user/termination-monitor] was not delivered. [1] dead letters encountered. If this is not an expected behavior then Actor[akka://cluster-test/user/termination-monitor] may have terminated unexpectedly. This logging can be turned off or adjusted with configuration settings 'akka.log-dead-letters' and 'akka.log-dead-letters-during-shutdown'.
01:35:36,582 PM [cluster-test-akka.actor.default-dispatcher-4] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2562] - Node [akka://cluster-test@127.0.0.1:2562] is JOINING itself (with roles [member-256, dc-default], version [0.0.0]) and forming new cluster
01:35:36,602 PM [cluster-test-akka.actor.default-dispatcher-14] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2562] - is the new leader among reachable nodes (more leaders may exist)
01:35:36,602 PM [cluster-test-akka.actor.default-dispatcher-14] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2562] - Leader is moving node [akka://cluster-test@127.0.0.1:2562] to [Up]
01:35:36,609 PM [cluster-test-akka.actor.default-dispatcher-14] [INFO] ShardManager - Recovery complete : shard-manager-config14
01:35:36,610 PM [cluster-test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - shard-manager-config14: Creating local shard: member-256-shard-default-config14
01:35:36,610 PM [cluster-test-akka.actor.default-dispatcher-14] [INFO] ShardManager - shard-manager-config14: Received MemberUp: memberName: MemberName{name=member-256}, address: akka://cluster-test@127.0.0.1:2562
01:35:36,610 PM [cluster-test-akka.actor.default-dispatcher-14] [INFO] ShardInformation - updatePeerAddress for peer member-256-shard-default-config14 with address akka://cluster-test@127.0.0.1:2562/user/shardmanager-config14/member-256-shard-default-config14
01:35:36,610 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] Slf4jLogger - Slf4jLogger started
01:35:36,650 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] ArteryTransport - Remoting started with transport [Artery tcp]; listening on address [akka://cluster-test@127.0.0.1:2559] with UID [4619770366941895646]
01:35:36,650 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2559] - Starting up, Akka version [2.6.21] ...
01:35:36,681 PM [cluster-test-akka.actor.default-dispatcher-5] [WARN] Cluster - Could not register Cluster JMX MBean with name=akka:type=Cluster as it is already registered. If you are running multiple clusters in the same JVM, set 'akka.cluster.jmx.multi-mbeans-in-same-jvm = on' in config
01:35:36,681 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2559] - Started up successfully
01:35:36,681 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2559] - No downing-provider-class configured, manual cluster downing required, see https://doc.akka.io/docs/akka/current/typed/cluster.html#downing
01:35:36,681 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2559] - No seed-nodes configured, manual cluster join required, see https://doc.akka.io/docs/akka/current/typed/cluster.html#joining
01:35:36,684 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] ShardManager - Starting ShardManager shard-manager-config14
01:35:36,684 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] EmptyLocalActorRef - Message [org.opendaylight.controller.cluster.common.actor.Monitor] from TestActor[akka://cluster-test/user/shardmanager-config14] to Actor[akka://cluster-test/user/termination-monitor] was not delivered. [1] dead letters encountered. If this is not an expected behavior then Actor[akka://cluster-test/user/termination-monitor] may have terminated unexpectedly. This logging can be turned off or adjusted with configuration settings 'akka.log-dead-letters' and 'akka.log-dead-letters-during-shutdown'.
01:35:36,688 PM [cluster-test-akka.actor.default-dispatcher-13] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1
01:35:36,688 PM [cluster-test-akka.actor.default-dispatcher-13] [DEBUG] ShardManager - Creating Shard member-256-shard-default-config14
01:35:36,688 PM [cluster-test-akka.actor.default-dispatcher-13] [INFO] ShardInformation - updatePeerAddress for peer member-256-shard-default-config14 with address akka://cluster-test@127.0.0.1:2562/user/shardmanager-config14/member-256-shard-default-config14
01:35:36,688 PM [cluster-test-akka.actor.default-dispatcher-13] [DEBUG] ShardInformation - Sending PeerAddressResolved for peer member-256-shard-default-config14 with address akka://cluster-test@127.0.0.1:2562/user/shardmanager-config14/member-256-shard-default-config14 to akka://cluster-test/user/member-256-shard-default-config
01:35:36,688 PM [cluster-test-akka.actor.default-dispatcher-13] [DEBUG] ShardManager - shard-manager-config14: updated peer member-256-shard-default-config14 on member MemberName{name=member-256} with address akka://cluster-test@127.0.0.1:2562/user/shardmanager-config14/member-256-shard-default-config14 on shard member-256-shard-default-config14 whose actor address is Actor[akka://cluster-test/user/member-256-shard-default-config#-1539224936]
01:35:36,688 PM [cluster-test-akka.actor.default-dispatcher-13] [DEBUG] ShardManager - shard-manager-config14: Initializing shard [default]
01:35:36,688 PM [cluster-test-akka.actor.default-dispatcher-13] [DEBUG] ShardInformation - Shard member-256-shard-default-config14 is initialized
01:35:36,688 PM [cluster-test-akka.actor.default-dispatcher-13] [INFO] ShardManager - shard-manager-config14: Received LeaderStateChanged message: LeaderStateChanged [memberId=member-256-shard-default-config14, leaderId=member-256-shard-default-config14, leaderPayloadVersion=13]
01:35:36,688 PM [cluster-test-akka.actor.default-dispatcher-13] [INFO] ShardManager - shard-manager-config14: Received role changed for member-256-shard-default-config14 from Candidate to Leader
01:35:36,688 PM [cluster-test-akka.actor.default-dispatcher-13] [INFO] ShardManager - shard-manager-config14: All Shards are ready - data store config14 is ready
01:35:36,692 PM [cluster-test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Recovery complete : shard-manager-config14
01:35:36,692 PM [cluster-test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config14: Creating local shard: member-2-shard-default-config14
01:35:36,701 PM [cluster-test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1
01:35:36,701 PM [cluster-test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - Creating Shard member-2-shard-default-config14
01:35:36,701 PM [cluster-test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config14: Initializing shard [default]
01:35:36,701 PM [cluster-test-akka.actor.default-dispatcher-11] [DEBUG] ShardInformation - Shard member-2-shard-default-config14 is initialized
01:35:36,701 PM [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]
01:35:36,701 PM [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
01:35:36,742 PM [cluster-test-akka.actor.default-dispatcher-13] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2562] - Node [akka://cluster-test@127.0.0.1:2559] is JOINING, roles [member-2, dc-default], version [0.0.0]
01:35:36,746 PM [cluster-test-akka.actor.default-dispatcher-16] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2559] - Welcome from [akka://cluster-test@127.0.0.1:2562]
01:35:36,747 PM [cluster-test-akka.actor.default-dispatcher-16] [INFO] ShardManager - shard-manager-config14: Received MemberUp: memberName: MemberName{name=member-256}, address: akka://cluster-test@127.0.0.1:2562
01:35:36,747 PM [cluster-test-akka.actor.default-dispatcher-16] [INFO] ShardInformation - updatePeerAddress for peer member-256-shard-default-config14 with address akka://cluster-test@127.0.0.1:2562/user/shardmanager-config14/member-256-shard-default-config14
01:35:36,747 PM [cluster-test-akka.actor.default-dispatcher-16] [DEBUG] ShardInformation - Sending PeerAddressResolved for peer member-256-shard-default-config14 with address akka://cluster-test@127.0.0.1:2562/user/shardmanager-config14/member-256-shard-default-config14 to akka://cluster-test/user/member-2-shard-default-config
01:35:36,747 PM [cluster-test-akka.actor.default-dispatcher-16] [INFO] ShardManager - shard-manager-config14: All Shards are ready - data store config14 is ready
01:35:37,586 PM [cluster-test-akka.actor.default-dispatcher-13] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2562] - Leader is moving node [akka://cluster-test@127.0.0.1:2559] to [Up]
01:35:37,588 PM [cluster-test-akka.actor.default-dispatcher-13] [INFO] ShardManager - shard-manager-config14: Received MemberUp: memberName: MemberName{name=member-2}, address: akka://cluster-test@127.0.0.1:2559
01:35:37,588 PM [cluster-test-akka.actor.default-dispatcher-13] [INFO] ShardInformation - updatePeerAddress for peer member-2-shard-default-config14 with address akka://cluster-test@127.0.0.1:2559/user/shardmanager-config14/member-2-shard-default-config14
01:35:37,588 PM [cluster-test-akka.actor.default-dispatcher-13] [DEBUG] ShardInformation - Sending PeerAddressResolved for peer member-2-shard-default-config14 with address akka://cluster-test@127.0.0.1:2559/user/shardmanager-config14/member-2-shard-default-config14 to akka://cluster-test/user/member-256-shard-default-config
01:35:37,588 PM [cluster-test-akka.actor.default-dispatcher-13] [INFO] ShardManager - shard-manager-config14: All Shards are ready - data store config14 is ready
01:35:37,589 PM [cluster-test-akka.actor.default-dispatcher-13] [DEBUG] ShardManager - shard-manager-config14: In findPrimary: org.opendaylight.controller.cluster.datastore.messages.FindPrimary [shardName=default, waitUntilReady=true]
01:35:37,589 PM [cluster-test-akka.actor.default-dispatcher-13] [DEBUG] ShardManager - shard-manager-config14: Found primary for default: LocalPrimaryShardFound [primaryPath=akka://cluster-test@127.0.0.1:2562/user/member-256-shard-default-config#-1539224936, localShardDataTree=org.opendaylight.yangtools.yang.data.tree.api.DataTree$MockitoMock$yZQhsnCX@653cfba0]
01:35:37,590 PM [cluster-test-akka.actor.default-dispatcher-4] [INFO] ShardManager - Received UnreachableMember: memberName MemberName{name=member-2}, address: akka://cluster-test@127.0.0.1:2558
01:35:37,591 PM [cluster-test-akka.actor.default-dispatcher-4] [DEBUG] ShardManager - shard-manager-config14: In findPrimary: org.opendaylight.controller.cluster.datastore.messages.FindPrimary [shardName=default, waitUntilReady=true]
01:35:37,591 PM [cluster-test-akka.actor.default-dispatcher-4] [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#-1539224936, localShardDataTree=org.opendaylight.yangtools.yang.data.tree.api.DataTree$MockitoMock$yZQhsnCX@653cfba0]
01:35:37,593 PM [main] [INFO] ShardManagerTest - testShardAvailabilityChangeOnMemberWithNameContainedInLeaderIdUnreachable ending
01:35:37,695 PM [cluster-test-akka.actor.default-dispatcher-13] [INFO] ShardManager - Stopping ShardManager shard-manager-config14
01:35:37,697 PM [cluster-test-akka.actor.default-dispatcher-11] [INFO] RemoteActorRefProvider$RemotingTerminator - Shutting down remote daemon.
01:35:37,697 PM [cluster-test-akka.actor.default-dispatcher-11] [INFO] RemoteActorRefProvider$RemotingTerminator - Remote daemon shut down; proceeding with flushing remote transports.
01:35:37,701 PM [cluster-test-akka.actor.default-dispatcher-16] [INFO] ShardManager - shard-manager-config14: Received MemberUp: memberName: MemberName{name=member-2}, address: akka://cluster-test@127.0.0.1:2559
01:35:37,701 PM [cluster-test-akka.actor.default-dispatcher-16] [INFO] ShardInformation - updatePeerAddress for peer member-2-shard-default-config14 with address akka://cluster-test@127.0.0.1:2559/user/shardmanager-config14/member-2-shard-default-config14
01:35:37,701 PM [cluster-test-akka.actor.default-dispatcher-16] [DEBUG] ShardInformation - Sending PeerAddressResolved for peer member-2-shard-default-config14 with address akka://cluster-test@127.0.0.1:2559/user/shardmanager-config14/member-2-shard-default-config14 to akka://cluster-test/user/member-2-shard-default-config
01:35:37,701 PM [cluster-test-akka.actor.default-dispatcher-16] [INFO] ShardManager - shard-manager-config14: All Shards are ready - data store config14 is ready
01:35:37,717 PM [cluster-test-akka.actor.default-dispatcher-11] [WARN] Materializer - [outbound connection to [akka://cluster-test@127.0.0.1:2559], control stream] Upstream failed, cause: StreamTcpException: The connection has been aborted
01:35:37,717 PM [cluster-test-akka.actor.default-dispatcher-11] [WARN] Materializer - [outbound connection to [akka://cluster-test@127.0.0.1:2559], message stream] Upstream failed, cause: StreamTcpException: The connection has been aborted
01:35:37,721 PM [cluster-test-akka.actor.default-dispatcher-11] [INFO] RemoteActorRefProvider$RemotingTerminator - Remoting shut down.
01:35:37,738 PM [cluster-test-akka.actor.default-dispatcher-22] [INFO] ShardManager - Stopping ShardManager shard-manager-config14
01:35:37,739 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] RemoteActorRefProvider$RemotingTerminator - Shutting down remote daemon.
01:35:37,739 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] RemoteActorRefProvider$RemotingTerminator - Remote daemon shut down; proceeding with flushing remote transports.
01:35:38,707 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2559] - is the new leader among reachable nodes (more leaders may exist)
01:35:38,760 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] RemoteActorRefProvider$RemotingTerminator - Remoting shut down.
[WARN] [03/11/2024 13:35:38.764] [cluster-test-akka.actor.internal-dispatcher-2] [Cluster(akka://cluster-test)] Could not unregister Cluster JMX MBean with name=akka:type=Cluster as it was not found. If you are running multiple clusters in the same JVM, set 'akka.cluster.jmx.multi-mbeans-in-same-jvm = on' in config
01:35:38,774 PM [main] [INFO] ShardManager - Starting ShardManager shard-manager-config15
01:35:38,775 PM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Recovery complete : shard-manager-config15
01:35:38,775 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config15: Creating local shard: member-1-shard-default-config15
01:35:38,777 PM [main] [INFO] ShardManager - shard-manager-config15: Received role changed for member-1-shard-default-config15 from Follower to Leader
01:35:38,879 PM [main] [INFO] TestActorFactory - Killing actor TestActor[akka://test/user/$$d]
01:35:38,890 PM [main] [INFO] ShardManager - Stopping ShardManager shard-manager-config15
01:35:38,896 PM [main] [INFO] ShardManager - Starting ShardManager shard-manager-config16
01:35:38,898 PM [test-akka.actor.default-dispatcher-5] [INFO] ShardManager - Recovery complete : shard-manager-config16
01:35:38,898 PM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - shard-manager-config16: Creating local shard: member-1-shard-default-config16
01:35:38,898 PM [main] [INFO] ShardManager - shard-manager-config16: Received role changed for member-1-shard-default-config16 from Candidate to Leader
01:35:38,899 PM [main] [INFO] ShardManager - shard-manager-config16: Received LeaderStateChanged message: LeaderStateChanged [memberId=member-1-shard-default-config16, leaderId=member-1-shard-default-config16, leaderPayloadVersion=13]
01:35:38,899 PM [main] [INFO] ShardManager - shard-manager-config16: All Shards are ready - data store config16 is ready
01:35:39,0 PM [main] [INFO] TestActorFactory - Killing actor TestActor[akka://test/user/$$e]
01:35:39,11 PM [main] [INFO] ShardManager - Stopping ShardManager shard-manager-config16
01:35:39,14 PM [main] [INFO] ShardManagerTest - testOnCreateShardWithLocalMemberNotInShardConfig starting
01:35:39,16 PM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Starting ShardManager shard-manager-config17
01:35:39,18 PM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Recovery complete : shard-manager-config17
01:35:39,19 PM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1
01:35:39,33 PM [test-akka.actor.default-dispatcher-5] [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@3e55666e]
01:35:39,33 PM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - shard-manager-config17 doCreateShard: shardId: member-1-shard-foo-config17, memberNames: [MemberName{name=member-5}, MemberName{name=member-6}], peerAddresses: {}, isActiveMember: false
01:35:39,34 PM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - shard-manager-config17: findLocalShard : foo
01:35:39,34 PM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - shard-manager-config17: Scheduling 60000 ms timer to wait for shard ShardInformation [shardId=member-1-shard-foo-config17, leaderAvailable=false, actorInitialized=false, followerSyncStatus=false, role=null, leaderId=null, activeMember=false]
01:35:39,35 PM [test-shard-dispatcher-15] [INFO] Shard - Shard created : member-1-shard-foo-config17, persistent : true
01:35:39,36 PM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardSnapshotActor - Actor created Actor[akka://test/user/$i/member-1-shard-foo-config17/shard-member-1:snapshot-read#398250223]
01:35:39,36 PM [test-akka.actor.default-dispatcher-5] [INFO] RoleChangeNotifier - RoleChangeNotifier:akka://test@127.0.0.1:2565/user/$i/member-1-shard-foo-config17/member-1-shard-foo-config17-notifier#-1227142421 created and ready for shard:member-1-shard-foo-config17
01:35:39,36 PM [test-shard-dispatcher-15] [INFO] Shard - Starting recovery for member-1-shard-foo-config17 with journal batch size 1
01:35:39,37 PM [test-shard-dispatcher-15] [DEBUG] Shard - member-1-shard-foo-config17: onReceiveRecover: Received message class akka.persistence.RecoveryCompleted$ from Actor[akka://test/deadLetters]
01:35:39,37 PM [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
01:35:39,37 PM [test-shard-dispatcher-15] [DEBUG] DataTreeChangeListenerSupport - member-1-shard-foo-config17: onLeadershipChange, isLeader: false, hasLeader : false
01:35:39,38 PM [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
01:35:39,38 PM [test-shard-dispatcher-15] [INFO] DefaultConfigParamsImpl - Trying to use custom RaftPolicy org.opendaylight.controller.cluster.raft.policy.DisableElectionsRaftPolicy
01:35:39,38 PM [test-akka.actor.default-dispatcher-10] [INFO] RoleChangeNotifier - RoleChangeNotifier for member-1-shard-foo-config17 , received role change from null to Follower
01:35:39,38 PM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - shard-manager-config17: Initializing shard [foo]
01:35:39,38 PM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardInformation - Shard member-1-shard-foo-config17 is initialized
01:35:39,38 PM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardInformation - Shard member-1-shard-foo-config17 is initialized - notifying 1 OnShardInitialized callbacks
01:35:39,38 PM [test-akka.actor.default-dispatcher-5] [INFO] RoleChangeNotifier - RoleChangeNotifier for member-1-shard-foo-config17 , registered listener akka://test/user/$i
01:35:39,38 PM [test-akka.actor.default-dispatcher-5] [INFO] ShardManager - shard-manager-config17: Received role changed for member-1-shard-foo-config17 from null to Follower
01:35:39,43 PM [main] [INFO] ShardManagerTest - testOnCreateShardWithLocalMemberNotInShardConfig ending
01:35:39,144 PM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/$i#-862051584]
01:35:39,156 PM [test-shard-dispatcher-15] [INFO] Shard - Stopping Shard member-1-shard-foo-config17
01:35:39,156 PM [test-shard-dispatcher-15] [DEBUG] MessageAssembler - member-1-shard-foo-config17 (Follower): Closing
01:35:39,156 PM [test-shard-dispatcher-15] [DEBUG] Shard - member-1-shard-foo-config17: Aborting 0 pending queued transactions
01:35:39,156 PM [test-akka.actor.default-dispatcher-14] [INFO] ShardManager - Stopping ShardManager shard-manager-config17
01:35:39,159 PM [main] [INFO] ShardManagerTest - testServerRemovedShardActorNotRunning starting
01:35:39,162 PM [test-akka.actor.default-dispatcher-14] [INFO] ShardManager - Starting ShardManager shard-manager-config18
01:35:39,163 PM [test-akka.actor.default-dispatcher-5] [INFO] ShardManager - Recovery complete : shard-manager-config18
01:35:39,163 PM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - shard-manager-config18: Creating local shard: member-1-shard-default-config18
01:35:39,163 PM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - shard-manager-config18: Creating local shard: member-1-shard-people-config18
01:35:39,272 PM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - shard-manager-config18: findLocalShard : people
01:35:39,272 PM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - shard-manager-config18: Returning NotInitializedException for shard people
01:35:39,273 PM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - shard-manager-config18: findLocalShard : default
01:35:39,273 PM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - shard-manager-config18: Returning NotInitializedException for shard default
01:35:39,275 PM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - shard-manager-config18 : Local Shard replica for shard default has been removed
01:35:39,275 PM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - shard-manager-config18: persisting the shard list [people]
01:35:39,276 PM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - shard-manager-config18 saved ShardManager snapshot successfully. Deleting the prev snapshot if available
01:35:39,276 PM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - shard-manager-config18: Successfully deleted prior snapshots
01:35:39,276 PM [main] [INFO] ShardManagerTest - testServerRemovedShardActorNotRunning ending
01:35:39,377 PM [main] [INFO] TestActorFactory - Killing actor TestActor[akka://test/user/$$f]
01:35:39,388 PM [test-akka.actor.default-dispatcher-14] [INFO] ShardManager - Stopping ShardManager shard-manager-config18
01:35:39,393 PM [test-akka.actor.default-dispatcher-5] [INFO] ShardManager - Starting ShardManager shard-manager-config19
01:35:39,394 PM [test-akka.actor.default-dispatcher-14] [INFO] ShardManager - Recovery complete : shard-manager-config19
01:35:39,394 PM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - shard-manager-config19: Creating local shard: member-1-shard-default-config19
01:35:39,403 PM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1
01:35:39,404 PM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - Creating Shard member-1-shard-default-config19
01:35:39,404 PM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - shard-manager-config19: Initializing shard [default]
01:35:39,404 PM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardInformation - Shard member-1-shard-default-config19 is initialized
01:35:39,404 PM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - shard-manager-config19: In findPrimary: org.opendaylight.controller.cluster.datastore.messages.FindPrimary [shardName=default, waitUntilReady=false]
01:35:39,404 PM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - shard-manager-config19: Returning NoShardLeaderException for shard default
01:35:39,505 PM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/$j#-295253922]
01:35:39,516 PM [test-akka.actor.default-dispatcher-5] [INFO] ShardManager - Stopping ShardManager shard-manager-config19
01:35:39,518 PM [main] [INFO] ShardManagerTest - testOnReceiveFindPrimaryForFollowerShardWithNoInitialLeaderId starting
01:35:39,522 PM [test-akka.actor.default-dispatcher-14] [INFO] ShardManager - Starting ShardManager shard-manager-config20
01:35:39,523 PM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - Recovery complete : shard-manager-config20
01:35:39,523 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config20: Creating local shard: member-1-shard-default-config20
01:35:39,534 PM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1
01:35:39,534 PM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - Creating Shard member-1-shard-default-config20
01:35:39,534 PM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - shard-manager-config20: Initializing shard [default]
01:35:39,534 PM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardInformation - Shard member-1-shard-default-config20 is initialized
01:35:39,534 PM [test-akka.actor.default-dispatcher-14] [INFO] ShardManager - shard-manager-config20: Received role changed for member-1-shard-default-config20 from Candidate to Follower
01:35:39,534 PM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - shard-manager-config20: In findPrimary: org.opendaylight.controller.cluster.datastore.messages.FindPrimary [shardName=default, waitUntilReady=false]
01:35:39,534 PM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - shard-manager-config20: Returning NoShardLeaderException for shard default
01:35:39,535 PM [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]
01:35:39,535 PM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - shard-manager-config20: All Shards are ready - data store config20 is ready
01:35:39,535 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config20: In findPrimary: org.opendaylight.controller.cluster.datastore.messages.FindPrimary [shardName=default, waitUntilReady=false]
01:35:39,535 PM [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#849574630, localShardDataTree=org.opendaylight.yangtools.yang.data.tree.api.DataTree$MockitoMock$yZQhsnCX@702bb00f]
01:35:39,535 PM [main] [INFO] ShardManagerTest - testOnReceiveFindPrimaryForFollowerShardWithNoInitialLeaderId starting
01:35:39,637 PM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/$k#-1484230562]
01:35:39,648 PM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Stopping ShardManager shard-manager-config20
01:35:39,652 PM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Starting ShardManager shard-manager-config21
01:35:39,653 PM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - Recovery complete : shard-manager-config21
01:35:39,674 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1
01:35:39,674 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config21: onAddShardReplica: AddShardReplica[ShardName=astronauts]
01:35:39,675 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config21: Sending AddServer message to peer akka://test@127.0.0.1:2565/system/testProbe-45#-1392564353 for shard member-1-shard-astronauts-config21
01:35:39,686 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config21: onAddShardReplica: AddShardReplica[ShardName=astronauts]
01:35:39,686 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config21: A shard replica operation for astronauts is already in progress
01:35:39,791 PM [main] [INFO] ShardManagerTest - testOnReceiveFindPrimaryWaitForReadyWithCandidateShard starting
01:35:39,794 PM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - Starting ShardManager shard-manager-config22
01:35:39,795 PM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - Recovery complete : shard-manager-config22
01:35:39,796 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config22: Creating local shard: member-1-shard-default-config22
01:35:39,805 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1
01:35:39,805 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - Creating Shard member-1-shard-default-config22
01:35:39,805 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config22: Initializing shard [default]
01:35:39,805 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardInformation - Shard member-1-shard-default-config22 is initialized
01:35:39,805 PM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - shard-manager-config22: Received role changed for member-1-shard-default-config22 from null to Candidate
01:35:39,805 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config22: In findPrimary: org.opendaylight.controller.cluster.datastore.messages.FindPrimary [shardName=default, waitUntilReady=true]
01:35:39,805 PM [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]
01:35:41,16 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config22: Received ShardNotInitializedTimeout message for shard default
01:35:41,16 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config22: Returning NoShardLeaderException for shard default
01:35:41,17 PM [main] [INFO] ShardManagerTest - testOnReceiveFindPrimaryWaitForReadyWithCandidateShard ending
01:35:41,119 PM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/$l#909407279]
01:35:41,132 PM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Stopping ShardManager shard-manager-config22
01:35:41,135 PM [main] [INFO] ShardManagerTest - testAddShardReplicaWithAddServerReplyFailure starting
01:35:41,143 PM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Starting ShardManager shard-manager-config23
01:35:41,144 PM [test-akka.actor.default-dispatcher-14] [INFO] ShardManager - Recovery complete : shard-manager-config23
01:35:41,264 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1
01:35:41,274 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config23: onAddShardReplica: AddShardReplica[ShardName=astronauts]
01:35:41,275 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config23: Sending AddServer message to peer akka://test@127.0.0.1:2565/system/testProbe-50#1876607059 for shard member-1-shard-astronauts-config23
01:35:41,276 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config23: Received AddServerReply{status=TIMEOUT} for shard astronauts from leader akka://test@127.0.0.1:2565/system/testProbe-50#1876607059
01:35:41,276 PM [test-akka.actor.default-dispatcher-11] [WARN] ShardManager - shard-manager-config23: Leader failed to add shard replica astronauts with status TIMEOUT
01:35:41,277 PM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - shard-manager-config23: findLocalShard : astronauts
01:35:41,277 PM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - shard-manager-config23: Local shard astronauts not found - shards present: []
01:35:41,277 PM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - shard-manager-config23: onAddShardReplica: AddShardReplica[ShardName=astronauts]
01:35:41,278 PM [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-50#1876607059 for shard member-1-shard-astronauts-config23
01:35:41,279 PM [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-50#1876607059
01:35:41,279 PM [test-akka.actor.default-dispatcher-14] [WARN] ShardManager - shard-manager-config23: Leader failed to add shard replica astronauts with status NO_LEADER
01:35:41,279 PM [main] [INFO] ShardManagerTest - testAddShardReplicaWithAddServerReplyFailure ending
01:35:41,380 PM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/member-1-shard-astronauts-config#-1421766251]
01:35:41,391 PM [main] [INFO] TestActorFactory - Killing actor TestActor[akka://test/user/shardmanager-config23]
01:35:41,391 PM [test-akka.actor.default-dispatcher-14] [INFO] ShardManager - Stopping ShardManager shard-manager-config23
01:35:41,396 PM [main] [INFO] ShardManager - Starting ShardManager shard-manager-config24
01:35:41,397 PM [test-akka.actor.default-dispatcher-14] [INFO] ShardManager - Recovery complete : shard-manager-config24
01:35:41,397 PM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - shard-manager-config24: Creating local shard: member-1-shard-default-config24
01:35:41,398 PM [main] [INFO] ShardManager - shard-manager-config24: Received role changed for member-1-shard-default-config24 from Candidate to Follower
01:35:41,398 PM [main] [INFO] ShardManager - shard-manager-config24 Received follower initial sync status for member-1-shard-default-config24 status sync done true
01:35:41,398 PM [main] [INFO] ShardManager - shard-manager-config24 Received follower initial sync status for member-1-shard-default-config24 status sync done false
01:35:41,499 PM [main] [INFO] TestActorFactory - Killing actor TestActor[akka://test/user/$$g]
01:35:41,510 PM [main] [INFO] ShardManager - Stopping ShardManager shard-manager-config24
01:35:41,515 PM [main] [INFO] ShardManager - Starting ShardManager shard-manager-config25
01:35:41,516 PM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Recovery complete : shard-manager-config25
01:35:41,516 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config25: Creating local shard: member-1-shard-default-config25
01:35:41,517 PM [main] [INFO] ShardManager - shard-manager-config25: Received role changed for unknown from Candidate to Leader
01:35:41,618 PM [main] [INFO] TestActorFactory - Killing actor TestActor[akka://test/user/$$h]
01:35:41,629 PM [main] [INFO] ShardManager - Stopping ShardManager shard-manager-config25
01:35:41,631 PM [main] [INFO] ShardManagerTest - testOnReceiveFindPrimaryWaitForReadyWithUninitializedShard starting
01:35:41,634 PM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Starting ShardManager shard-manager-config26
01:35:41,635 PM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - Recovery complete : shard-manager-config26
01:35:41,635 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config26: Creating local shard: member-1-shard-default-config26
01:35:41,644 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1
01:35:41,644 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - Creating Shard member-1-shard-default-config26
01:35:41,644 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config26: In findPrimary: org.opendaylight.controller.cluster.datastore.messages.FindPrimary [shardName=default, waitUntilReady=true]
01:35:41,644 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config26: Scheduling 600 ms timer to wait for shard ShardInformation [shardId=member-1-shard-default-config26, leaderAvailable=false, actorInitialized=false, followerSyncStatus=false, role=null, leaderId=null, activeMember=true]
01:35:42,257 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config26: Received ShardNotInitializedTimeout message for shard default
01:35:42,257 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config26: Returning NotInitializedException for shard default
01:35:42,258 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config26: Initializing shard [default]
01:35:42,258 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardInformation - Shard member-1-shard-default-config26 is initialized
01:35:42,458 PM [main] [INFO] ShardManagerTest - testOnReceiveFindPrimaryWaitForReadyWithUninitializedShard ending
01:35:42,559 PM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/$m#1883415750]
01:35:42,570 PM [test-akka.actor.default-dispatcher-14] [INFO] ShardManager - Stopping ShardManager shard-manager-config26
01:35:42,579 PM [test-akka.actor.default-dispatcher-14] [INFO] ShardManager - Starting ShardManager shard-manager-config27
01:35:42,580 PM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Recovery complete : shard-manager-config27
01:35:42,580 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config27: Creating local shard: member-1-shard-default-config27
01:35:42,591 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1
01:35:42,591 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - Creating Shard member-1-shard-default-config27
01:35:42,591 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config27: Initializing shard [default]
01:35:42,591 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardInformation - Shard member-1-shard-default-config27 is initialized
01:35:42,591 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config27: findLocalShard : default
01:35:42,692 PM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/$n#1314369926]
01:35:42,703 PM [test-akka.actor.default-dispatcher-14] [INFO] ShardManager - Stopping ShardManager shard-manager-config27
01:35:42,706 PM [main] [INFO] ShardManagerTest - testRegisterForShardLeaderChanges starting
01:35:42,709 PM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - Starting ShardManager shard-manager-config28
01:35:42,710 PM [test-akka.actor.default-dispatcher-14] [INFO] ShardManager - Recovery complete : shard-manager-config28
01:35:42,710 PM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - shard-manager-config28: Creating local shard: member-1-shard-default-config28
01:35:42,719 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1
01:35:42,719 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - Creating Shard member-1-shard-default-config28
01:35:42,719 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config28: Initializing shard [default]
01:35:42,719 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardInformation - Shard member-1-shard-default-config28 is initialized
01:35:42,792 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config28: onRegisterForShardAvailabilityChanges: org.opendaylight.controller.cluster.datastore.shardmanager.RegisterForShardAvailabilityChanges@4356324b
01:35:42,795 PM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - shard-manager-config28: Received LeaderStateChanged message: LeaderStateChanged [memberId=member-1-shard-default-config28, leaderId=member-1-shard-default-config28, leaderPayloadVersion=13]
01:35:42,805 PM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - shard-manager-config28: Received LeaderStateChanged message: LeaderStateChanged [memberId=member-1-shard-default-config28, leaderId=member-1-shard-default-config28, leaderPayloadVersion=13]
01:35:43,306 PM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - shard-manager-config28: Received LeaderStateChanged message: LeaderStateChanged [memberId=member-1-shard-default-config28, leaderId=null, leaderPayloadVersion=13]
01:35:43,317 PM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - shard-manager-config28: Received LeaderStateChanged message: LeaderStateChanged [memberId=member-1-shard-default-config28, leaderId=member-2-shard-default-config28, leaderPayloadVersion=13]
01:35:43,328 PM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - shard-manager-config28: Received LeaderStateChanged message: LeaderStateChanged [memberId=member-1-shard-default-config28, leaderId=member-1-shard-default-config28, leaderPayloadVersion=13]
01:35:43,828 PM [main] [INFO] ShardManagerTest - testRegisterForShardLeaderChanges ending
01:35:43,929 PM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/$o#859953122]
01:35:43,940 PM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - Stopping ShardManager shard-manager-config28
01:35:43,945 PM [main] [INFO] ShardManager - Starting ShardManager shard-manager-config29
01:35:43,946 PM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - Recovery complete : shard-manager-config29
01:35:43,947 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config29: Creating local shard: member-1-shard-default-config29
01:35:44,48 PM [main] [INFO] TestActorFactory - Killing actor TestActor[akka://test/user/$$i]
01:35:44,59 PM [main] [INFO] ShardManager - Stopping ShardManager shard-manager-config29
01:35:44,64 PM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - Starting ShardManager shard-manager-config30
01:35:44,65 PM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Recovery complete : shard-manager-config30
01:35:44,65 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config30: Creating local shard: member-1-shard-default-config30
01:35:44,74 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1
01:35:44,74 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - Creating Shard member-1-shard-default-config30
01:35:44,75 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config30: In findPrimary: org.opendaylight.controller.cluster.datastore.messages.FindPrimary [shardName=non-existent, waitUntilReady=false]
01:35:44,75 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config30: No shard found for non-existent
01:35:44,176 PM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/$p#1810029082]
01:35:44,187 PM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - Stopping ShardManager shard-manager-config30
01:35:44,192 PM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - Starting ShardManager shard-manager-config31
01:35:44,193 PM [test-akka.actor.default-dispatcher-14] [INFO] ShardManager - Recovery complete : shard-manager-config31
01:35:44,202 PM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - shard-manager-config31: onAddShardReplica: AddShardReplica[ShardName=model-inventory]
01:35:44,202 PM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - shard-manager-config31: No module configuration exists for shard model-inventory
01:35:44,304 PM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/$q#270264798]
01:35:44,315 PM [test-akka.actor.default-dispatcher-14] [INFO] ShardManager - Stopping ShardManager shard-manager-config31
01:35:44,318 PM [main] [INFO] ShardManagerTest - testAddShardReplicaWithPreExistingReplicaInRemoteShardLeader starting
01:35:44,321 PM [test-akka.actor.default-dispatcher-14] [INFO] ShardManager - Starting ShardManager shard-manager-config32
01:35:44,322 PM [test-akka.actor.default-dispatcher-14] [INFO] ShardManager - Recovery complete : shard-manager-config32
01:35:44,322 PM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - shard-manager-config32: Creating local shard: member-1-shard-default-config32
01:35:44,431 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1
01:35:44,431 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - Creating Shard member-1-shard-default-config32
01:35:44,431 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config32: Initializing shard [default]
01:35:44,431 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardInformation - Shard member-1-shard-default-config32 is initialized
01:35:44,431 PM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - shard-manager-config32: Received MemberUp: memberName: MemberName{name=leader-member}, address: akka://test
01:35:44,431 PM [test-akka.actor.default-dispatcher-10] [INFO] ShardInformation - updatePeerAddress for peer leader-member-shard-default-config32 with address akka://test/user/shardmanager-config32/leader-member-shard-default-config32
01:35:44,431 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardInformation - Sending PeerAddressResolved for peer leader-member-shard-default-config32 with address akka://test/user/shardmanager-config32/leader-member-shard-default-config32 to akka://test/user/member-1-shard-default-config
01:35:44,431 PM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - shard-manager-config32: Received role changed for member-1-shard-default-config32 from Candidate to Follower
01:35:44,431 PM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - shard-manager-config32: Received LeaderStateChanged message: LeaderStateChanged [memberId=member-1-shard-default-config32, leaderId=leader-member-shard-default-config32, leaderPayloadVersion=13]
01:35:44,431 PM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - shard-manager-config32: All Shards are ready - data store config32 is ready
01:35:44,431 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config32: onAddShardReplica: AddShardReplica[ShardName=default]
01:35:44,432 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config32: In findPrimary: org.opendaylight.controller.cluster.datastore.messages.FindPrimary [shardName=default, waitUntilReady=true]
01:35:44,432 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config32: Found primary for default: RemotePrimaryShardFound [primaryPath=akka://test/user/shardmanager-config32/leader-member-shard-default-config32, primaryVersion=13]
01:35:44,432 PM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - shard-manager-config32: Sending AddServer message to peer akka://test/user/shardmanager-config32/leader-member-shard-default-config32 for shard member-1-shard-default-config32
01:35:44,432 PM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - shard-manager-config32: Received AddServerReply{status=ALREADY_EXISTS} for shard default from leader akka://test/user/shardmanager-config32/leader-member-shard-default-config32
01:35:44,432 PM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - shard-manager-config32: Local shard default already exists
01:35:44,482 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config32: findLocalShard : default
01:35:44,482 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config32: onAddShardReplica: AddShardReplica[ShardName=default]
01:35:44,482 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config32: In findPrimary: org.opendaylight.controller.cluster.datastore.messages.FindPrimary [shardName=default, waitUntilReady=true]
01:35:44,482 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config32: Found primary for default: RemotePrimaryShardFound [primaryPath=akka://test/user/shardmanager-config32/leader-member-shard-default-config32, primaryVersion=13]
01:35:44,483 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config32: Sending AddServer message to peer akka://test/user/shardmanager-config32/leader-member-shard-default-config32 for shard member-1-shard-default-config32
01:35:44,483 PM [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
01:35:44,483 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config32: Local shard default already exists
01:35:44,484 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardInformation - Sending new DatastoreContext to member-1-shard-default-config32
01:35:44,484 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config32: onAddShardReplica: AddShardReplica[ShardName=default]
01:35:44,485 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config32: In findPrimary: org.opendaylight.controller.cluster.datastore.messages.FindPrimary [shardName=default, waitUntilReady=true]
01:35:44,485 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config32: Found primary for default: RemotePrimaryShardFound [primaryPath=akka://test/user/shardmanager-config32/leader-member-shard-default-config32, primaryVersion=13]
01:35:44,485 PM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - shard-manager-config32: Sending AddServer message to peer akka://test/user/shardmanager-config32/leader-member-shard-default-config32 for shard member-1-shard-default-config32
01:35:44,596 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config32: AddServer request to akka://test/user/shardmanager-config32/leader-member-shard-default-config32 for default failed
akka.pattern.AskTimeoutException: Ask timed out on [ActorSelection[Anchor(akka://test/), Path(/user/shardmanager-config32/leader-member-shard-default-config32)]] after [100 ms]. Message of type [org.opendaylight.controller.cluster.raft.messages.AddServer]. A typical reason for `AskTimeoutException` is that the recipient actor didn't send a reply.
01:35:44,597 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config32: findLocalShard : default
01:35:44,597 PM [main] [INFO] ShardManagerTest - testAddShardReplicaWithPreExistingReplicaInRemoteShardLeader ending
01:35:44,698 PM [main] [INFO] TestActorFactory - Killing actor TestActor[akka://test/user/shardmanager-config32]
01:35:44,709 PM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Stopping ShardManager shard-manager-config32
01:35:44,712 PM [main] [INFO] ShardManagerTest - testOnReceiveFindPrimaryForRemoteShard starting
01:35:44,721 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] Slf4jLogger - Slf4jLogger started
01:35:44,736 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] ArteryTransport - Remoting started with transport [Artery tcp]; listening on address [akka://cluster-test@127.0.0.1:2558] with UID [5522419374236501570]
01:35:44,736 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2558] - Starting up, Akka version [2.6.21] ...
01:35:44,741 PM [cluster-test-akka.actor.default-dispatcher-10] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2558] - Registered cluster JMX MBean [akka:type=Cluster]
01:35:44,741 PM [cluster-test-akka.actor.default-dispatcher-10] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2558] - Started up successfully
01:35:44,741 PM [cluster-test-akka.actor.default-dispatcher-10] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2558] - No downing-provider-class configured, manual cluster downing required, see https://doc.akka.io/docs/akka/current/typed/cluster.html#downing
01:35:44,741 PM [cluster-test-akka.actor.default-dispatcher-10] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2558] - No seed-nodes configured, manual cluster join required, see https://doc.akka.io/docs/akka/current/typed/cluster.html#joining
01:35:44,753 PM [cluster-test-akka.actor.default-dispatcher-10] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2558] - Node [akka://cluster-test@127.0.0.1:2558] is JOINING itself (with roles [member-1, dc-default], version [0.0.0]) and forming new cluster
01:35:44,753 PM [cluster-test-akka.actor.default-dispatcher-10] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2558] - is the new leader among reachable nodes (more leaders may exist)
01:35:44,753 PM [cluster-test-akka.actor.default-dispatcher-10] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2558] - Leader is moving node [akka://cluster-test@127.0.0.1:2558] to [Up]
01:35:44,753 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] ShardManager - Starting ShardManager shard-manager-config33
01:35:44,754 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] EmptyLocalActorRef - Message [org.opendaylight.controller.cluster.common.actor.Monitor] from TestActor[akka://cluster-test/user/shardmanager-config33] to Actor[akka://cluster-test/user/termination-monitor] was not delivered. [1] dead letters encountered. If this is not an expected behavior then Actor[akka://cluster-test/user/termination-monitor] may have terminated unexpectedly. This logging can be turned off or adjusted with configuration settings 'akka.log-dead-letters' and 'akka.log-dead-letters-during-shutdown'.
01:35:44,778 PM [cluster-test-akka.actor.default-dispatcher-6] [INFO] Slf4jLogger - Slf4jLogger started
01:35:44,789 PM [cluster-test-akka.actor.default-dispatcher-13] [INFO] ShardManager - Recovery complete : shard-manager-config33
01:35:44,790 PM [cluster-test-akka.actor.default-dispatcher-13] [DEBUG] ShardManager - shard-manager-config33: Creating local shard: member-1-shard-default-config33
01:35:44,790 PM [cluster-test-akka.actor.default-dispatcher-13] [INFO] ShardManager - shard-manager-config33: Received MemberUp: memberName: MemberName{name=member-1}, address: akka://cluster-test@127.0.0.1:2558
01:35:44,790 PM [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
01:35:44,801 PM [cluster-test-akka.actor.default-dispatcher-6] [INFO] ArteryTransport - Remoting started with transport [Artery tcp]; listening on address [akka://cluster-test@127.0.0.1:2559] with UID [5415267806106536533]
01:35:44,802 PM [cluster-test-akka.actor.default-dispatcher-6] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2559] - Starting up, Akka version [2.6.21] ...
01:35:44,804 PM [cluster-test-akka.actor.default-dispatcher-6] [WARN] Cluster - Could not register Cluster JMX MBean with name=akka:type=Cluster as it is already registered. If you are running multiple clusters in the same JVM, set 'akka.cluster.jmx.multi-mbeans-in-same-jvm = on' in config
01:35:44,804 PM [cluster-test-akka.actor.default-dispatcher-6] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2559] - Started up successfully
01:35:44,817 PM [cluster-test-akka.actor.default-dispatcher-6] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2559] - No downing-provider-class configured, manual cluster downing required, see https://doc.akka.io/docs/akka/current/typed/cluster.html#downing
01:35:44,817 PM [cluster-test-akka.actor.default-dispatcher-6] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2559] - No seed-nodes configured, manual cluster join required, see https://doc.akka.io/docs/akka/current/typed/cluster.html#joining
01:35:44,821 PM [cluster-test-akka.actor.default-dispatcher-11] [INFO] EmptyLocalActorRef - Message [org.opendaylight.controller.cluster.common.actor.Monitor] from TestActor[akka://cluster-test/user/shardmanager-config33] to Actor[akka://cluster-test/user/termination-monitor] was not delivered. [1] dead letters encountered. If this is not an expected behavior then Actor[akka://cluster-test/user/termination-monitor] may have terminated unexpectedly. This logging can be turned off or adjusted with configuration settings 'akka.log-dead-letters' and 'akka.log-dead-letters-during-shutdown'.
01:35:44,822 PM [cluster-test-akka.actor.default-dispatcher-6] [INFO] ShardManager - Starting ShardManager shard-manager-config33
01:35:44,833 PM [cluster-test-akka.actor.default-dispatcher-13] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1
01:35:44,833 PM [cluster-test-akka.actor.default-dispatcher-13] [DEBUG] ShardManager - Creating Shard member-1-shard-default-config33
01:35:44,833 PM [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
01:35:44,834 PM [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
01:35:44,834 PM [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#-170823341]
01:35:44,837 PM [cluster-test-akka.actor.default-dispatcher-13] [INFO] ShardManager - Recovery complete : shard-manager-config33
01:35:44,837 PM [cluster-test-akka.actor.default-dispatcher-13] [DEBUG] ShardManager - shard-manager-config33: Creating local shard: member-2-shard-default-config33
01:35:44,837 PM [cluster-test-akka.actor.default-dispatcher-13] [DEBUG] ShardManager - shard-manager-config33: Creating local shard: member-2-shard-astronauts-config33
01:35:44,838 PM [cluster-test-akka.actor.default-dispatcher-13] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1
01:35:44,838 PM [cluster-test-akka.actor.default-dispatcher-13] [DEBUG] ShardManager - Creating Shard member-2-shard-default-config33
01:35:44,838 PM [cluster-test-akka.actor.default-dispatcher-13] [DEBUG] ShardManager - Creating Shard member-2-shard-astronauts-config33
01:35:44,838 PM [cluster-test-akka.actor.default-dispatcher-13] [DEBUG] ShardManager - shard-manager-config33: Initializing shard [astronauts]
01:35:44,838 PM [cluster-test-akka.actor.default-dispatcher-13] [DEBUG] ShardInformation - Shard member-2-shard-astronauts-config33 is initialized
01:35:44,838 PM [cluster-test-akka.actor.default-dispatcher-13] [INFO] ShardManager - shard-manager-config33: Received LeaderStateChanged message: LeaderStateChanged [memberId=member-2-shard-astronauts-config33, leaderId=member-2-shard-astronauts-config33, leaderPayloadVersion=12]
01:35:44,838 PM [cluster-test-akka.actor.default-dispatcher-13] [INFO] ShardManager - shard-manager-config33: Received role changed for member-2-shard-astronauts-config33 from Candidate to Leader
01:35:44,872 PM [cluster-test-akka.actor.default-dispatcher-13] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2558] - Node [akka://cluster-test@127.0.0.1:2559] is JOINING, roles [member-2, dc-default], version [0.0.0]
01:35:44,877 PM [cluster-test-akka.actor.default-dispatcher-14] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2559] - Welcome from [akka://cluster-test@127.0.0.1:2558]
01:35:44,879 PM [cluster-test-akka.actor.default-dispatcher-14] [INFO] ShardManager - shard-manager-config33: Received MemberUp: memberName: MemberName{name=member-1}, address: akka://cluster-test@127.0.0.1:2558
01:35:44,879 PM [cluster-test-akka.actor.default-dispatcher-14] [INFO] ShardInformation - updatePeerAddress for peer member-1-shard-default-config33 with address akka://cluster-test@127.0.0.1:2558/user/shardmanager-config33/member-1-shard-default-config33
01:35:44,879 PM [cluster-test-akka.actor.default-dispatcher-14] [DEBUG] ShardInformation - Sending PeerAddressResolved for peer member-1-shard-default-config33 with address akka://cluster-test@127.0.0.1:2558/user/shardmanager-config33/member-1-shard-default-config33 to akka://cluster-test/user/member-2-shard-astronauts-config
01:35:44,879 PM [cluster-test-akka.actor.default-dispatcher-14] [INFO] ShardInformation - updatePeerAddress for peer member-1-shard-astronauts-config33 with address akka://cluster-test@127.0.0.1:2558/user/shardmanager-config33/member-1-shard-astronauts-config33
01:35:44,879 PM [cluster-test-akka.actor.default-dispatcher-14] [DEBUG] ShardInformation - Sending PeerAddressResolved for peer member-1-shard-astronauts-config33 with address akka://cluster-test@127.0.0.1:2558/user/shardmanager-config33/member-1-shard-astronauts-config33 to akka://cluster-test/user/member-2-shard-astronauts-config
01:35:45,758 PM [cluster-test-akka.actor.default-dispatcher-13] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2558] - Leader is moving node [akka://cluster-test@127.0.0.1:2559] to [Up]
01:35:45,759 PM [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
01:35:45,759 PM [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
01:35:45,759 PM [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
01:35:45,760 PM [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]
01:35:45,760 PM [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]
01:35:45,767 PM [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]
01:35:45,767 PM [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#133166962, primaryVersion=12]
01:35:45,769 PM [main] [INFO] ShardManagerTest - testOnReceiveFindPrimaryForRemoteShard ending
01:35:45,843 PM [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
01:35:45,843 PM [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
01:35:45,843 PM [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
01:35:45,843 PM [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
01:35:45,843 PM [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
01:35:45,872 PM [cluster-test-akka.actor.default-dispatcher-10] [INFO] ShardManager - Stopping ShardManager shard-manager-config33
01:35:45,873 PM [cluster-test-akka.actor.default-dispatcher-10] [INFO] RemoteActorRefProvider$RemotingTerminator - Shutting down remote daemon.
01:35:45,873 PM [cluster-test-akka.actor.default-dispatcher-10] [INFO] RemoteActorRefProvider$RemotingTerminator - Remote daemon shut down; proceeding with flushing remote transports.
01:35:45,888 PM [cluster-test-akka.actor.default-dispatcher-10] [WARN] Materializer - [outbound connection to [akka://cluster-test@127.0.0.1:2559], message stream] Upstream failed, cause: StreamTcpException: The connection has been aborted
01:35:45,888 PM [cluster-test-akka.actor.default-dispatcher-10] [WARN] Materializer - [outbound connection to [akka://cluster-test@127.0.0.1:2559], control stream] Upstream failed, cause: StreamTcpException: The connection has been aborted
01:35:45,911 PM [cluster-test-akka.actor.default-dispatcher-14] [INFO] ShardManager - Stopping ShardManager shard-manager-config33
01:35:45,913 PM [cluster-test-akka.actor.default-dispatcher-10] [INFO] RemoteActorRefProvider$RemotingTerminator - Shutting down remote daemon.
01:35:45,913 PM [cluster-test-akka.actor.default-dispatcher-10] [INFO] RemoteActorRefProvider$RemotingTerminator - Remote daemon shut down; proceeding with flushing remote transports.
01:35:46,941 PM [cluster-test-akka.actor.default-dispatcher-14] [INFO] RemoteActorRefProvider$RemotingTerminator - Remoting shut down.
[WARN] [03/11/2024 13:35:46.943] [cluster-test-akka.actor.internal-dispatcher-3] [Cluster(akka://cluster-test)] Could not unregister Cluster JMX MBean with name=akka:type=Cluster as it was not found. If you are running multiple clusters in the same JVM, set 'akka.cluster.jmx.multi-mbeans-in-same-jvm = on' in config
01:35:46,969 PM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Starting ShardManager shard-manager-config34
01:35:46,970 PM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Recovery complete : shard-manager-config34
01:35:46,971 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config34: Creating local shard: member-1-shard-default-config34
01:35:46,979 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config34: findLocalShard : default
01:35:46,979 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config34: Returning NotInitializedException for shard default
01:35:47,81 PM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/$r#1525934023]
01:35:47,91 PM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - Stopping ShardManager shard-manager-config34
01:35:47,97 PM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - Starting ShardManager shard-manager-config35
01:35:47,98 PM [test-akka.actor.default-dispatcher-5] [INFO] ShardManager - Recovery complete : shard-manager-config35
01:35:47,98 PM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - shard-manager-config35: Creating local shard: member-1-shard-default-config35
01:35:47,106 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1
01:35:47,106 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - Creating Shard member-1-shard-default-config35
01:35:47,106 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config35: Initializing shard [default]
01:35:47,106 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardInformation - Shard member-1-shard-default-config35 is initialized
01:35:47,106 PM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - shard-manager-config35: Received LeaderStateChanged message: LeaderStateChanged [memberId=member-1-shard-default-config35, leaderId=member-1-shard-default-config35, leaderPayloadVersion=13]
01:35:47,106 PM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - shard-manager-config35: Received role changed for member-1-shard-default-config35 from Candidate to Leader
01:35:47,106 PM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - shard-manager-config35: All Shards are ready - data store config35 is ready
01:35:47,106 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config35: onChangeShardServersVotingStatus: ChangeShardMembersVotingStatus [shardName=default, meberVotingStatusMap={member-2=true}]
01:35:47,106 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config35: findLocalShard : default
01:35:47,107 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config35: Sending ChangeServersVotingStatus message ChangeServersVotingStatus [serverVotingStatusMap={member-2-shard-default-config35=true}, serversVisited=[]] to local shard akka://test/user/member-1-shard-default-config35
01:35:47,107 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config35: Received ServerChangeReply{status=OK} from local shard akka://test/user/member-1-shard-default-config35
01:35:47,107 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config35: ChangeServersVotingStatus succeeded for shard default
01:35:47,258 PM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/member-1-shard-default-config35#-1634314409]
01:35:47,271 PM [main] [INFO] ShardManagerTest - testShutDown starting
01:35:47,279 PM [test-akka.actor.default-dispatcher-14] [INFO] ShardManager - Starting ShardManager shard-manager-config36
01:35:47,281 PM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - Recovery complete : shard-manager-config36
01:35:47,281 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config36: Creating local shard: member-1-shard-shard2-config36
01:35:47,282 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config36: Creating local shard: member-1-shard-shard1-config36
01:35:47,289 PM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1
01:35:47,289 PM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - Creating Shard member-1-shard-shard2-config36
01:35:47,289 PM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - Creating Shard member-1-shard-shard1-config36
01:35:47,289 PM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - shard-manager-config36: Initializing shard [shard1]
01:35:47,289 PM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardInformation - Shard member-1-shard-shard1-config36 is initialized
01:35:47,289 PM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - shard-manager-config36: Initializing shard [shard2]
01:35:47,289 PM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardInformation - Shard member-1-shard-shard2-config36 is initialized
01:35:47,289 PM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - shard-manager-config36: Issuing gracefulStop to shard member-1-shard-shard2-config36
01:35:47,289 PM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - shard-manager-config36: Issuing gracefulStop to shard member-1-shard-shard1-config36
01:35:47,289 PM [test-akka.actor.default-dispatcher-14] [INFO] ShardManager - Shutting down ShardManager shard-manager-config36 - waiting on 2 shards
01:35:47,840 PM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/member-1-shard-shard1-config36#-690634776]
01:35:47,841 PM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/member-1-shard-shard2-config36#-1192305315]
01:35:47,841 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config36: All shards shutdown - sending PoisonPill to self
01:35:47,841 PM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Stopping ShardManager shard-manager-config36
01:35:47,842 PM [main] [INFO] ShardManagerTest - testShutDown ending
01:35:47,943 PM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/$t#900824019]
01:35:47,956 PM [main] [INFO] ShardManagerTest - testOnReceiveFindPrimaryForNonLocalLeaderShardBeforeMemberUp starting
01:35:47,959 PM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Starting ShardManager shard-manager-config37
01:35:47,960 PM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - Recovery complete : shard-manager-config37
01:35:47,961 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config37: Creating local shard: member-1-shard-default-config37
01:35:47,970 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1
01:35:47,970 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - Creating Shard member-1-shard-default-config37
01:35:47,970 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config37: Initializing shard [default]
01:35:47,970 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardInformation - Shard member-1-shard-default-config37 is initialized
01:35:47,970 PM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - shard-manager-config37: Received role changed for member-1-shard-default-config37 from Candidate to Follower
01:35:47,970 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManagerTest$TestShardManager - Received unhandled message LeaderStateChanged [memberId=member-1-shard-default-config37, leaderId=member-2-shard-default-config37, leaderPayloadVersion=13]
01:35:47,971 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config37: In findPrimary: org.opendaylight.controller.cluster.datastore.messages.FindPrimary [shardName=default, waitUntilReady=false]
01:35:47,971 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config37: Returning NoShardLeaderException for shard default
01:35:47,972 PM [main] [INFO] ShardManagerTest - testOnReceiveFindPrimaryForNonLocalLeaderShardBeforeMemberUp ending
01:35:48,73 PM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/$u#-431911153]
01:35:48,84 PM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Stopping ShardManager shard-manager-config37
01:35:48,87 PM [main] [INFO] ShardManagerTest - testOnReceiveFindPrimaryWaitForReadyWithNoRoleShard starting
01:35:48,93 PM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - Starting ShardManager shard-manager-config38
01:35:48,95 PM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Recovery complete : shard-manager-config38
01:35:48,95 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config38: Creating local shard: member-1-shard-default-config38
01:35:48,104 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1
01:35:48,104 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - Creating Shard member-1-shard-default-config38
01:35:48,104 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config38: Initializing shard [default]
01:35:48,104 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardInformation - Shard member-1-shard-default-config38 is initialized
01:35:48,104 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config38: In findPrimary: org.opendaylight.controller.cluster.datastore.messages.FindPrimary [shardName=default, waitUntilReady=true]
01:35:48,104 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config38: Scheduling 1200 ms timer to wait for shard ShardInformation [shardId=member-1-shard-default-config38, leaderAvailable=false, actorInitialized=true, followerSyncStatus=false, role=null, leaderId=null, activeMember=true]
01:35:49,317 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config38: Received ShardNotInitializedTimeout message for shard default
01:35:49,317 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config38: Returning NoShardLeaderException for shard default
01:35:49,318 PM [main] [INFO] ShardManagerTest - testOnReceiveFindPrimaryWaitForReadyWithNoRoleShard ending
01:35:49,419 PM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/$v#1394146168]
01:35:49,430 PM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - Stopping ShardManager shard-manager-config38
01:35:49,432 PM [main] [INFO] ShardManagerTest - testShardPersistenceWithRestoredData starting
01:35:49,435 PM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Starting ShardManager shard-manager-config39
01:35:49,437 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config39: onSnapshotOffer: ShardManagerSnapshot [ShardList = [default, astronauts] ]
01:35:49,437 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config39: adding shard astronauts
01:35:49,437 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config39: removing shard people
01:35:49,440 PM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - Recovery complete : shard-manager-config39
01:35:49,440 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config39: Creating local shard: member-1-shard-default-config39
01:35:49,440 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config39: Creating local shard: member-1-shard-astronauts-config39
01:35:49,450 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config39: findLocalShard : people
01:35:49,450 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config39: Local shard people not found - shards present: [default, astronauts]
01:35:49,451 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config39: findLocalShard : default
01:35:49,451 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config39: Returning NotInitializedException for shard default
01:35:49,451 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config39: findLocalShard : astronauts
01:35:49,451 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config39: Returning NotInitializedException for shard astronauts
01:35:49,451 PM [main] [INFO] ShardManagerTest - testShardPersistenceWithRestoredData ending
01:35:49,552 PM [main] [INFO] TestActorFactory - Killing actor TestActor[akka://test/user/$$j]
01:35:49,563 PM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Stopping ShardManager shard-manager-config39
01:35:49,566 PM [main] [INFO] ShardManagerTest - testOnReceiveFindPrimaryForNonLocalLeaderShard starting
01:35:49,569 PM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Starting ShardManager shard-manager-config40
01:35:49,570 PM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - Recovery complete : shard-manager-config40
01:35:49,570 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config40: Creating local shard: member-1-shard-default-config40
01:35:49,579 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1
01:35:49,579 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - Creating Shard member-1-shard-default-config40
01:35:49,579 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config40: Initializing shard [default]
01:35:49,579 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardInformation - Shard member-1-shard-default-config40 is initialized
01:35:49,579 PM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - shard-manager-config40: Received MemberUp: memberName: MemberName{name=member-2}, address: akka://test
01:35:49,579 PM [test-akka.actor.default-dispatcher-10] [INFO] ShardInformation - updatePeerAddress for peer member-2-shard-default-config40 with address akka://test/user/shardmanager-config40/member-2-shard-default-config40
01:35:49,579 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardInformation - Sending PeerAddressResolved for peer member-2-shard-default-config40 with address akka://test/user/shardmanager-config40/member-2-shard-default-config40 to akka://test/user/member-1-shard-default-config
01:35:49,579 PM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - shard-manager-config40: Received role changed for member-1-shard-default-config40 from Candidate to Follower
01:35:49,579 PM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - shard-manager-config40: Received LeaderStateChanged message: LeaderStateChanged [memberId=member-1-shard-default-config40, leaderId=member-2-shard-default-config40, leaderPayloadVersion=12]
01:35:49,579 PM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - shard-manager-config40: All Shards are ready - data store config40 is ready
01:35:49,580 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config40: In findPrimary: org.opendaylight.controller.cluster.datastore.messages.FindPrimary [shardName=default, waitUntilReady=false]
01:35:49,580 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config40: Found primary for default: RemotePrimaryShardFound [primaryPath=akka://test/user/shardmanager-config40/member-2-shard-default-config40, primaryVersion=12]
01:35:49,580 PM [main] [INFO] ShardManagerTest - testOnReceiveFindPrimaryForNonLocalLeaderShard ending
01:35:49,681 PM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/$w#-437425017]
01:35:49,692 PM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - Stopping ShardManager shard-manager-config40
01:35:49,694 PM [main] [INFO] ShardManagerTest - testShardAvailabilityOnChangeOfMemberReachability starting
01:35:49,701 PM [cluster-test-akka.actor.default-dispatcher-6] [INFO] Slf4jLogger - Slf4jLogger started
01:35:49,711 PM [cluster-test-akka.actor.default-dispatcher-6] [INFO] ArteryTransport - Remoting started with transport [Artery tcp]; listening on address [akka://cluster-test@127.0.0.1:2558] with UID [7432888466234480210]
01:35:49,711 PM [cluster-test-akka.actor.default-dispatcher-6] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2558] - Starting up, Akka version [2.6.21] ...
01:35:49,714 PM [cluster-test-akka.actor.default-dispatcher-6] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2558] - Registered cluster JMX MBean [akka:type=Cluster]
01:35:49,714 PM [cluster-test-akka.actor.default-dispatcher-6] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2558] - Started up successfully
01:35:49,716 PM [cluster-test-akka.actor.default-dispatcher-10] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2558] - No downing-provider-class configured, manual cluster downing required, see https://doc.akka.io/docs/akka/current/typed/cluster.html#downing
01:35:49,716 PM [cluster-test-akka.actor.default-dispatcher-10] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2558] - No seed-nodes configured, manual cluster join required, see https://doc.akka.io/docs/akka/current/typed/cluster.html#joining
01:35:49,730 PM [cluster-test-akka.actor.default-dispatcher-10] [INFO] EmptyLocalActorRef - Message [org.opendaylight.controller.cluster.common.actor.Monitor] from TestActor[akka://cluster-test/user/shardmanager-config41] to Actor[akka://cluster-test/user/termination-monitor] was not delivered. [1] dead letters encountered. If this is not an expected behavior then Actor[akka://cluster-test/user/termination-monitor] may have terminated unexpectedly. This logging can be turned off or adjusted with configuration settings 'akka.log-dead-letters' and 'akka.log-dead-letters-during-shutdown'.
01:35:49,733 PM [cluster-test-akka.actor.default-dispatcher-6] [INFO] ShardManager - Starting ShardManager shard-manager-config41
01:35:49,734 PM [cluster-test-akka.actor.default-dispatcher-6] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2558] - Node [akka://cluster-test@127.0.0.1:2558] is JOINING itself (with roles [member-1, dc-default], version [0.0.0]) and forming new cluster
01:35:49,735 PM [cluster-test-akka.actor.default-dispatcher-6] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2558] - is the new leader among reachable nodes (more leaders may exist)
01:35:49,735 PM [cluster-test-akka.actor.default-dispatcher-6] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2558] - Leader is moving node [akka://cluster-test@127.0.0.1:2558] to [Up]
01:35:49,739 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] Slf4jLogger - Slf4jLogger started
01:35:49,751 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] ArteryTransport - Remoting started with transport [Artery tcp]; listening on address [akka://cluster-test@127.0.0.1:2559] with UID [-7455654884683340949]
01:35:49,751 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2559] - Starting up, Akka version [2.6.21] ...
01:35:49,759 PM [cluster-test-akka.actor.default-dispatcher-5] [WARN] Cluster - Could not register Cluster JMX MBean with name=akka:type=Cluster as it is already registered. If you are running multiple clusters in the same JVM, set 'akka.cluster.jmx.multi-mbeans-in-same-jvm = on' in config
01:35:49,759 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2559] - Started up successfully
01:35:49,759 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2559] - No downing-provider-class configured, manual cluster downing required, see https://doc.akka.io/docs/akka/current/typed/cluster.html#downing
01:35:49,759 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2559] - No seed-nodes configured, manual cluster join required, see https://doc.akka.io/docs/akka/current/typed/cluster.html#joining
01:35:49,774 PM [cluster-test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Recovery complete : shard-manager-config41
01:35:49,774 PM [cluster-test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config41: Creating local shard: member-1-shard-default-config41
01:35:49,775 PM [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
01:35:49,775 PM [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
01:35:49,781 PM [cluster-test-akka.actor.default-dispatcher-11] [INFO] EmptyLocalActorRef - Message [org.opendaylight.controller.cluster.common.actor.Monitor] from TestActor[akka://cluster-test/user/shardmanager-config41] to Actor[akka://cluster-test/user/termination-monitor] was not delivered. [1] dead letters encountered. If this is not an expected behavior then Actor[akka://cluster-test/user/termination-monitor] may have terminated unexpectedly. This logging can be turned off or adjusted with configuration settings 'akka.log-dead-letters' and 'akka.log-dead-letters-during-shutdown'.
01:35:49,787 PM [cluster-test-akka.actor.default-dispatcher-10] [INFO] ShardManager - Starting ShardManager shard-manager-config41
01:35:49,791 PM [cluster-test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1
01:35:49,791 PM [cluster-test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - Creating Shard member-1-shard-default-config41
01:35:49,791 PM [cluster-test-akka.actor.default-dispatcher-14] [INFO] ShardInformation - updatePeerAddress for peer member-1-shard-default-config41 with address akka://cluster-test@127.0.0.1:2558/user/shardmanager-config41/member-1-shard-default-config41
01:35:49,791 PM [cluster-test-akka.actor.default-dispatcher-14] [DEBUG] ShardInformation - Sending PeerAddressResolved for peer member-1-shard-default-config41 with address akka://cluster-test@127.0.0.1:2558/user/shardmanager-config41/member-1-shard-default-config41 to akka://cluster-test/user/member-1-shard-default-config
01:35:49,791 PM [cluster-test-akka.actor.default-dispatcher-14] [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#-386901925]
01:35:49,791 PM [cluster-test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - shard-manager-config41: Initializing shard [default]
01:35:49,791 PM [cluster-test-akka.actor.default-dispatcher-14] [DEBUG] ShardInformation - Shard member-1-shard-default-config41 is initialized
01:35:49,791 PM [cluster-test-akka.actor.default-dispatcher-14] [INFO] ShardManager - shard-manager-config41: Received LeaderStateChanged message: LeaderStateChanged [memberId=member-1-shard-default-config41, leaderId=member-2-shard-default-config41, leaderPayloadVersion=13]
01:35:49,791 PM [cluster-test-akka.actor.default-dispatcher-14] [INFO] ShardManager - shard-manager-config41: Received role changed for member-1-shard-default-config41 from Candidate to Follower
01:35:49,796 PM [cluster-test-akka.actor.default-dispatcher-10] [INFO] ShardManager - Recovery complete : shard-manager-config41
01:35:49,796 PM [cluster-test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config41: Creating local shard: member-2-shard-default-config41
01:35:49,797 PM [cluster-test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1
01:35:49,797 PM [cluster-test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - Creating Shard member-2-shard-default-config41
01:35:49,797 PM [cluster-test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config41: Initializing shard [default]
01:35:49,797 PM [cluster-test-akka.actor.default-dispatcher-10] [DEBUG] ShardInformation - Shard member-2-shard-default-config41 is initialized
01:35:49,797 PM [cluster-test-akka.actor.default-dispatcher-10] [INFO] ShardManager - shard-manager-config41: Received LeaderStateChanged message: LeaderStateChanged [memberId=member-2-shard-default-config41, leaderId=member-2-shard-default-config41, leaderPayloadVersion=13]
01:35:49,797 PM [cluster-test-akka.actor.default-dispatcher-10] [INFO] ShardManager - shard-manager-config41: Received role changed for member-2-shard-default-config41 from Candidate to Leader
01:35:49,797 PM [cluster-test-akka.actor.default-dispatcher-10] [INFO] ShardManager - shard-manager-config41: All Shards are ready - data store config41 is ready
01:35:49,842 PM [cluster-test-akka.actor.default-dispatcher-11] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2558] - Node [akka://cluster-test@127.0.0.1:2559] is JOINING, roles [member-2, dc-default], version [0.0.0]
01:35:49,848 PM [cluster-test-akka.actor.default-dispatcher-14] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2559] - Welcome from [akka://cluster-test@127.0.0.1:2558]
01:35:49,848 PM [cluster-test-akka.actor.default-dispatcher-14] [INFO] ShardManager - shard-manager-config41: Received MemberUp: memberName: MemberName{name=member-1}, address: akka://cluster-test@127.0.0.1:2558
01:35:49,848 PM [cluster-test-akka.actor.default-dispatcher-14] [INFO] ShardInformation - updatePeerAddress for peer member-1-shard-default-config41 with address akka://cluster-test@127.0.0.1:2558/user/shardmanager-config41/member-1-shard-default-config41
01:35:49,849 PM [cluster-test-akka.actor.default-dispatcher-14] [DEBUG] ShardInformation - Sending PeerAddressResolved for peer member-1-shard-default-config41 with address akka://cluster-test@127.0.0.1:2558/user/shardmanager-config41/member-1-shard-default-config41 to akka://cluster-test/user/member-2-shard-default-config
01:35:49,849 PM [cluster-test-akka.actor.default-dispatcher-14] [INFO] ShardManager - shard-manager-config41: All Shards are ready - data store config41 is ready
01:35:50,730 PM [cluster-test-akka.actor.default-dispatcher-11] [INFO] ShardManager - shard-manager-config41: Received MemberUp: memberName: MemberName{name=member-2}, address: akka://cluster-test@127.0.0.1:2559
01:35:50,731 PM [cluster-test-akka.actor.default-dispatcher-11] [INFO] ShardInformation - updatePeerAddress for peer member-2-shard-default-config41 with address akka://cluster-test@127.0.0.1:2559/user/shardmanager-config41/member-2-shard-default-config41
01:35:50,731 PM [cluster-test-akka.actor.default-dispatcher-11] [DEBUG] ShardInformation - Sending PeerAddressResolved for peer member-2-shard-default-config41 with address akka://cluster-test@127.0.0.1:2559/user/shardmanager-config41/member-2-shard-default-config41 to akka://cluster-test/user/member-1-shard-default-config
01:35:50,731 PM [cluster-test-akka.actor.default-dispatcher-11] [INFO] ShardManager - shard-manager-config41: All Shards are ready - data store config41 is ready
01:35:50,731 PM [cluster-test-akka.actor.default-dispatcher-6] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2558] - Leader is moving node [akka://cluster-test@127.0.0.1:2559] to [Up]
01:35:50,733 PM [cluster-test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - shard-manager-config41: In findPrimary: org.opendaylight.controller.cluster.datastore.messages.FindPrimary [shardName=default, waitUntilReady=true]
01:35:50,733 PM [cluster-test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - shard-manager-config41: Found primary for default: RemotePrimaryShardFound [primaryPath=akka://cluster-test@127.0.0.1:2559/user/shardmanager-config41/member-2-shard-default-config41, primaryVersion=13]
01:35:50,734 PM [cluster-test-akka.actor.default-dispatcher-14] [INFO] ShardManager - Received UnreachableMember: memberName MemberName{name=member-2}, address: akka://cluster-test@127.0.0.1:2558
01:35:50,734 PM [cluster-test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - Marking Leader member-2-shard-default-config41 as unavailable.
01:35:50,736 PM [cluster-test-akka.actor.default-dispatcher-14] [INFO] ShardManager - shard-manager-config41: Received MemberRemoved: memberName: MemberName{name=member-2}, address: akka://cluster-test@127.0.0.1:2558
01:35:50,736 PM [cluster-test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - shard-manager-config41: In findPrimary: org.opendaylight.controller.cluster.datastore.messages.FindPrimary [shardName=default, waitUntilReady=true]
01:35:50,736 PM [cluster-test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - shard-manager-config41: Scheduling 1200 ms timer to wait for shard ShardInformation [shardId=member-1-shard-default-config41, leaderAvailable=false, actorInitialized=true, followerSyncStatus=false, role=Follower, leaderId=member-2-shard-default-config41, activeMember=true]
01:35:50,779 PM [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
01:35:50,779 PM [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
01:35:50,779 PM [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
01:35:50,779 PM [cluster-test-akka.actor.default-dispatcher-10] [INFO] ShardManager - shard-manager-config41: All Shards are ready - data store config41 is ready
01:35:51,949 PM [cluster-test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - shard-manager-config41: Received ShardNotInitializedTimeout message for shard default
01:35:51,949 PM [cluster-test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - shard-manager-config41: Returning NoShardLeaderException for shard default
01:35:51,949 PM [cluster-test-akka.actor.default-dispatcher-14] [INFO] ShardManager - Received ReachableMember: memberName MemberName{name=member-2}, address: akka://cluster-test@127.0.0.1:2558
01:35:51,949 PM [cluster-test-akka.actor.default-dispatcher-14] [INFO] ShardInformation - updatePeerAddress for peer member-2-shard-default-config41 with address akka://cluster-test@127.0.0.1:2558/user/shardmanager-config41/member-2-shard-default-config41
01:35:51,949 PM [cluster-test-akka.actor.default-dispatcher-14] [DEBUG] ShardInformation - Sending PeerAddressResolved for peer member-2-shard-default-config41 with address akka://cluster-test@127.0.0.1:2558/user/shardmanager-config41/member-2-shard-default-config41 to akka://cluster-test/user/member-1-shard-default-config
01:35:51,950 PM [cluster-test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - Marking Leader member-2-shard-default-config41 as available.
01:35:51,950 PM [cluster-test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - shard-manager-config41: In findPrimary: org.opendaylight.controller.cluster.datastore.messages.FindPrimary [shardName=default, waitUntilReady=true]
01:35:51,950 PM [cluster-test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - shard-manager-config41: Found primary for default: RemotePrimaryShardFound [primaryPath=akka://cluster-test@127.0.0.1:2558/user/shardmanager-config41/member-2-shard-default-config41, primaryVersion=13]
01:35:51,950 PM [cluster-test-akka.actor.default-dispatcher-14] [INFO] ShardManager - shard-manager-config41: Received MemberUp: memberName: MemberName{name=member-2}, address: akka://cluster-test@127.0.0.1:2558
01:35:51,950 PM [cluster-test-akka.actor.default-dispatcher-14] [INFO] ShardInformation - updatePeerAddress for peer member-2-shard-default-config41 with address akka://cluster-test@127.0.0.1:2558/user/shardmanager-config41/member-2-shard-default-config41
01:35:51,950 PM [cluster-test-akka.actor.default-dispatcher-14] [DEBUG] ShardInformation - Sending PeerAddressResolved for peer member-2-shard-default-config41 with address akka://cluster-test@127.0.0.1:2558/user/shardmanager-config41/member-2-shard-default-config41 to akka://cluster-test/user/member-1-shard-default-config
01:35:51,950 PM [cluster-test-akka.actor.default-dispatcher-14] [INFO] ShardManager - shard-manager-config41: All Shards are ready - data store config41 is ready
01:35:51,950 PM [cluster-test-akka.actor.default-dispatcher-14] [INFO] ShardManager - Received UnreachableMember: memberName MemberName{name=member-2}, address: akka://cluster-test@127.0.0.1:2558
01:35:51,950 PM [cluster-test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - Marking Leader member-2-shard-default-config41 as unavailable.
01:35:51,950 PM [cluster-test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - shard-manager-config41: In findPrimary: org.opendaylight.controller.cluster.datastore.messages.FindPrimary [shardName=default, waitUntilReady=true]
01:35:51,950 PM [cluster-test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - shard-manager-config41: Scheduling 1200 ms timer to wait for shard ShardInformation [shardId=member-1-shard-default-config41, leaderAvailable=false, actorInitialized=true, followerSyncStatus=false, role=Follower, leaderId=member-2-shard-default-config41, activeMember=true]
01:35:51,951 PM [cluster-test-akka.actor.default-dispatcher-14] [INFO] ShardManager - Received ReachableMember: memberName MemberName{name=member-2}, address: akka://cluster-test@127.0.0.1:2558
01:35:51,951 PM [cluster-test-akka.actor.default-dispatcher-14] [INFO] ShardInformation - updatePeerAddress for peer member-2-shard-default-config41 with address akka://cluster-test@127.0.0.1:2558/user/shardmanager-config41/member-2-shard-default-config41
01:35:51,951 PM [cluster-test-akka.actor.default-dispatcher-14] [DEBUG] ShardInformation - Sending PeerAddressResolved for peer member-2-shard-default-config41 with address akka://cluster-test@127.0.0.1:2558/user/shardmanager-config41/member-2-shard-default-config41 to akka://cluster-test/user/member-1-shard-default-config
01:35:51,951 PM [cluster-test-akka.actor.default-dispatcher-14] [DEBUG] ShardInformation - Shard member-1-shard-default-config41 is initialized - notifying 1 OnShardInitialized callbacks
01:35:51,951 PM [cluster-test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - Marking Leader member-2-shard-default-config41 as available.
01:35:51,951 PM [cluster-test-akka.actor.default-dispatcher-14] [DEBUG] ShardInformation - Shard member-1-shard-default-config41 is ready - notifying 1 OnShardInitialized callbacks
01:35:51,951 PM [cluster-test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - shard-manager-config41: Found primary for default: RemotePrimaryShardFound [primaryPath=akka://cluster-test@127.0.0.1:2558/user/shardmanager-config41/member-2-shard-default-config41, primaryVersion=13]
01:35:51,951 PM [main] [INFO] ShardManagerTest - testShardAvailabilityOnChangeOfMemberReachability ending
01:35:52,53 PM [cluster-test-akka.actor.default-dispatcher-6] [INFO] ShardManager - Stopping ShardManager shard-manager-config41
01:35:52,54 PM [cluster-test-akka.actor.default-dispatcher-11] [INFO] RemoteActorRefProvider$RemotingTerminator - Shutting down remote daemon.
01:35:52,54 PM [cluster-test-akka.actor.default-dispatcher-11] [INFO] RemoteActorRefProvider$RemotingTerminator - Remote daemon shut down; proceeding with flushing remote transports.
01:35:52,64 PM [cluster-test-akka.actor.default-dispatcher-11] [WARN] Materializer - [outbound connection to [akka://cluster-test@127.0.0.1:2559], message stream] Upstream failed, cause: StreamTcpException: The connection has been aborted
01:35:52,64 PM [cluster-test-akka.actor.default-dispatcher-11] [WARN] Materializer - [outbound connection to [akka://cluster-test@127.0.0.1:2559], control stream] Upstream failed, cause: StreamTcpException: The connection has been aborted
01:35:52,68 PM [cluster-test-akka.actor.default-dispatcher-11] [INFO] RemoteActorRefProvider$RemotingTerminator - Remoting shut down.
01:35:52,81 PM [cluster-test-akka.actor.default-dispatcher-13] [INFO] ShardManager - Stopping ShardManager shard-manager-config41
01:35:52,81 PM [cluster-test-akka.actor.default-dispatcher-10] [INFO] RemoteActorRefProvider$RemotingTerminator - Shutting down remote daemon.
01:35:52,82 PM [cluster-test-akka.actor.default-dispatcher-10] [INFO] RemoteActorRefProvider$RemotingTerminator - Remote daemon shut down; proceeding with flushing remote transports.
01:35:53,105 PM [cluster-test-akka.actor.default-dispatcher-10] [INFO] RemoteActorRefProvider$RemotingTerminator - Remoting shut down.
[WARN] [03/11/2024 13:35:53.108] [cluster-test-akka.actor.internal-dispatcher-3] [Cluster(akka://cluster-test)] Could not unregister Cluster JMX MBean with name=akka:type=Cluster as it was not found. If you are running multiple clusters in the same JVM, set 'akka.cluster.jmx.multi-mbeans-in-same-jvm = on' in config
01:35:53,129 PM [main] [INFO] ShardManagerTest - testAddShardReplica starting
01:35:53,137 PM [cluster-test-akka.actor.default-dispatcher-6] [INFO] Slf4jLogger - Slf4jLogger started
01:35:53,146 PM [cluster-test-akka.actor.default-dispatcher-6] [INFO] ArteryTransport - Remoting started with transport [Artery tcp]; listening on address [akka://cluster-test@127.0.0.1:2558] with UID [-5034707862182736924]
01:35:53,146 PM [cluster-test-akka.actor.default-dispatcher-6] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2558] - Starting up, Akka version [2.6.21] ...
01:35:53,148 PM [cluster-test-akka.actor.default-dispatcher-6] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2558] - Registered cluster JMX MBean [akka:type=Cluster]
01:35:53,148 PM [cluster-test-akka.actor.default-dispatcher-6] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2558] - Started up successfully
01:35:53,149 PM [cluster-test-akka.actor.default-dispatcher-6] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2558] - No downing-provider-class configured, manual cluster downing required, see https://doc.akka.io/docs/akka/current/typed/cluster.html#downing
01:35:53,149 PM [cluster-test-akka.actor.default-dispatcher-6] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2558] - No seed-nodes configured, manual cluster join required, see https://doc.akka.io/docs/akka/current/typed/cluster.html#joining
01:35:53,161 PM [cluster-test-akka.actor.default-dispatcher-10] [INFO] ShardManager - Starting ShardManager shardmanager-config42
01:35:53,161 PM [cluster-test-akka.actor.default-dispatcher-10] [INFO] EmptyLocalActorRef - Message [org.opendaylight.controller.cluster.common.actor.Monitor] from TestActor[akka://cluster-test/user/shardmanager-config42] to Actor[akka://cluster-test/user/termination-monitor] was not delivered. [1] dead letters encountered. If this is not an expected behavior then Actor[akka://cluster-test/user/termination-monitor] may have terminated unexpectedly. This logging can be turned off or adjusted with configuration settings 'akka.log-dead-letters' and 'akka.log-dead-letters-during-shutdown'.
01:35:53,163 PM [cluster-test-akka.actor.default-dispatcher-6] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2558] - Node [akka://cluster-test@127.0.0.1:2558] is JOINING itself (with roles [member-1, dc-default], version [0.0.0]) and forming new cluster
01:35:53,163 PM [cluster-test-akka.actor.default-dispatcher-6] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2558] - is the new leader among reachable nodes (more leaders may exist)
01:35:53,163 PM [cluster-test-akka.actor.default-dispatcher-6] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2558] - Leader is moving node [akka://cluster-test@127.0.0.1:2558] to [Up]
01:35:53,167 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] Slf4jLogger - Slf4jLogger started
01:35:53,169 PM [cluster-test-akka.actor.default-dispatcher-14] [INFO] ShardManager - Recovery complete : shardmanager-config42
01:35:53,169 PM [cluster-test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - shardmanager-config42: Creating local shard: member-1-shard-default-config42
01:35:53,176 PM [cluster-test-akka.actor.default-dispatcher-10] [INFO] ShardManager - shardmanager-config42: Received MemberUp: memberName: MemberName{name=member-1}, address: akka://cluster-test@127.0.0.1:2558
01:35:53,176 PM [cluster-test-akka.actor.default-dispatcher-10] [INFO] ShardInformation - updatePeerAddress for peer member-1-shard-default-config42 with address akka://cluster-test@127.0.0.1:2558/user/shardmanager-config42/member-1-shard-default-config42
01:35:53,179 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] ArteryTransport - Remoting started with transport [Artery tcp]; listening on address [akka://cluster-test@127.0.0.1:2559] with UID [7732278129082559730]
01:35:53,179 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2559] - Starting up, Akka version [2.6.21] ...
01:35:53,181 PM [cluster-test-akka.actor.default-dispatcher-5] [WARN] Cluster - Could not register Cluster JMX MBean with name=akka:type=Cluster as it is already registered. If you are running multiple clusters in the same JVM, set 'akka.cluster.jmx.multi-mbeans-in-same-jvm = on' in config
01:35:53,181 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2559] - Started up successfully
01:35:53,192 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2559] - No downing-provider-class configured, manual cluster downing required, see https://doc.akka.io/docs/akka/current/typed/cluster.html#downing
01:35:53,192 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2559] - No seed-nodes configured, manual cluster join required, see https://doc.akka.io/docs/akka/current/typed/cluster.html#joining
01:35:53,205 PM [cluster-test-akka.actor.default-dispatcher-10] [INFO] EmptyLocalActorRef - Message [org.opendaylight.controller.cluster.common.actor.Monitor] from TestActor[akka://cluster-test/user/shardmanager-config42] to Actor[akka://cluster-test/user/termination-monitor] was not delivered. [1] dead letters encountered. If this is not an expected behavior then Actor[akka://cluster-test/user/termination-monitor] may have terminated unexpectedly. This logging can be turned off or adjusted with configuration settings 'akka.log-dead-letters' and 'akka.log-dead-letters-during-shutdown'.
01:35:53,207 PM [cluster-test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1
01:35:53,207 PM [cluster-test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - Creating Shard member-1-shard-default-config42
01:35:53,207 PM [cluster-test-akka.actor.default-dispatcher-10] [INFO] ShardInformation - updatePeerAddress for peer member-1-shard-default-config42 with address akka://cluster-test@127.0.0.1:2558/user/shardmanager-config42/member-1-shard-default-config42
01:35:53,207 PM [cluster-test-akka.actor.default-dispatcher-10] [DEBUG] ShardInformation - Sending PeerAddressResolved for peer member-1-shard-default-config42 with address akka://cluster-test@127.0.0.1:2558/user/shardmanager-config42/member-1-shard-default-config42 to akka://cluster-test/user/member-1-shard-default-config
01:35:53,207 PM [cluster-test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shardmanager-config42: updated peer member-1-shard-default-config42 on member MemberName{name=member-1} with address akka://cluster-test@127.0.0.1:2558/user/shardmanager-config42/member-1-shard-default-config42 on shard member-1-shard-default-config42 whose actor address is Actor[akka://cluster-test/user/member-1-shard-default-config#-559427120]
01:35:53,207 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] ShardManager - Starting ShardManager shardmanager-config42
01:35:53,224 PM [cluster-test-akka.actor.default-dispatcher-13] [INFO] ShardManager - Recovery complete : shardmanager-config42
01:35:53,224 PM [cluster-test-akka.actor.default-dispatcher-13] [DEBUG] ShardManager - shardmanager-config42: Creating local shard: member-2-shard-default-config42
01:35:53,225 PM [cluster-test-akka.actor.default-dispatcher-13] [DEBUG] ShardManager - shardmanager-config42: Creating local shard: member-2-shard-astronauts-config42
01:35:53,225 PM [cluster-test-akka.actor.default-dispatcher-13] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1
01:35:53,225 PM [cluster-test-akka.actor.default-dispatcher-13] [DEBUG] ShardManager - Creating Shard member-2-shard-default-config42
01:35:53,225 PM [cluster-test-akka.actor.default-dispatcher-13] [DEBUG] ShardManager - Creating Shard member-2-shard-astronauts-config42
01:35:53,225 PM [cluster-test-akka.actor.default-dispatcher-13] [DEBUG] ShardManager - shardmanager-config42: Initializing shard [astronauts]
01:35:53,225 PM [cluster-test-akka.actor.default-dispatcher-13] [DEBUG] ShardInformation - Shard member-2-shard-astronauts-config42 is initialized
01:35:53,225 PM [cluster-test-akka.actor.default-dispatcher-13] [INFO] ShardManager - shardmanager-config42: Received LeaderStateChanged message: LeaderStateChanged [memberId=member-2-shard-astronauts-config42, leaderId=member-2-shard-astronauts-config42, leaderPayloadVersion=12]
01:35:53,225 PM [cluster-test-akka.actor.default-dispatcher-13] [INFO] ShardManager - shardmanager-config42: Received role changed for member-2-shard-astronauts-config42 from Candidate to Leader
01:35:53,259 PM [cluster-test-akka.actor.default-dispatcher-11] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2558] - Node [akka://cluster-test@127.0.0.1:2559] is JOINING, roles [member-2, dc-default], version [0.0.0]
01:35:53,267 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2559] - Welcome from [akka://cluster-test@127.0.0.1:2558]
01:35:53,267 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] ShardManager - shardmanager-config42: Received MemberUp: memberName: MemberName{name=member-1}, address: akka://cluster-test@127.0.0.1:2558
01:35:53,267 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] ShardInformation - updatePeerAddress for peer member-1-shard-default-config42 with address akka://cluster-test@127.0.0.1:2558/user/shardmanager-config42/member-1-shard-default-config42
01:35:53,267 PM [cluster-test-akka.actor.default-dispatcher-5] [DEBUG] ShardInformation - Sending PeerAddressResolved for peer member-1-shard-default-config42 with address akka://cluster-test@127.0.0.1:2558/user/shardmanager-config42/member-1-shard-default-config42 to akka://cluster-test/user/member-2-shard-astronauts-config
01:35:53,267 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] ShardInformation - updatePeerAddress for peer member-1-shard-astronauts-config42 with address akka://cluster-test@127.0.0.1:2558/user/shardmanager-config42/member-1-shard-astronauts-config42
01:35:53,267 PM [cluster-test-akka.actor.default-dispatcher-5] [DEBUG] ShardInformation - Sending PeerAddressResolved for peer member-1-shard-astronauts-config42 with address akka://cluster-test@127.0.0.1:2558/user/shardmanager-config42/member-1-shard-astronauts-config42 to akka://cluster-test/user/member-2-shard-astronauts-config
01:35:54,164 PM [cluster-test-akka.actor.default-dispatcher-11] [INFO] Cluster - Cluster Node [akka://cluster-test@127.0.0.1:2558] - Leader is moving node [akka://cluster-test@127.0.0.1:2559] to [Up]
01:35:54,167 PM [cluster-test-akka.actor.default-dispatcher-11] [INFO] ShardManager - shardmanager-config42: Received MemberUp: memberName: MemberName{name=member-2}, address: akka://cluster-test@127.0.0.1:2559
01:35:54,167 PM [cluster-test-akka.actor.default-dispatcher-11] [INFO] ShardInformation - updatePeerAddress for peer member-2-shard-default-config42 with address akka://cluster-test@127.0.0.1:2559/user/shardmanager-config42/member-2-shard-default-config42
01:35:54,167 PM [cluster-test-akka.actor.default-dispatcher-11] [DEBUG] ShardInformation - Sending PeerAddressResolved for peer member-2-shard-default-config42 with address akka://cluster-test@127.0.0.1:2559/user/shardmanager-config42/member-2-shard-default-config42 to akka://cluster-test/user/member-1-shard-default-config
01:35:54,170 PM [cluster-test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shardmanager-config42: onAddShardReplica: AddShardReplica[ShardName=astronauts]
01:35:54,170 PM [cluster-test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shardmanager-config42: In findPrimary: org.opendaylight.controller.cluster.datastore.messages.FindPrimary [shardName=astronauts, waitUntilReady=true]
01:35:54,170 PM [cluster-test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shardmanager-config42: findPrimary for astronauts forwarding to remote ShardManager akka://cluster-test@127.0.0.1:2559/user/shardmanager-config42, visitedAddresses: [akka://cluster-test@127.0.0.1:2558/user/shardmanager-config42]
01:35:54,180 PM [cluster-test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shardmanager-config42: In findPrimary: org.opendaylight.controller.cluster.datastore.messages.RemoteFindPrimary [shardName=astronauts, waitUntilReady=true]
01:35:54,180 PM [cluster-test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shardmanager-config42: Found primary for astronauts: RemotePrimaryShardFound [primaryPath=akka://cluster-test@127.0.0.1:2559/user/member-2-shard-astronauts-config, primaryVersion=12]
01:35:54,187 PM [cluster-test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shardmanager-config42: Sending AddServer message to peer akka://cluster-test@127.0.0.1:2559/user/member-2-shard-astronauts-config for shard member-1-shard-astronauts-config42
01:35:54,197 PM [cluster-test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shardmanager-config42: Received AddServerReply{status=OK, leaderHint=member-2-shard-astronauts-config42} for shard astronauts from leader akka://cluster-test@127.0.0.1:2559/user/member-2-shard-astronauts-config
01:35:54,197 PM [cluster-test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shardmanager-config42: Leader shard successfully added the replica shard astronauts
01:35:54,198 PM [cluster-test-akka.actor.default-dispatcher-11] [DEBUG] ShardInformation - Sending new DatastoreContext to member-1-shard-astronauts-config42
01:35:54,198 PM [cluster-test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shardmanager-config42: persisting the shard list [default, astronauts]
01:35:54,199 PM [cluster-test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shardmanager-config42 saved ShardManager snapshot successfully. Deleting the prev snapshot if available
01:35:54,200 PM [cluster-test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shardmanager-config42: Successfully deleted prior snapshots
01:35:54,222 PM [cluster-test-akka.actor.default-dispatcher-10] [INFO] ShardManager - shardmanager-config42: Received MemberUp: memberName: MemberName{name=member-2}, address: akka://cluster-test@127.0.0.1:2559
01:35:54,222 PM [cluster-test-akka.actor.default-dispatcher-10] [INFO] ShardInformation - updatePeerAddress for peer member-2-shard-default-config42 with address akka://cluster-test@127.0.0.1:2559/user/shardmanager-config42/member-2-shard-default-config42
01:35:54,222 PM [cluster-test-akka.actor.default-dispatcher-10] [DEBUG] ShardInformation - Sending PeerAddressResolved for peer member-2-shard-default-config42 with address akka://cluster-test@127.0.0.1:2559/user/shardmanager-config42/member-2-shard-default-config42 to akka://cluster-test/user/member-2-shard-astronauts-config
01:35:54,222 PM [cluster-test-akka.actor.default-dispatcher-10] [INFO] ShardInformation - updatePeerAddress for peer member-2-shard-astronauts-config42 with address akka://cluster-test@127.0.0.1:2559/user/shardmanager-config42/member-2-shard-astronauts-config42
01:35:54,222 PM [cluster-test-akka.actor.default-dispatcher-10] [DEBUG] ShardInformation - Sending PeerAddressResolved for peer member-2-shard-astronauts-config42 with address akka://cluster-test@127.0.0.1:2559/user/shardmanager-config42/member-2-shard-astronauts-config42 to akka://cluster-test/user/member-2-shard-astronauts-config
01:35:54,227 PM [main] [INFO] ShardManagerTest - testAddShardReplica ending
01:35:54,330 PM [cluster-test-akka.actor.default-dispatcher-14] [INFO] ShardManager - Stopping ShardManager shardmanager-config42
01:35:54,337 PM [cluster-test-akka.actor.default-dispatcher-14] [INFO] RemoteActorRefProvider$RemotingTerminator - Shutting down remote daemon.
01:35:54,337 PM [cluster-test-akka.actor.default-dispatcher-14] [INFO] RemoteActorRefProvider$RemotingTerminator - Remote daemon shut down; proceeding with flushing remote transports.
01:35:54,341 PM [cluster-test-akka.actor.default-dispatcher-14] [WARN] Materializer - [outbound connection to [akka://cluster-test@127.0.0.1:2559], control stream] Upstream failed, cause: StreamTcpException: The connection has been aborted
01:35:54,342 PM [cluster-test-akka.actor.default-dispatcher-14] [WARN] Materializer - [outbound connection to [akka://cluster-test@127.0.0.1:2559], message stream] Upstream failed, cause: StreamTcpException: The connection has been aborted
01:35:54,344 PM [cluster-test-akka.actor.default-dispatcher-14] [INFO] RemoteActorRefProvider$RemotingTerminator - Remoting shut down.
01:35:54,357 PM [cluster-test-akka.actor.default-dispatcher-10] [INFO] ShardManager - Stopping ShardManager shardmanager-config42
01:35:54,359 PM [cluster-test-akka.actor.default-dispatcher-11] [INFO] RemoteActorRefProvider$RemotingTerminator - Shutting down remote daemon.
01:35:54,359 PM [cluster-test-akka.actor.default-dispatcher-11] [INFO] RemoteActorRefProvider$RemotingTerminator - Remote daemon shut down; proceeding with flushing remote transports.
01:35:55,376 PM [cluster-test-akka.actor.default-dispatcher-5] [INFO] RemoteActorRefProvider$RemotingTerminator - Remoting shut down.
[WARN] [03/11/2024 13:35:55.378] [cluster-test-akka.actor.internal-dispatcher-8] [Cluster(akka://cluster-test)] Could not unregister Cluster JMX MBean with name=akka:type=Cluster as it was not found. If you are running multiple clusters in the same JVM, set 'akka.cluster.jmx.multi-mbeans-in-same-jvm = on' in config
01:35:55,399 PM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Starting ShardManager shard-manager-config43
01:35:55,401 PM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - Recovery complete : shard-manager-config43
01:35:55,401 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config43: Creating local shard: member-1-shard-default-config43
01:35:55,408 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1
01:35:55,408 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - Creating Shard member-1-shard-default-config43
01:35:55,408 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config43: Initializing shard [default]
01:35:55,408 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardInformation - Shard member-1-shard-default-config43 is initialized
01:35:55,408 PM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - shard-manager-config43: Received LeaderStateChanged message: LeaderStateChanged [memberId=member-1-shard-default-config43, leaderId=member-1-shard-default-config43, leaderPayloadVersion=13]
01:35:55,408 PM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - shard-manager-config43: Received role changed for member-1-shard-default-config43 from Candidate to Leader
01:35:55,408 PM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - shard-manager-config43: All Shards are ready - data store config43 is ready
01:35:55,408 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config43: onRemoveShardReplica: RemoveShardReplica [shardName=default, memberName=MemberName{name=member-1}]
01:35:55,408 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config43: In findPrimary: org.opendaylight.controller.cluster.datastore.messages.FindPrimary [shardName=default, waitUntilReady=true]
01:35:55,408 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config43: Found primary for default: LocalPrimaryShardFound [primaryPath=akka://test@127.0.0.1:2565/user/member-1-shard-default-config43#-1367528485, localShardDataTree=org.opendaylight.yangtools.yang.data.tree.api.DataTree$MockitoMock$yZQhsnCX@6259e660]
01:35:55,409 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config43: Sending RemoveServer message to peer akka://test@127.0.0.1:2565/user/member-1-shard-default-config43#-1367528485 for shard member-1-shard-default-config43
01:35:55,409 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config43: Received RemoveServerReply{status=OK} for shard default
01:35:55,409 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config43: Leader shard successfully removed the replica shard default
01:35:55,560 PM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/member-1-shard-default-config43#-1367528485]
01:35:55,574 PM [main] [INFO] ShardManagerTest - testOnReceiveFindPrimaryWaitForReadyWithIsolatedLeaderShard starting
01:35:55,576 PM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - Starting ShardManager shard-manager-config44
01:35:55,578 PM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Recovery complete : shard-manager-config44
01:35:55,578 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config44: Creating local shard: member-1-shard-default-config44
01:35:55,587 PM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1
01:35:55,587 PM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - Creating Shard member-1-shard-default-config44
01:35:55,587 PM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - shard-manager-config44: Initializing shard [default]
01:35:55,587 PM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardInformation - Shard member-1-shard-default-config44 is initialized
01:35:55,587 PM [test-akka.actor.default-dispatcher-14] [INFO] ShardManager - shard-manager-config44: Received role changed for member-1-shard-default-config44 from null to IsolatedLeader
01:35:55,587 PM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - shard-manager-config44: In findPrimary: org.opendaylight.controller.cluster.datastore.messages.FindPrimary [shardName=default, waitUntilReady=true]
01:35:55,587 PM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - shard-manager-config44: Scheduling 1200 ms timer to wait for shard ShardInformation [shardId=member-1-shard-default-config44, leaderAvailable=false, actorInitialized=true, followerSyncStatus=false, role=IsolatedLeader, leaderId=null, activeMember=true]
01:35:56,807 PM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - shard-manager-config44: Received ShardNotInitializedTimeout message for shard default
01:35:56,807 PM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - shard-manager-config44: Returning NoShardLeaderException for shard default
01:35:56,808 PM [main] [INFO] ShardManagerTest - testOnReceiveFindPrimaryWaitForReadyWithIsolatedLeaderShard ending
01:35:56,909 PM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/$y#-1842754257]
01:35:56,920 PM [test-akka.actor.default-dispatcher-14] [INFO] ShardManager - Stopping ShardManager shard-manager-config44
01:35:56,927 PM [test-akka.actor.default-dispatcher-14] [INFO] ShardManager - Starting ShardManager shard-manager-config45
01:35:56,928 PM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - Recovery complete : shard-manager-config45
01:35:56,928 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config45: Creating local shard: member-1-shard-default-config45
01:35:56,938 PM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1
01:35:56,938 PM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - Creating Shard member-1-shard-default-config45
01:35:56,938 PM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - shard-manager-config45: findLocalShard : non-existent
01:35:56,938 PM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - shard-manager-config45: Local shard non-existent not found - shards present: [default]
01:35:57,39 PM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/$z#1392113114]
01:35:57,50 PM [test-akka.actor.default-dispatcher-14] [INFO] ShardManager - Stopping ShardManager shard-manager-config45
01:35:57,55 PM [test-akka.actor.default-dispatcher-14] [INFO] ShardManager - Starting ShardManager shard-manager-config46
01:35:57,57 PM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - Recovery complete : shard-manager-config46
01:35:57,76 PM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1
01:35:57,76 PM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - shard-manager-config46: onRemoveShardReplica: RemoveShardReplica [shardName=astronauts, memberName=MemberName{name=member-2}]
01:35:57,77 PM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - shard-manager-config46: Sending RemoveServer message to peer akka://test@127.0.0.1:2565/system/testProbe-92#-1206375534 for shard member-2-shard-astronauts-config46
01:35:57,88 PM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - shard-manager-config46: onRemoveShardReplica: RemoveShardReplica [shardName=astronauts, memberName=MemberName{name=member-3}]
01:35:57,88 PM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - shard-manager-config46: A shard replica operation for astronauts is already in progress
01:35:57,196 PM [test-akka.actor.default-dispatcher-14] [INFO] ShardManager - Starting ShardManager shard-manager-config47
01:35:57,197 PM [test-akka.actor.default-dispatcher-14] [INFO] ShardManager - Recovery complete : shard-manager-config47
01:35:57,197 PM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - shard-manager-config47: Creating local shard: member-1-shard-default-config47
01:35:57,206 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config47: In findPrimary: org.opendaylight.controller.cluster.datastore.messages.FindPrimary [shardName=default, waitUntilReady=false]
01:35:57,206 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config47: Returning NotInitializedException for shard default
01:35:57,308 PM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/$A#1828137080]
01:35:57,319 PM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - Stopping ShardManager shard-manager-config47
01:35:57,321 PM [main] [INFO] ShardManagerTest - testServerRemovedShardActorRunning starting
01:35:57,325 PM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Starting ShardManager shard-manager-config48
01:35:57,326 PM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - Recovery complete : shard-manager-config48
01:35:57,326 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config48: Creating local shard: member-1-shard-default-config48
01:35:57,327 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config48: Creating local shard: member-1-shard-people-config48
01:35:57,337 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1
01:35:57,337 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - Creating Shard member-1-shard-default-config48
01:35:57,337 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - Creating Shard member-1-shard-people-config48
01:35:57,338 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config48: Initializing shard [default]
01:35:57,338 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardInformation - Shard member-1-shard-default-config48 is initialized
01:35:57,338 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config48: findLocalShard : people
01:35:57,338 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config48: Scheduling 600 ms timer to wait for shard ShardInformation [shardId=member-1-shard-people-config48, leaderAvailable=false, actorInitialized=false, followerSyncStatus=false, role=null, leaderId=null, activeMember=true]
01:35:57,339 PM [test-shard-dispatcher-16] [INFO] Shard - Shard created : member-1-shard-people-config48, persistent : true
01:35:57,342 PM [test-shard-dispatcher-16] [INFO] Shard - Starting recovery for member-1-shard-people-config48 with journal batch size 1
01:35:57,346 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardSnapshotActor - Actor created Actor[akka://test/user/$$k/member-1-shard-people-config48/shard-member-1:snapshot-read#1151686296]
01:35:57,347 PM [test-akka.actor.default-dispatcher-14] [INFO] RoleChangeNotifier - RoleChangeNotifier:akka://test@127.0.0.1:2565/user/$$k/member-1-shard-people-config48/member-1-shard-people-config48-notifier#29015010 created and ready for shard:member-1-shard-people-config48
01:35:57,351 PM [test-shard-dispatcher-16] [DEBUG] Shard - member-1-shard-people-config48: onReceiveRecover: Received message class akka.persistence.RecoveryCompleted$ from Actor[akka://test/deadLetters]
01:35:57,351 PM [test-shard-dispatcher-16] [INFO] Shard - member-1-shard-people-config48: Recovery completed  - Switching actor to Follower - last log index = -1, last log term = -1, snapshot index = -1, snapshot term = -1, journal size = 0
01:35:57,351 PM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - shard-manager-config48: Initializing shard [people]
01:35:57,351 PM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardInformation - Shard member-1-shard-people-config48 is initialized
01:35:57,351 PM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardInformation - Shard member-1-shard-people-config48 is initialized - notifying 1 OnShardInitialized callbacks
01:35:57,351 PM [test-shard-dispatcher-16] [DEBUG] DataTreeChangeListenerSupport - member-1-shard-people-config48: onLeadershipChange, isLeader: false, hasLeader : false
01:35:57,352 PM [test-shard-dispatcher-16] [DEBUG] Shard - member-1-shard-people-config48: onStateChanged: Closing all transaction chains because shard member-1-shard-people-config48 is no longer the leader
01:35:57,352 PM [test-akka.actor.default-dispatcher-11] [INFO] RoleChangeNotifier - RoleChangeNotifier for member-1-shard-people-config48 , received role change from null to Follower
01:35:57,352 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config48: findLocalShard : default
01:35:57,352 PM [test-akka.actor.default-dispatcher-11] [INFO] RoleChangeNotifier - RoleChangeNotifier for member-1-shard-people-config48 , registered listener akka://test/user/$$k
01:35:57,352 PM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - shard-manager-config48 : Sending Shutdown to Shard actor Actor[akka://test/user/member-1-shard-default-config48#-1754900709] with 10000 ms timeout
01:35:57,353 PM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - shard-manager-config48 : Local Shard replica for shard default has been removed
01:35:57,353 PM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - shard-manager-config48: persisting the shard list [people]
01:35:57,354 PM [test-akka.actor.default-dispatcher-14] [INFO] ShardManager - shard-manager-config48: Received role changed for member-1-shard-people-config48 from null to Follower
01:35:57,354 PM [main] [INFO] ShardManagerTest - testServerRemovedShardActorRunning ending
01:35:57,354 PM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - shard-manager-config48 saved ShardManager snapshot successfully. Deleting the prev snapshot if available
01:35:57,354 PM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - shard-manager-config48: Successfully deleted prior snapshots
01:35:57,455 PM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/member-1-shard-default-config48#-1754900709]
01:35:57,466 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config48 : Successfully shut down Shard actor Actor[akka://test/user/member-1-shard-default-config48#-1754900709]
01:35:57,466 PM [main] [INFO] TestActorFactory - Killing actor TestActor[akka://test/user/$$k]
01:35:57,466 PM [test-shard-dispatcher-16] [INFO] Shard - Stopping Shard member-1-shard-people-config48
01:35:57,467 PM [test-shard-dispatcher-16] [DEBUG] MessageAssembler - member-1-shard-people-config48 (Follower): Closing
01:35:57,467 PM [test-shard-dispatcher-16] [DEBUG] Shard - member-1-shard-people-config48: Aborting 0 pending queued transactions
01:35:57,467 PM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Stopping ShardManager shard-manager-config48
01:35:57,472 PM [main] [INFO] ShardManager - Starting ShardManager shard-manager-config49
01:35:57,474 PM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - Recovery complete : shard-manager-config49
01:35:57,474 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config49: Creating local shard: member-1-shard-default-config49
01:35:57,573 PM [main] [INFO] ShardManager - shard-manager-config49: Received role changed for member-1-shard-default-config49 from null to Follower
01:35:57,573 PM [main] [INFO] ShardManager - shard-manager-config49: Received LeaderStateChanged message: LeaderStateChanged [memberId=member-1-shard-default-config49, leaderId=member-2-shard-default-config49, leaderPayloadVersion=13]
01:35:57,584 PM [main] [INFO] ShardManager - shard-manager-config49: Received MemberUp: memberName: MemberName{name=member-2}, address: akka://test
01:35:57,584 PM [main] [INFO] ShardInformation - updatePeerAddress for peer member-2-shard-default-config49 with address akka://test/user/shardmanager-config49/member-2-shard-default-config49
01:35:57,584 PM [main] [INFO] ShardManager - shard-manager-config49: All Shards are ready - data store config49 is ready
01:35:57,686 PM [main] [INFO] TestActorFactory - Killing actor TestActor[akka://test/user/$$l]
01:35:57,696 PM [main] [INFO] ShardManager - Stopping ShardManager shard-manager-config49
01:35:57,699 PM [main] [INFO] ShardManagerTest - testRestoreFromSnapshot starting
01:35:57,701 PM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - Starting ShardManager shard-manager-config50
01:35:57,702 PM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - Recovery complete : shard-manager-config50
01:35:57,702 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config50: Restoring from ShardManagerSnapshot: ShardManagerSnapshot [ShardList = [shard1, shard2, astronauts] ]
01:35:57,702 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config50: onSnapshotOffer: ShardManagerSnapshot [ShardList = [shard1, shard2, astronauts] ]
01:35:57,703 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config50: adding shard shard1
01:35:57,703 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config50: adding shard shard2
01:35:57,703 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config50: adding shard astronauts
01:35:57,703 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config50: Creating local shard: member-1-shard-shard2-config50
01:35:57,703 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config50: Creating local shard: member-1-shard-astronauts-config50
01:35:57,703 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config50: Creating local shard: member-1-shard-shard1-config50
01:35:57,802 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1
01:35:57,802 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - Creating Shard member-1-shard-shard2-config50
01:35:57,802 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - Creating Shard member-1-shard-astronauts-config50
01:35:57,803 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - Creating Shard member-1-shard-shard1-config50
01:35:57,803 PM [test-shard-dispatcher-16] [INFO] Shard - Shard created : member-1-shard-shard2-config50, persistent : true
01:35:57,804 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardSnapshotActor - Actor created Actor[akka://test/user/$$m/member-1-shard-shard2-config50/shard-member-1:snapshot-read#-851789879]
01:35:57,804 PM [test-shard-dispatcher-16] [INFO] Shard - Starting recovery for member-1-shard-shard2-config50 with journal batch size 1
01:35:57,805 PM [test-shard-dispatcher-18] [INFO] Shard - Shard created : member-1-shard-shard1-config50, persistent : true
01:35:57,805 PM [test-shard-dispatcher-18] [INFO] Shard - Starting recovery for member-1-shard-shard1-config50 with journal batch size 1
01:35:57,805 PM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardSnapshotActor - Actor created Actor[akka://test/user/$$m/member-1-shard-shard1-config50/shard-member-1:snapshot-read#2024081872]
01:35:57,805 PM [test-shard-dispatcher-18] [DEBUG] Shard - member-1-shard-shard2-config50: onReceiveRecover: Received message class akka.persistence.RecoveryCompleted$ from Actor[akka://test/deadLetters]
01:35:57,805 PM [test-shard-dispatcher-18] [INFO] Shard - member-1-shard-shard2-config50: Recovery completed  - Switching actor to Follower - last log index = -1, last log term = -1, snapshot index = -1, snapshot term = -1, journal size = 0
01:35:57,806 PM [test-shard-dispatcher-18] [DEBUG] DataTreeChangeListenerSupport - member-1-shard-shard2-config50: onLeadershipChange, isLeader: false, hasLeader : false
01:35:57,806 PM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - shard-manager-config50: Initializing shard [shard2]
01:35:57,806 PM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardInformation - Shard member-1-shard-shard2-config50 is initialized
01:35:57,806 PM [test-shard-dispatcher-18] [DEBUG] Shard - member-1-shard-shard2-config50: onStateChanged: Closing all transaction chains because shard member-1-shard-shard2-config50 is no longer the leader
01:35:57,806 PM [test-shard-dispatcher-18] [DEBUG] Shard - member-1-shard-shard2-config50 (Follower): Received TimeoutNow - switching to Candidate
01:35:57,806 PM [test-shard-dispatcher-18] [DEBUG] Shard - member-1-shard-shard2-config50 (Candidate): Election: Candidate has following voting peers: []
01:35:57,806 PM [test-shard-dispatcher-18] [DEBUG] Shard - member-1-shard-shard2-config50: Set currentTerm=1, votedFor=member-1-shard-shard2-config50
01:35:57,806 PM [test-shard-dispatcher-18] [INFO] Shard - member-1-shard-shard2-config50 (Candidate): Starting new election term 1
01:35:57,806 PM [test-shard-dispatcher-18] [INFO] Shard - member-1-shard-shard2-config50 (Follower) :- Switching from behavior Follower to Candidate, election term: 1
01:35:57,806 PM [test-shard-dispatcher-18] [DEBUG] MessageAssembler - member-1-shard-shard2-config50 (Follower): Closing
01:35:57,806 PM [test-shard-dispatcher-18] [DEBUG] DataTreeChangeListenerSupport - member-1-shard-shard2-config50: onLeadershipChange, isLeader: false, hasLeader : false
01:35:57,806 PM [test-shard-dispatcher-18] [DEBUG] Shard - member-1-shard-shard2-config50: onStateChanged: Closing all transaction chains because shard member-1-shard-shard2-config50 is no longer the leader
01:35:57,806 PM [test-akka.actor.default-dispatcher-10] [INFO] RoleChangeNotifier - RoleChangeNotifier:akka://test@127.0.0.1:2565/user/$$m/member-1-shard-shard2-config50/member-1-shard-shard2-config50-notifier#-625113869 created and ready for shard:member-1-shard-shard2-config50
01:35:57,806 PM [test-akka.actor.default-dispatcher-10] [INFO] RoleChangeNotifier - RoleChangeNotifier for member-1-shard-shard2-config50 , received role change from null to Follower
01:35:57,806 PM [test-akka.actor.default-dispatcher-10] [INFO] RoleChangeNotifier - RoleChangeNotifier for member-1-shard-shard2-config50 , received role change from Follower to Candidate
01:35:57,807 PM [test-shard-dispatcher-17] [INFO] Shard - Shard created : member-1-shard-astronauts-config50, persistent : true
01:35:57,807 PM [test-akka.actor.default-dispatcher-14] [INFO] RoleChangeNotifier - RoleChangeNotifier:akka://test@127.0.0.1:2565/user/$$m/member-1-shard-shard1-config50/member-1-shard-shard1-config50-notifier#-509382597 created and ready for shard:member-1-shard-shard1-config50
01:35:57,807 PM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardSnapshotActor - Actor created Actor[akka://test/user/$$m/member-1-shard-astronauts-config50/shard-member-1:snapshot-read#1097812440]
01:35:57,807 PM [test-akka.actor.default-dispatcher-14] [INFO] RoleChangeNotifier - RoleChangeNotifier:akka://test@127.0.0.1:2565/user/$$m/member-1-shard-astronauts-config50/member-1-shard-astronauts-config50-notifier#-69200899 created and ready for shard:member-1-shard-astronauts-config50
01:35:57,807 PM [test-shard-dispatcher-17] [INFO] Shard - Starting recovery for member-1-shard-astronauts-config50 with journal batch size 1
01:35:57,808 PM [test-shard-dispatcher-17] [DEBUG] Shard - member-1-shard-shard2-config50 (Candidate): Received ElectionTimeout
01:35:57,808 PM [test-shard-dispatcher-16] [DEBUG] Shard - member-1-shard-shard1-config50: onReceiveRecover: Received message class akka.persistence.RecoveryCompleted$ from Actor[akka://test/deadLetters]
01:35:57,808 PM [test-shard-dispatcher-16] [INFO] Shard - member-1-shard-shard1-config50: Recovery completed  - Switching actor to Follower - last log index = -1, last log term = -1, snapshot index = -1, snapshot term = -1, journal size = 0
01:35:57,808 PM [test-shard-dispatcher-17] [DEBUG] Shard - member-1-shard-shard2-config50 (Leader): Election: Leader has following peers: []
01:35:57,808 PM [test-shard-dispatcher-17] [INFO] Shard - member-1-shard-shard2-config50 (Candidate) :- Switching from behavior Candidate to Leader, election term: 1
01:35:57,808 PM [test-shard-dispatcher-17] [DEBUG] DataTreeChangeListenerSupport - member-1-shard-shard2-config50: onLeadershipChange, isLeader: true, hasLeader : true
01:35:57,808 PM [test-shard-dispatcher-17] [DEBUG] Shard - member-1-shard-shard2-config50: became leader with frontend state for []
01:35:57,808 PM [test-shard-dispatcher-16] [DEBUG] DataTreeChangeListenerSupport - member-1-shard-shard1-config50: onLeadershipChange, isLeader: false, hasLeader : false
01:35:57,808 PM [test-shard-dispatcher-16] [DEBUG] Shard - member-1-shard-shard1-config50: onStateChanged: Closing all transaction chains because shard member-1-shard-shard1-config50 is no longer the leader
01:35:57,808 PM [test-akka.actor.default-dispatcher-5] [INFO] RoleChangeNotifier - RoleChangeNotifier for member-1-shard-shard1-config50 , received role change from null to Follower
01:35:57,808 PM [test-akka.actor.default-dispatcher-5] [INFO] RoleChangeNotifier - RoleChangeNotifier for member-1-shard-shard2-config50 , received role change from Candidate to Leader
01:35:57,808 PM [test-akka.actor.default-dispatcher-5] [INFO] RoleChangeNotifier - RoleChangeNotifier for member-1-shard-shard2-config50 , registered listener akka://test/user/$$m
01:35:57,808 PM [test-shard-dispatcher-16] [DEBUG] Shard - member-1-shard-shard1-config50 (Follower): Received TimeoutNow - switching to Candidate
01:35:57,808 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config50: Initializing shard [shard1]
01:35:57,808 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardInformation - Shard member-1-shard-shard1-config50 is initialized
01:35:57,808 PM [test-shard-dispatcher-16] [DEBUG] Shard - member-1-shard-shard1-config50 (Candidate): Election: Candidate has following voting peers: []
01:35:57,808 PM [test-shard-dispatcher-16] [DEBUG] Shard - member-1-shard-shard1-config50: Set currentTerm=1, votedFor=member-1-shard-shard1-config50
01:35:57,808 PM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - shard-manager-config50: Received LeaderStateChanged message: LeaderStateChanged [memberId=member-1-shard-shard2-config50, leaderId=member-1-shard-shard2-config50, leaderPayloadVersion=13]
01:35:57,808 PM [test-shard-dispatcher-16] [INFO] Shard - member-1-shard-shard1-config50 (Candidate): Starting new election term 1
01:35:57,808 PM [test-shard-dispatcher-16] [INFO] Shard - member-1-shard-shard1-config50 (Follower) :- Switching from behavior Follower to Candidate, election term: 1
01:35:57,808 PM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - shard-manager-config50: Received role changed for member-1-shard-shard2-config50 from Candidate to Leader
01:35:57,808 PM [test-shard-dispatcher-16] [DEBUG] MessageAssembler - member-1-shard-shard1-config50 (Follower): Closing
01:35:57,808 PM [test-shard-dispatcher-16] [DEBUG] DataTreeChangeListenerSupport - member-1-shard-shard1-config50: onLeadershipChange, isLeader: false, hasLeader : false
01:35:57,808 PM [test-shard-dispatcher-16] [DEBUG] Shard - member-1-shard-shard1-config50: onStateChanged: Closing all transaction chains because shard member-1-shard-shard1-config50 is no longer the leader
01:35:57,808 PM [test-akka.actor.default-dispatcher-10] [INFO] RoleChangeNotifier - RoleChangeNotifier for member-1-shard-shard1-config50 , received role change from Follower to Candidate
01:35:57,809 PM [test-shard-dispatcher-21] [DEBUG] Shard - member-1-shard-shard1-config50 (Candidate): Received ElectionTimeout
01:35:57,809 PM [test-shard-dispatcher-21] [DEBUG] Shard - member-1-shard-shard1-config50 (Leader): Election: Leader has following peers: []
01:35:57,809 PM [test-shard-dispatcher-21] [INFO] Shard - member-1-shard-shard1-config50 (Candidate) :- Switching from behavior Candidate to Leader, election term: 1
01:35:57,809 PM [test-shard-dispatcher-21] [DEBUG] DataTreeChangeListenerSupport - member-1-shard-shard1-config50: onLeadershipChange, isLeader: true, hasLeader : true
01:35:57,809 PM [test-shard-dispatcher-21] [DEBUG] Shard - member-1-shard-shard1-config50: became leader with frontend state for []
01:35:57,809 PM [test-akka.actor.default-dispatcher-10] [INFO] RoleChangeNotifier - RoleChangeNotifier for member-1-shard-shard1-config50 , received role change from Candidate to Leader
01:35:57,809 PM [test-shard-dispatcher-21] [DEBUG] Shard - member-1-shard-astronauts-config50: onReceiveRecover: Received message class akka.persistence.RecoveryCompleted$ from Actor[akka://test/deadLetters]
01:35:57,809 PM [test-akka.actor.default-dispatcher-10] [INFO] RoleChangeNotifier - RoleChangeNotifier for member-1-shard-shard1-config50 , registered listener akka://test/user/$$m
01:35:57,809 PM [test-shard-dispatcher-21] [INFO] Shard - member-1-shard-astronauts-config50: Recovery completed  - Switching actor to Follower - last log index = -1, last log term = -1, snapshot index = -1, snapshot term = -1, journal size = 0
01:35:57,809 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config50: Initializing shard [astronauts]
01:35:57,809 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardInformation - Shard member-1-shard-astronauts-config50 is initialized
01:35:57,810 PM [test-shard-dispatcher-21] [DEBUG] DataTreeChangeListenerSupport - member-1-shard-astronauts-config50: onLeadershipChange, isLeader: false, hasLeader : false
01:35:57,810 PM [test-shard-dispatcher-21] [DEBUG] Shard - member-1-shard-astronauts-config50: onStateChanged: Closing all transaction chains because shard member-1-shard-astronauts-config50 is no longer the leader
01:35:57,810 PM [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]
01:35:57,810 PM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - shard-manager-config50: Received role changed for member-1-shard-shard1-config50 from Candidate to Leader
01:35:57,810 PM [test-shard-dispatcher-21] [DEBUG] Shard - member-1-shard-astronauts-config50 (Follower): Received TimeoutNow - switching to Candidate
01:35:57,810 PM [test-akka.actor.default-dispatcher-20] [INFO] RoleChangeNotifier - RoleChangeNotifier for member-1-shard-astronauts-config50 , received role change from null to Follower
01:35:57,810 PM [test-shard-dispatcher-21] [DEBUG] Shard - member-1-shard-astronauts-config50 (Candidate): Election: Candidate has following voting peers: []
01:35:57,810 PM [test-shard-dispatcher-21] [DEBUG] Shard - member-1-shard-astronauts-config50: Set currentTerm=1, votedFor=member-1-shard-astronauts-config50
01:35:57,810 PM [test-shard-dispatcher-21] [INFO] Shard - member-1-shard-astronauts-config50 (Candidate): Starting new election term 1
01:35:57,810 PM [test-shard-dispatcher-21] [INFO] Shard - member-1-shard-astronauts-config50 (Follower) :- Switching from behavior Follower to Candidate, election term: 1
01:35:57,810 PM [test-shard-dispatcher-21] [DEBUG] MessageAssembler - member-1-shard-astronauts-config50 (Follower): Closing
01:35:57,810 PM [test-shard-dispatcher-21] [DEBUG] DataTreeChangeListenerSupport - member-1-shard-astronauts-config50: onLeadershipChange, isLeader: false, hasLeader : false
01:35:57,810 PM [test-shard-dispatcher-21] [DEBUG] Shard - member-1-shard-astronauts-config50: onStateChanged: Closing all transaction chains because shard member-1-shard-astronauts-config50 is no longer the leader
01:35:57,810 PM [test-akka.actor.default-dispatcher-10] [INFO] RoleChangeNotifier - RoleChangeNotifier for member-1-shard-astronauts-config50 , received role change from Follower to Candidate
01:35:57,810 PM [test-shard-dispatcher-21] [DEBUG] Shard - member-1-shard-astronauts-config50 (Candidate): Received ElectionTimeout
01:35:57,810 PM [test-shard-dispatcher-21] [DEBUG] Shard - member-1-shard-astronauts-config50 (Leader): Election: Leader has following peers: []
01:35:57,810 PM [test-shard-dispatcher-21] [INFO] Shard - member-1-shard-astronauts-config50 (Candidate) :- Switching from behavior Candidate to Leader, election term: 1
01:35:57,810 PM [test-shard-dispatcher-21] [DEBUG] DataTreeChangeListenerSupport - member-1-shard-astronauts-config50: onLeadershipChange, isLeader: true, hasLeader : true
01:35:57,810 PM [test-shard-dispatcher-21] [DEBUG] Shard - member-1-shard-astronauts-config50: became leader with frontend state for []
01:35:57,810 PM [test-akka.actor.default-dispatcher-10] [INFO] RoleChangeNotifier - RoleChangeNotifier for member-1-shard-astronauts-config50 , received role change from Candidate to Leader
01:35:57,810 PM [test-akka.actor.default-dispatcher-10] [INFO] RoleChangeNotifier - RoleChangeNotifier for member-1-shard-astronauts-config50 , registered listener akka://test/user/$$m
01:35:57,810 PM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - shard-manager-config50: Received LeaderStateChanged message: LeaderStateChanged [memberId=member-1-shard-astronauts-config50, leaderId=member-1-shard-astronauts-config50, leaderPayloadVersion=13]
01:35:57,810 PM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - shard-manager-config50: Received role changed for member-1-shard-astronauts-config50 from Candidate to Leader
01:35:57,810 PM [test-akka.actor.default-dispatcher-10] [INFO] ShardManager - shard-manager-config50: All Shards are ready - data store config50 is ready
01:35:57,812 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config50: findLocalShard : shard1
01:35:57,813 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config50: findLocalShard : shard2
01:35:57,813 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config50: findLocalShard : astronauts
01:35:57,813 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManager - shard-manager-config50: onGetSnapshot
01:35:57,813 PM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardManagerGetSnapshotReplyActor - shard-manager-config50: Expecting 3 shard snapshot replies
01:35:57,813 PM [test-shard-dispatcher-21] [DEBUG] Shard - member-1-shard-shard2-config50: onGetSnapshot
01:35:57,813 PM [test-shard-dispatcher-16] [DEBUG] Shard - member-1-shard-astronauts-config50: onGetSnapshot
01:35:57,813 PM [test-shard-dispatcher-18] [DEBUG] Shard - member-1-shard-shard1-config50: onGetSnapshot
01:35:57,813 PM [test-shard-dispatcher-16] [DEBUG] Shard - member-1-shard-astronauts-config50: Capturing Snapshot : lastLogEntry is null. Using snapshot values lastAppliedIndex -1 and lastAppliedTerm -1 instead.
01:35:57,813 PM [test-shard-dispatcher-18] [DEBUG] Shard - member-1-shard-shard1-config50: Capturing Snapshot : lastLogEntry is null. Using snapshot values lastAppliedIndex -1 and lastAppliedTerm -1 instead.
01:35:57,813 PM [test-shard-dispatcher-21] [DEBUG] Shard - member-1-shard-shard2-config50: Capturing Snapshot : lastLogEntry is null. Using snapshot values lastAppliedIndex -1 and lastAppliedTerm -1 instead.
01:35:57,820 PM [test-shard-dispatcher-18] [DEBUG] Shard - member-1-shard-shard1-config50: requesting serialization of snapshot MetadataShardDataTreeSnapshot{metadata={class org.opendaylight.controller.cluster.datastore.persisted.FrontendShardDataTreeSnapshotMetadata=FrontendShardDataTreeSnapshotMetadata{clients=[]}}}
01:35:57,820 PM [test-shard-dispatcher-21] [DEBUG] Shard - member-1-shard-shard2-config50: requesting serialization of snapshot MetadataShardDataTreeSnapshot{metadata={class org.opendaylight.controller.cluster.datastore.persisted.FrontendShardDataTreeSnapshotMetadata=FrontendShardDataTreeSnapshotMetadata{clients=[]}}}
01:35:57,820 PM [test-akka.actor.default-dispatcher-5] [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@4cb8cbaa, electionTerm=1, electionVotedFor=member-1-shard-shard2-config50, ServerConfigPayload=null]]
01:35:57,820 PM [test-shard-dispatcher-16] [DEBUG] Shard - member-1-shard-astronauts-config50: requesting serialization of snapshot MetadataShardDataTreeSnapshot{metadata={class org.opendaylight.controller.cluster.datastore.persisted.FrontendShardDataTreeSnapshotMetadata=FrontendShardDataTreeSnapshotMetadata{clients=[]}}}
01:35:57,820 PM [test-akka.actor.default-dispatcher-5] [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@386a2585, electionTerm=1, electionVotedFor=member-1-shard-shard1-config50, ServerConfigPayload=null]]
01:35:57,820 PM [test-akka.actor.default-dispatcher-5] [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@34fc57be, electionTerm=1, electionVotedFor=member-1-shard-astronauts-config50, ServerConfigPayload=null]]
01:35:57,820 PM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManagerGetSnapshotReplyActor - shard-manager-config50: All shard snapshots received
01:35:57,821 PM [main] [INFO] ShardManagerTest - testRestoreFromSnapshot ending
01:35:57,922 PM [main] [INFO] TestActorFactory - Killing actor TestActor[akka://test/user/$$m]
01:35:57,934 PM [test-shard-dispatcher-18] [INFO] Shard - Stopping Shard member-1-shard-astronauts-config50
01:35:57,934 PM [test-shard-dispatcher-18] [DEBUG] MessageSlicer - member-1-shard-astronauts-config50 (Leader)_slicer-id-163: Closing
01:35:57,934 PM [test-shard-dispatcher-16] [INFO] Shard - Stopping Shard member-1-shard-shard1-config50
01:35:57,934 PM [test-shard-dispatcher-16] [DEBUG] MessageSlicer - member-1-shard-shard1-config50 (Leader)_slicer-id-162: Closing
01:35:57,934 PM [test-shard-dispatcher-21] [INFO] Shard - Stopping Shard member-1-shard-shard2-config50
01:35:57,934 PM [test-shard-dispatcher-21] [DEBUG] MessageSlicer - member-1-shard-shard2-config50 (Leader)_slicer-id-161: Closing
01:35:57,934 PM [test-shard-dispatcher-18] [DEBUG] Shard - member-1-shard-astronauts-config50: Aborting 0 pending queued transactions
01:35:57,934 PM [test-shard-dispatcher-16] [DEBUG] Shard - member-1-shard-shard1-config50: Aborting 0 pending queued transactions
01:35:57,934 PM [test-shard-dispatcher-21] [DEBUG] Shard - member-1-shard-shard2-config50: Aborting 0 pending queued transactions
01:35:57,934 PM [test-akka.actor.default-dispatcher-20] [INFO] ShardManager - Stopping ShardManager shard-manager-config50
01:35:57,937 PM [main] [INFO] ShardManagerTest - testOnCreateShardWithNoInitialSchemaContext starting
01:35:57,940 PM [test-akka.actor.default-dispatcher-20] [INFO] ShardManager - Starting ShardManager shard-manager-config51
01:35:57,941 PM [test-akka.actor.default-dispatcher-14] [INFO] ShardManager - Recovery complete : shard-manager-config51
01:35:57,951 PM [test-akka.actor.default-dispatcher-20] [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@5193c272]
01:35:57,951 PM [test-akka.actor.default-dispatcher-20] [DEBUG] ShardManager - shard-manager-config51 doCreateShard: shardId: member-1-shard-foo-config51, memberNames: [MemberName{name=member-1}], peerAddresses: {}, isActiveMember: true
01:35:57,951 PM [test-akka.actor.default-dispatcher-20] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1
01:35:57,951 PM [test-akka.actor.default-dispatcher-20] [DEBUG] ShardManager - Creating Shard member-1-shard-foo-config51
01:35:57,952 PM [test-akka.actor.default-dispatcher-20] [DEBUG] ShardManager - shard-manager-config51: findLocalShard : foo
01:35:57,952 PM [test-akka.actor.default-dispatcher-20] [DEBUG] ShardManager - shard-manager-config51: Scheduling 600 ms timer to wait for shard ShardInformation [shardId=member-1-shard-foo-config51, leaderAvailable=false, actorInitialized=false, followerSyncStatus=false, role=null, leaderId=null, activeMember=true]
01:35:57,952 PM [test-shard-dispatcher-21] [INFO] Shard - Shard created : member-1-shard-foo-config51, persistent : true
01:35:57,953 PM [test-akka.actor.default-dispatcher-20] [INFO] RoleChangeNotifier - RoleChangeNotifier:akka://test@127.0.0.1:2565/user/$B/member-1-shard-foo-config51/member-1-shard-foo-config51-notifier#-343856705 created and ready for shard:member-1-shard-foo-config51
01:35:57,953 PM [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#292535681]
01:35:57,953 PM [test-shard-dispatcher-21] [INFO] Shard - Starting recovery for member-1-shard-foo-config51 with journal batch size 1
01:35:57,954 PM [test-shard-dispatcher-21] [DEBUG] Shard - member-1-shard-foo-config51: onReceiveRecover: Received message class akka.persistence.RecoveryCompleted$ from Actor[akka://test/deadLetters]
01:35:57,954 PM [test-shard-dispatcher-21] [INFO] Shard - member-1-shard-foo-config51: Recovery completed  - Switching actor to Follower - last log index = -1, last log term = -1, snapshot index = -1, snapshot term = -1, journal size = 0
01:35:57,954 PM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - shard-manager-config51: Initializing shard [foo]
01:35:57,954 PM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardInformation - Shard member-1-shard-foo-config51 is initialized
01:35:57,954 PM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardInformation - Shard member-1-shard-foo-config51 is initialized - notifying 1 OnShardInitialized callbacks
01:35:57,955 PM [test-shard-dispatcher-21] [DEBUG] DataTreeChangeListenerSupport - member-1-shard-foo-config51: onLeadershipChange, isLeader: false, hasLeader : false
01:35:57,955 PM [test-shard-dispatcher-21] [DEBUG] Shard - member-1-shard-foo-config51: onStateChanged: Closing all transaction chains because shard member-1-shard-foo-config51 is no longer the leader
01:35:57,955 PM [test-akka.actor.default-dispatcher-14] [INFO] RoleChangeNotifier - RoleChangeNotifier for member-1-shard-foo-config51 , received role change from null to Follower
01:35:57,955 PM [main] [INFO] ShardManagerTest - testOnCreateShardWithNoInitialSchemaContext ending
01:35:57,955 PM [test-shard-dispatcher-21] [DEBUG] Shard - member-1-shard-foo-config51 (Follower): Received TimeoutNow - switching to Candidate
01:35:57,955 PM [test-shard-dispatcher-21] [DEBUG] Shard - member-1-shard-foo-config51 (Candidate): Election: Candidate has following voting peers: []
01:35:57,955 PM [test-shard-dispatcher-21] [DEBUG] Shard - member-1-shard-foo-config51: Set currentTerm=1, votedFor=member-1-shard-foo-config51
01:35:57,955 PM [test-shard-dispatcher-21] [INFO] Shard - member-1-shard-foo-config51 (Candidate): Starting new election term 1
01:35:57,955 PM [test-shard-dispatcher-21] [INFO] Shard - member-1-shard-foo-config51 (Follower) :- Switching from behavior Follower to Candidate, election term: 1
01:35:57,955 PM [test-shard-dispatcher-21] [DEBUG] MessageAssembler - member-1-shard-foo-config51 (Follower): Closing
01:35:57,955 PM [test-shard-dispatcher-21] [DEBUG] DataTreeChangeListenerSupport - member-1-shard-foo-config51: onLeadershipChange, isLeader: false, hasLeader : false
01:35:57,955 PM [test-shard-dispatcher-21] [DEBUG] Shard - member-1-shard-foo-config51: onStateChanged: Closing all transaction chains because shard member-1-shard-foo-config51 is no longer the leader
01:35:57,955 PM [test-akka.actor.default-dispatcher-20] [INFO] RoleChangeNotifier - RoleChangeNotifier for member-1-shard-foo-config51 , received role change from Follower to Candidate
01:35:57,956 PM [test-shard-dispatcher-21] [DEBUG] Shard - member-1-shard-foo-config51 (Candidate): Received ElectionTimeout
01:35:57,956 PM [test-shard-dispatcher-21] [DEBUG] Shard - member-1-shard-foo-config51 (Leader): Election: Leader has following peers: []
01:35:57,956 PM [test-shard-dispatcher-21] [INFO] Shard - member-1-shard-foo-config51 (Candidate) :- Switching from behavior Candidate to Leader, election term: 1
01:35:57,956 PM [test-shard-dispatcher-21] [DEBUG] DataTreeChangeListenerSupport - member-1-shard-foo-config51: onLeadershipChange, isLeader: true, hasLeader : true
01:35:57,956 PM [test-shard-dispatcher-21] [DEBUG] Shard - member-1-shard-foo-config51: became leader with frontend state for []
01:35:57,956 PM [test-akka.actor.default-dispatcher-19] [INFO] RoleChangeNotifier - RoleChangeNotifier for member-1-shard-foo-config51 , received role change from Candidate to Leader
01:35:57,956 PM [test-akka.actor.default-dispatcher-19] [INFO] RoleChangeNotifier - RoleChangeNotifier for member-1-shard-foo-config51 , registered listener akka://test/user/$B
01:35:57,956 PM [test-akka.actor.default-dispatcher-19] [INFO] ShardManager - shard-manager-config51: Received LeaderStateChanged message: LeaderStateChanged [memberId=member-1-shard-foo-config51, leaderId=member-1-shard-foo-config51, leaderPayloadVersion=13]
01:35:57,956 PM [test-akka.actor.default-dispatcher-19] [INFO] ShardManager - shard-manager-config51: Received role changed for member-1-shard-foo-config51 from Candidate to Leader
01:35:57,956 PM [test-akka.actor.default-dispatcher-19] [INFO] ShardManager - shard-manager-config51: All Shards are ready - data store config51 is ready
01:35:58,56 PM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/$B#599410714]
01:35:58,68 PM [test-shard-dispatcher-21] [INFO] Shard - Stopping Shard member-1-shard-foo-config51
01:35:58,68 PM [test-shard-dispatcher-21] [DEBUG] MessageSlicer - member-1-shard-foo-config51 (Leader)_slicer-id-165: Closing
01:35:58,68 PM [test-shard-dispatcher-21] [DEBUG] Shard - member-1-shard-foo-config51: Aborting 0 pending queued transactions
01:35:58,69 PM [test-akka.actor.default-dispatcher-19] [INFO] ShardManager - Stopping ShardManager shard-manager-config51
01:35:58,71 PM [main] [INFO] ShardManagerTest - testGetSnapshot starting
01:35:58,74 PM [test-akka.actor.default-dispatcher-19] [INFO] ShardManager - Starting ShardManager shard-manager-config52
01:35:58,76 PM [test-akka.actor.default-dispatcher-19] [INFO] ShardManager - Recovery complete : shard-manager-config52
01:35:58,76 PM [test-akka.actor.default-dispatcher-19] [DEBUG] ShardManager - shard-manager-config52: Creating local shard: member-1-shard-shard2-config52
01:35:58,76 PM [test-akka.actor.default-dispatcher-19] [DEBUG] ShardManager - shard-manager-config52: Creating local shard: member-1-shard-shard1-config52
01:35:58,85 PM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - shard-manager-config52: onGetSnapshot
01:35:58,85 PM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1
01:35:58,85 PM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - Creating Shard member-1-shard-shard2-config52
01:35:58,86 PM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - Creating Shard member-1-shard-shard1-config52
01:35:58,86 PM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - shard-manager-config52: findLocalShard : shard1
01:35:58,86 PM [test-shard-dispatcher-21] [INFO] Shard - Shard created : member-1-shard-shard2-config52, persistent : true
01:35:58,86 PM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardManager - shard-manager-config52: Scheduling 600 ms timer to wait for shard ShardInformation [shardId=member-1-shard-shard1-config52, leaderAvailable=false, actorInitialized=false, followerSyncStatus=false, role=null, leaderId=null, activeMember=true]
01:35:58,86 PM [test-shard-dispatcher-16] [INFO] Shard - Shard created : member-1-shard-shard1-config52, persistent : true
01:35:58,87 PM [test-akka.actor.default-dispatcher-14] [INFO] RoleChangeNotifier - RoleChangeNotifier:akka://test@127.0.0.1:2565/user/$$n/member-1-shard-shard2-config52/member-1-shard-shard2-config52-notifier#-664053013 created and ready for shard:member-1-shard-shard2-config52
01:35:58,87 PM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardSnapshotActor - Actor created Actor[akka://test/user/$$n/member-1-shard-shard2-config52/shard-member-1:snapshot-read#801241672]
01:35:58,87 PM [test-shard-dispatcher-21] [INFO] Shard - Starting recovery for member-1-shard-shard2-config52 with journal batch size 1
01:35:58,87 PM [test-akka.actor.default-dispatcher-10] [INFO] RoleChangeNotifier - RoleChangeNotifier:akka://test@127.0.0.1:2565/user/$$n/member-1-shard-shard1-config52/member-1-shard-shard1-config52-notifier#-699447965 created and ready for shard:member-1-shard-shard1-config52
01:35:58,87 PM [test-akka.actor.default-dispatcher-19] [DEBUG] ShardSnapshotActor - Actor created Actor[akka://test/user/$$n/member-1-shard-shard1-config52/shard-member-1:snapshot-read#1415407743]
01:35:58,88 PM [test-shard-dispatcher-16] [INFO] Shard - Starting recovery for member-1-shard-shard1-config52 with journal batch size 1
01:35:58,88 PM [test-shard-dispatcher-16] [DEBUG] Shard - member-1-shard-shard2-config52: onReceiveRecover: Received message class akka.persistence.RecoveryCompleted$ from Actor[akka://test/deadLetters]
01:35:58,89 PM [test-shard-dispatcher-16] [INFO] Shard - member-1-shard-shard2-config52: Recovery completed  - Switching actor to Follower - last log index = -1, last log term = -1, snapshot index = -1, snapshot term = -1, journal size = 0
01:35:58,89 PM [test-shard-dispatcher-21] [DEBUG] Shard - member-1-shard-shard1-config52: onReceiveRecover: Received message class akka.persistence.RecoveryCompleted$ from Actor[akka://test/deadLetters]
01:35:58,89 PM [test-shard-dispatcher-21] [INFO] Shard - member-1-shard-shard1-config52: Recovery completed  - Switching actor to Follower - last log index = -1, last log term = -1, snapshot index = -1, snapshot term = -1, journal size = 0
01:35:58,89 PM [test-shard-dispatcher-21] [DEBUG] DataTreeChangeListenerSupport - member-1-shard-shard1-config52: onLeadershipChange, isLeader: false, hasLeader : false
01:35:58,89 PM [test-shard-dispatcher-16] [DEBUG] DataTreeChangeListenerSupport - member-1-shard-shard2-config52: onLeadershipChange, isLeader: false, hasLeader : false
01:35:58,89 PM [test-shard-dispatcher-21] [DEBUG] Shard - member-1-shard-shard1-config52: onStateChanged: Closing all transaction chains because shard member-1-shard-shard1-config52 is no longer the leader
01:35:58,89 PM [test-shard-dispatcher-16] [DEBUG] Shard - member-1-shard-shard2-config52: onStateChanged: Closing all transaction chains because shard member-1-shard-shard2-config52 is no longer the leader
01:35:58,89 PM [test-shard-dispatcher-21] [DEBUG] Shard - member-1-shard-shard1-config52 (Follower): Received TimeoutNow - switching to Candidate
01:35:58,89 PM [test-shard-dispatcher-16] [DEBUG] Shard - member-1-shard-shard2-config52 (Follower): Received TimeoutNow - switching to Candidate
01:35:58,89 PM [test-shard-dispatcher-21] [DEBUG] Shard - member-1-shard-shard1-config52 (Candidate): Election: Candidate has following voting peers: []
01:35:58,89 PM [test-shard-dispatcher-16] [DEBUG] Shard - member-1-shard-shard2-config52 (Candidate): Election: Candidate has following voting peers: []
01:35:58,89 PM [test-shard-dispatcher-21] [DEBUG] Shard - member-1-shard-shard1-config52: Set currentTerm=1, votedFor=member-1-shard-shard1-config52
01:35:58,89 PM [test-shard-dispatcher-16] [DEBUG] Shard - member-1-shard-shard2-config52: Set currentTerm=1, votedFor=member-1-shard-shard2-config52
01:35:58,89 PM [test-shard-dispatcher-16] [INFO] Shard - member-1-shard-shard2-config52 (Candidate): Starting new election term 1
01:35:58,89 PM [test-shard-dispatcher-21] [INFO] Shard - member-1-shard-shard1-config52 (Candidate): Starting new election term 1
01:35:58,89 PM [test-shard-dispatcher-16] [INFO] Shard - member-1-shard-shard2-config52 (Follower) :- Switching from behavior Follower to Candidate, election term: 1
01:35:58,89 PM [test-shard-dispatcher-21] [INFO] Shard - member-1-shard-shard1-config52 (Follower) :- Switching from behavior Follower to Candidate, election term: 1
01:35:58,89 PM [test-shard-dispatcher-21] [DEBUG] MessageAssembler - member-1-shard-shard1-config52 (Follower): Closing
01:35:58,89 PM [test-shard-dispatcher-16] [DEBUG] MessageAssembler - member-1-shard-shard2-config52 (Follower): Closing
01:35:58,89 PM [test-shard-dispatcher-21] [DEBUG] DataTreeChangeListenerSupport - member-1-shard-shard1-config52: onLeadershipChange, isLeader: false, hasLeader : false
01:35:58,89 PM [test-shard-dispatcher-16] [DEBUG] DataTreeChangeListenerSupport - member-1-shard-shard2-config52: onLeadershipChange, isLeader: false, hasLeader : false
01:35:58,89 PM [test-akka.actor.default-dispatcher-14] [INFO] RoleChangeNotifier - RoleChangeNotifier for member-1-shard-shard2-config52 , received role change from null to Follower
01:35:58,89 PM [test-shard-dispatcher-21] [DEBUG] Shard - member-1-shard-shard1-config52: onStateChanged: Closing all transaction chains because shard member-1-shard-shard1-config52 is no longer the leader
01:35:58,89 PM [test-shard-dispatcher-16] [DEBUG] Shard - member-1-shard-shard2-config52: onStateChanged: Closing all transaction chains because shard member-1-shard-shard2-config52 is no longer the leader
01:35:58,89 PM [test-akka.actor.default-dispatcher-20] [DEBUG] ShardManager - shard-manager-config52: Initializing shard [shard2]
01:35:58,89 PM [test-akka.actor.default-dispatcher-20] [DEBUG] ShardInformation - Shard member-1-shard-shard2-config52 is initialized
01:35:58,89 PM [test-akka.actor.default-dispatcher-14] [INFO] RoleChangeNotifier - RoleChangeNotifier for member-1-shard-shard1-config52 , received role change from null to Follower
01:35:58,89 PM [test-akka.actor.default-dispatcher-14] [INFO] RoleChangeNotifier - RoleChangeNotifier for member-1-shard-shard1-config52 , received role change from Follower to Candidate
01:35:58,89 PM [test-akka.actor.default-dispatcher-20] [DEBUG] ShardManager - shard-manager-config52: Initializing shard [shard1]
01:35:58,89 PM [test-akka.actor.default-dispatcher-20] [DEBUG] ShardInformation - Shard member-1-shard-shard1-config52 is initialized
01:35:58,89 PM [test-akka.actor.default-dispatcher-20] [DEBUG] ShardInformation - Shard member-1-shard-shard1-config52 is initialized - notifying 1 OnShardInitialized callbacks
01:35:58,89 PM [test-akka.actor.default-dispatcher-14] [INFO] RoleChangeNotifier - RoleChangeNotifier for member-1-shard-shard2-config52 , received role change from Follower to Candidate
01:35:58,90 PM [test-shard-dispatcher-16] [DEBUG] Shard - member-1-shard-shard1-config52 (Candidate): Received ElectionTimeout
01:35:58,90 PM [test-shard-dispatcher-21] [DEBUG] Shard - member-1-shard-shard2-config52 (Candidate): Received ElectionTimeout
01:35:58,90 PM [test-shard-dispatcher-16] [DEBUG] Shard - member-1-shard-shard1-config52 (Leader): Election: Leader has following peers: []
01:35:58,90 PM [test-shard-dispatcher-21] [DEBUG] Shard - member-1-shard-shard2-config52 (Leader): Election: Leader has following peers: []
01:35:58,90 PM [test-shard-dispatcher-16] [INFO] Shard - member-1-shard-shard1-config52 (Candidate) :- Switching from behavior Candidate to Leader, election term: 1
01:35:58,90 PM [test-shard-dispatcher-21] [INFO] Shard - member-1-shard-shard2-config52 (Candidate) :- Switching from behavior Candidate to Leader, election term: 1
01:35:58,90 PM [test-shard-dispatcher-16] [DEBUG] DataTreeChangeListenerSupport - member-1-shard-shard1-config52: onLeadershipChange, isLeader: true, hasLeader : true
01:35:58,90 PM [test-shard-dispatcher-21] [DEBUG] DataTreeChangeListenerSupport - member-1-shard-shard2-config52: onLeadershipChange, isLeader: true, hasLeader : true
01:35:58,90 PM [test-shard-dispatcher-21] [DEBUG] Shard - member-1-shard-shard2-config52: became leader with frontend state for []
01:35:58,90 PM [test-shard-dispatcher-16] [DEBUG] Shard - member-1-shard-shard1-config52: became leader with frontend state for []
01:35:58,91 PM [test-akka.actor.default-dispatcher-20] [INFO] RoleChangeNotifier - RoleChangeNotifier for member-1-shard-shard1-config52 , received role change from Candidate to Leader
01:35:58,91 PM [test-akka.actor.default-dispatcher-10] [INFO] RoleChangeNotifier - RoleChangeNotifier for member-1-shard-shard2-config52 , received role change from Candidate to Leader
01:35:58,91 PM [test-akka.actor.default-dispatcher-10] [INFO] RoleChangeNotifier - RoleChangeNotifier for member-1-shard-shard2-config52 , registered listener akka://test/user/$$n
01:35:58,91 PM [test-akka.actor.default-dispatcher-19] [DEBUG] ShardManager - shard-manager-config52: findLocalShard : shard2
01:35:58,91 PM [test-akka.actor.default-dispatcher-10] [INFO] RoleChangeNotifier - RoleChangeNotifier for member-1-shard-shard1-config52 , registered listener akka://test/user/$$n
01:35:58,91 PM [test-akka.actor.default-dispatcher-19] [INFO] ShardManager - shard-manager-config52: Received LeaderStateChanged message: LeaderStateChanged [memberId=member-1-shard-shard2-config52, leaderId=member-1-shard-shard2-config52, leaderPayloadVersion=13]
01:35:58,91 PM [test-akka.actor.default-dispatcher-19] [INFO] ShardManager - shard-manager-config52: Received role changed for member-1-shard-shard2-config52 from Candidate to Leader
01:35:58,91 PM [test-akka.actor.default-dispatcher-19] [INFO] ShardManager - shard-manager-config52: Received LeaderStateChanged message: LeaderStateChanged [memberId=member-1-shard-shard1-config52, leaderId=member-1-shard-shard1-config52, leaderPayloadVersion=13]
01:35:58,91 PM [test-akka.actor.default-dispatcher-19] [INFO] ShardManager - shard-manager-config52: Received role changed for member-1-shard-shard1-config52 from Candidate to Leader
01:35:58,91 PM [test-akka.actor.default-dispatcher-19] [INFO] ShardManager - shard-manager-config52: All Shards are ready - data store config52 is ready
01:35:58,91 PM [test-akka.actor.default-dispatcher-19] [DEBUG] ShardManager - shard-manager-config52: onGetSnapshot
01:35:58,91 PM [test-shard-dispatcher-16] [DEBUG] Shard - member-1-shard-shard2-config52: onGetSnapshot
01:35:58,91 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManagerGetSnapshotReplyActor - shard-manager-config52: Expecting 2 shard snapshot replies
01:35:58,91 PM [test-shard-dispatcher-21] [DEBUG] Shard - member-1-shard-shard1-config52: onGetSnapshot
01:35:58,91 PM [test-shard-dispatcher-16] [DEBUG] Shard - member-1-shard-shard2-config52: Capturing Snapshot : lastLogEntry is null. Using snapshot values lastAppliedIndex -1 and lastAppliedTerm -1 instead.
01:35:58,91 PM [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.
01:35:58,92 PM [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=[]}}}
01:35:58,92 PM [test-shard-dispatcher-16] [DEBUG] Shard - member-1-shard-shard2-config52: requesting serialization of snapshot MetadataShardDataTreeSnapshot{metadata={class org.opendaylight.controller.cluster.datastore.persisted.FrontendShardDataTreeSnapshotMetadata=FrontendShardDataTreeSnapshotMetadata{clients=[]}}}
01:35:58,92 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManagerGetSnapshotReplyActor - shard-manager-config52: Received GetSnapshotReply [id=member-1-shard-shard1-config52, snapshot=Snapshot [lastIndex=-1, lastTerm=-1, lastAppliedIndex=-1, lastAppliedTerm=-1, unAppliedEntries size=0, state=org.opendaylight.controller.cluster.datastore.persisted.ShardSnapshotState@7c0a6731, electionTerm=1, electionVotedFor=member-1-shard-shard1-config52, ServerConfigPayload=null]]
01:35:58,92 PM [test-akka.actor.default-dispatcher-10] [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@6cd595cd, electionTerm=1, electionVotedFor=member-1-shard-shard2-config52, ServerConfigPayload=null]]
01:35:58,92 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardManagerGetSnapshotReplyActor - shard-manager-config52: All shard snapshots received
01:35:58,103 PM [test-akka.actor.default-dispatcher-19] [DEBUG] ShardManager - shard-manager-config52: onAddShardReplica: AddShardReplica[ShardName=astronauts]
01:35:58,104 PM [test-akka.actor.default-dispatcher-19] [DEBUG] ShardManager - shard-manager-config52: Sending AddServer message to peer akka://test@127.0.0.1:2565/system/testProbe-106#-51374343 for shard member-1-shard-astronauts-config52
01:35:58,105 PM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - shard-manager-config52: Received AddServerReply{status=OK, leaderHint=} for shard astronauts from leader akka://test@127.0.0.1:2565/system/testProbe-106#-51374343
01:35:58,105 PM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - shard-manager-config52: Leader shard successfully added the replica shard astronauts
01:35:58,105 PM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardInformation - Sending new DatastoreContext to member-1-shard-astronauts-config52
01:35:58,105 PM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - shard-manager-config52: persisting the shard list [shard2, astronauts, shard1]
01:35:58,105 PM [test-shard-dispatcher-21] [INFO] Shard - Shard created : member-1-shard-astronauts-config52, persistent : true
01:35:58,106 PM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - shard-manager-config52: findLocalShard : astronauts
01:35:58,106 PM [test-akka.actor.default-dispatcher-5] [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]
01:35:58,106 PM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - shard-manager-config52 saved ShardManager snapshot successfully. Deleting the prev snapshot if available
01:35:58,106 PM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - shard-manager-config52: Successfully deleted prior snapshots
01:35:58,106 PM [test-akka.actor.default-dispatcher-5] [INFO] RoleChangeNotifier - RoleChangeNotifier:akka://test@127.0.0.1:2565/user/$$n/member-1-shard-astronauts-config52/member-1-shard-astronauts-config52-notifier#1513335170 created and ready for shard:member-1-shard-astronauts-config52
01:35:58,106 PM [test-akka.actor.default-dispatcher-10] [DEBUG] ShardSnapshotActor - Actor created Actor[akka://test/user/$$n/member-1-shard-astronauts-config52/shard-member-1:snapshot-read#2014377014]
01:35:58,107 PM [test-shard-dispatcher-21] [INFO] Shard - Starting recovery for member-1-shard-astronauts-config52 with journal batch size 1
01:35:58,108 PM [test-shard-dispatcher-21] [DEBUG] Shard - member-1-shard-astronauts-config52: onReceiveRecover: Received message class akka.persistence.RecoveryCompleted$ from Actor[akka://test/deadLetters]
01:35:58,108 PM [test-shard-dispatcher-21] [INFO] Shard - member-1-shard-astronauts-config52: Recovery completed  - Switching actor to Follower - last log index = -1, last log term = -1, snapshot index = -1, snapshot term = -1, journal size = 0
01:35:58,108 PM [test-shard-dispatcher-21] [DEBUG] DataTreeChangeListenerSupport - member-1-shard-astronauts-config52: onLeadershipChange, isLeader: false, hasLeader : false
01:35:58,108 PM [test-shard-dispatcher-21] [DEBUG] Shard - member-1-shard-astronauts-config52: onStateChanged: Closing all transaction chains because shard member-1-shard-astronauts-config52 is no longer the leader
01:35:58,108 PM [test-shard-dispatcher-21] [INFO] DefaultConfigParamsImpl - Trying to use custom RaftPolicy org.opendaylight.controller.cluster.raft.policy.DisableElectionsRaftPolicy
01:35:58,109 PM [test-shard-dispatcher-21] [DEBUG] Shard - member-1-shard-astronauts-config52: RaftPolicy used with prev.config org.opendaylight.controller.cluster.raft.policy.DisableElectionsRaftPolicy, RaftPolicy used with newConfig null
01:35:58,109 PM [test-shard-dispatcher-21] [DEBUG] Shard - member-1-shard-astronauts-config52: Re-initializing to Follower with previous leaderId null
01:35:58,109 PM [test-shard-dispatcher-21] [DEBUG] MessageAssembler - member-1-shard-astronauts-config52 (Follower): Closing
01:35:58,109 PM [test-shard-dispatcher-21] [DEBUG] DataTreeChangeListenerSupport - member-1-shard-astronauts-config52: onLeadershipChange, isLeader: false, hasLeader : false
01:35:58,109 PM [test-shard-dispatcher-21] [DEBUG] Shard - member-1-shard-astronauts-config52: onStateChanged: Closing all transaction chains because shard member-1-shard-astronauts-config52 is no longer the leader
01:35:58,109 PM [test-shard-dispatcher-21] [DEBUG] Shard - member-1-shard-astronauts-config52 (Follower): Received TimeoutNow - switching to Candidate
01:35:58,109 PM [test-shard-dispatcher-21] [DEBUG] Shard - member-1-shard-astronauts-config52 (Candidate): Election: Candidate has following voting peers: []
01:35:58,109 PM [test-shard-dispatcher-21] [DEBUG] Shard - member-1-shard-astronauts-config52: Set currentTerm=1, votedFor=member-1-shard-astronauts-config52
01:35:58,109 PM [test-shard-dispatcher-21] [INFO] Shard - member-1-shard-astronauts-config52 (Candidate): Starting new election term 1
01:35:58,109 PM [test-shard-dispatcher-21] [INFO] Shard - member-1-shard-astronauts-config52 (Follower) :- Switching from behavior Follower to Candidate, election term: 1
01:35:58,109 PM [test-shard-dispatcher-21] [DEBUG] MessageAssembler - member-1-shard-astronauts-config52 (Follower): Closing
01:35:58,109 PM [test-shard-dispatcher-21] [DEBUG] DataTreeChangeListenerSupport - member-1-shard-astronauts-config52: onLeadershipChange, isLeader: false, hasLeader : false
01:35:58,109 PM [test-shard-dispatcher-21] [DEBUG] Shard - member-1-shard-astronauts-config52: onStateChanged: Closing all transaction chains because shard member-1-shard-astronauts-config52 is no longer the leader
01:35:58,109 PM [test-akka.actor.default-dispatcher-19] [DEBUG] ShardManager - shard-manager-config52: Initializing shard [astronauts]
01:35:58,109 PM [test-akka.actor.default-dispatcher-19] [DEBUG] ShardInformation - Shard member-1-shard-astronauts-config52 is initialized
01:35:58,109 PM [test-akka.actor.default-dispatcher-19] [DEBUG] ShardInformation - Shard member-1-shard-astronauts-config52 is initialized - notifying 1 OnShardInitialized callbacks
01:35:58,109 PM [test-akka.actor.default-dispatcher-19] [INFO] RoleChangeNotifier - RoleChangeNotifier for member-1-shard-astronauts-config52 , received role change from null to Follower
01:35:58,109 PM [test-akka.actor.default-dispatcher-19] [INFO] RoleChangeNotifier - RoleChangeNotifier for member-1-shard-astronauts-config52 , received role change from Follower to Candidate
01:35:58,110 PM [test-shard-dispatcher-21] [DEBUG] Shard - member-1-shard-astronauts-config52 (Candidate): Received ElectionTimeout
01:35:58,110 PM [test-shard-dispatcher-21] [DEBUG] Shard - member-1-shard-astronauts-config52 (Leader): Election: Leader has following peers: []
01:35:58,110 PM [test-shard-dispatcher-21] [INFO] Shard - member-1-shard-astronauts-config52 (Candidate) :- Switching from behavior Candidate to Leader, election term: 1
01:35:58,110 PM [test-shard-dispatcher-21] [DEBUG] DataTreeChangeListenerSupport - member-1-shard-astronauts-config52: onLeadershipChange, isLeader: true, hasLeader : true
01:35:58,110 PM [test-shard-dispatcher-21] [DEBUG] Shard - member-1-shard-astronauts-config52: became leader with frontend state for []
01:35:58,110 PM [test-akka.actor.default-dispatcher-19] [DEBUG] ShardManager - shard-manager-config52: onGetSnapshot
01:35:58,110 PM [test-akka.actor.default-dispatcher-14] [INFO] RoleChangeNotifier - RoleChangeNotifier for member-1-shard-astronauts-config52 , received role change from Candidate to Leader
01:35:58,110 PM [test-akka.actor.default-dispatcher-14] [INFO] RoleChangeNotifier - RoleChangeNotifier for member-1-shard-astronauts-config52 , registered listener akka://test/user/$$n
01:35:58,110 PM [test-akka.actor.default-dispatcher-19] [INFO] ShardManager - shard-manager-config52: Received LeaderStateChanged message: LeaderStateChanged [memberId=member-1-shard-astronauts-config52, leaderId=member-1-shard-astronauts-config52, leaderPayloadVersion=13]
01:35:58,110 PM [test-akka.actor.default-dispatcher-14] [DEBUG] ShardManagerGetSnapshotReplyActor - shard-manager-config52: Expecting 3 shard snapshot replies
01:35:58,110 PM [test-akka.actor.default-dispatcher-19] [INFO] ShardManager - shard-manager-config52: Received role changed for member-1-shard-astronauts-config52 from Candidate to Leader
01:35:58,110 PM [test-akka.actor.default-dispatcher-19] [INFO] ShardManager - shard-manager-config52: All Shards are ready - data store config52 is ready
01:35:58,110 PM [test-shard-dispatcher-21] [DEBUG] Shard - member-1-shard-shard2-config52: onGetSnapshot
01:35:58,110 PM [test-shard-dispatcher-21] [DEBUG] Shard - member-1-shard-shard2-config52: Capturing Snapshot : lastLogEntry is null. Using snapshot values lastAppliedIndex -1 and lastAppliedTerm -1 instead.
01:35:58,110 PM [test-shard-dispatcher-16] [DEBUG] Shard - member-1-shard-astronauts-config52: onGetSnapshot
01:35:58,110 PM [test-shard-dispatcher-16] [DEBUG] Shard - member-1-shard-astronauts-config52: Capturing Snapshot : lastLogEntry is null. Using snapshot values lastAppliedIndex -1 and lastAppliedTerm -1 instead.
01:35:58,111 PM [test-shard-dispatcher-21] [DEBUG] Shard - member-1-shard-shard2-config52: requesting serialization of snapshot MetadataShardDataTreeSnapshot{metadata={class org.opendaylight.controller.cluster.datastore.persisted.FrontendShardDataTreeSnapshotMetadata=FrontendShardDataTreeSnapshotMetadata{clients=[]}}}
01:35:58,111 PM [test-shard-dispatcher-21] [DEBUG] Shard - member-1-shard-shard1-config52: onGetSnapshot
01:35:58,111 PM [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.
01:35:58,111 PM [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=[]}}}
01:35:58,111 PM [test-shard-dispatcher-16] [DEBUG] Shard - member-1-shard-astronauts-config52: requesting serialization of snapshot MetadataShardDataTreeSnapshot{metadata={class org.opendaylight.controller.cluster.datastore.persisted.FrontendShardDataTreeSnapshotMetadata=FrontendShardDataTreeSnapshotMetadata{clients=[]}}}
01:35:58,111 PM [test-akka.actor.default-dispatcher-5] [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@62e2aef, electionTerm=1, electionVotedFor=member-1-shard-shard2-config52, ServerConfigPayload=null]]
01:35:58,111 PM [test-akka.actor.default-dispatcher-5] [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@1ef29f40, electionTerm=1, electionVotedFor=member-1-shard-shard1-config52, ServerConfigPayload=null]]
01:35:58,111 PM [test-akka.actor.default-dispatcher-5] [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@7db19fea, electionTerm=1, electionVotedFor=member-1-shard-astronauts-config52, ServerConfigPayload=null]]
01:35:58,111 PM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManagerGetSnapshotReplyActor - shard-manager-config52: All shard snapshots received
01:35:58,112 PM [main] [INFO] ShardManagerTest - testGetSnapshot ending
01:35:58,214 PM [main] [INFO] TestActorFactory - Killing actor TestActor[akka://test/user/$$n]
01:35:58,225 PM [test-shard-dispatcher-16] [INFO] Shard - Stopping Shard member-1-shard-shard1-config52
01:35:58,225 PM [test-shard-dispatcher-18] [INFO] Shard - Stopping Shard member-1-shard-astronauts-config52
01:35:58,225 PM [test-shard-dispatcher-16] [DEBUG] MessageSlicer - member-1-shard-shard1-config52 (Leader)_slicer-id-168: Closing
01:35:58,225 PM [test-shard-dispatcher-18] [DEBUG] MessageSlicer - member-1-shard-astronauts-config52 (Leader)_slicer-id-171: Closing
01:35:58,226 PM [test-shard-dispatcher-16] [DEBUG] Shard - member-1-shard-shard1-config52: Aborting 0 pending queued transactions
01:35:58,226 PM [test-shard-dispatcher-18] [DEBUG] Shard - member-1-shard-astronauts-config52: Aborting 0 pending queued transactions
01:35:58,226 PM [test-shard-dispatcher-16] [INFO] Shard - Stopping Shard member-1-shard-shard2-config52
01:35:58,226 PM [test-shard-dispatcher-16] [DEBUG] MessageSlicer - member-1-shard-shard2-config52 (Leader)_slicer-id-169: Closing
01:35:58,226 PM [test-shard-dispatcher-16] [DEBUG] Shard - member-1-shard-shard2-config52: Aborting 0 pending queued transactions
01:35:58,226 PM [test-akka.actor.default-dispatcher-5] [INFO] ShardManager - Stopping ShardManager shard-manager-config52
01:35:58,229 PM [main] [INFO] ShardManagerTest - testWhenMultipleShardsPresentSyncStatusMustBeTrueForAllShards starting
01:35:58,233 PM [main] [INFO] ShardManager - Starting ShardManager shard-manager-config53
01:35:58,235 PM [test-akka.actor.default-dispatcher-5] [INFO] ShardManager - Recovery complete : shard-manager-config53
01:35:58,235 PM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - shard-manager-config53: Creating local shard: member-1-shard-default-config53
01:35:58,235 PM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - shard-manager-config53: Creating local shard: member-1-shard-astronauts-config53
01:35:58,334 PM [main] [INFO] ShardManager - shard-manager-config53: Received role changed for member-1-shard-default-config53 from Follower to Leader
01:35:58,334 PM [main] [INFO] ShardManager - shard-manager-config53: Received role changed for member-1-shard-astronauts-config53 from Follower to Leader
01:35:58,334 PM [main] [INFO] ShardManager - shard-manager-config53: Received role changed for member-1-shard-astronauts-config53 from Leader to Follower
01:35:58,334 PM [main] [INFO] ShardManager - shard-manager-config53 Received follower initial sync status for member-1-shard-astronauts-config53 status sync done true
01:35:58,334 PM [main] [INFO] ShardManagerTest - testWhenMultipleShardsPresentSyncStatusMustBeTrueForAllShards ending
01:35:58,436 PM [main] [INFO] TestActorFactory - Killing actor TestActor[akka://test/user/$$o]
01:35:58,446 PM [main] [INFO] ShardManager - Stopping ShardManager shard-manager-config53
01:35:58,449 PM [main] [INFO] ShardManagerTest - testAddShardReplicaWithFindPrimaryTimeout starting
01:35:58,455 PM [test-akka.actor.default-dispatcher-23] [INFO] ShardManager - Starting ShardManager shard-manager-config54
01:35:58,456 PM [test-akka.actor.default-dispatcher-5] [INFO] ShardManager - Recovery complete : shard-manager-config54
01:35:58,465 PM [test-akka.actor.default-dispatcher-23] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1
01:35:58,465 PM [test-akka.actor.default-dispatcher-23] [INFO] ShardManager - shard-manager-config54: Received MemberUp: memberName: MemberName{name=member-2}, address: akka://non-existent@127.0.0.1:5
01:35:58,465 PM [test-akka.actor.default-dispatcher-23] [INFO] ShardManager - shard-manager-config54: All Shards are ready - data store config54 is ready
01:35:58,465 PM [test-akka.actor.default-dispatcher-23] [DEBUG] ShardManager - shard-manager-config54: onAddShardReplica: AddShardReplica[ShardName=astronauts]
01:35:58,466 PM [test-akka.actor.default-dispatcher-23] [DEBUG] ShardManager - shard-manager-config54: In findPrimary: org.opendaylight.controller.cluster.datastore.messages.FindPrimary [shardName=astronauts, waitUntilReady=true]
01:35:58,466 PM [test-akka.actor.default-dispatcher-23] [DEBUG] ShardManager - shard-manager-config54: findPrimary for astronauts forwarding to remote ShardManager akka://non-existent@127.0.0.1:5/user/shardmanager-config54, visitedAddresses: [akka://test@127.0.0.1:2550/user/shardmanager-config54]
01:35:58,478 PM [test-akka.actor.default-dispatcher-23] [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
01:35:58,479 PM [test-akka.actor.default-dispatcher-23] [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
01:35:58,677 PM [test-akka.actor.default-dispatcher-23] [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#1232571318]] after [200 ms]. Message of type [org.opendaylight.controller.cluster.datastore.messages.FindPrimary]. A typical reason for `AskTimeoutException` is that the recipient actor didn't send a reply.
01:35:58,677 PM [main] [INFO] ShardManagerTest - testAddShardReplicaWithFindPrimaryTimeout ending
01:35:58,779 PM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/shardmanager-config54#1232571318]
01:35:58,789 PM [test-akka.actor.default-dispatcher-23] [INFO] ShardManager - Stopping ShardManager shard-manager-config54
01:35:58,792 PM [main] [INFO] ShardManagerTest - testOnCreateShard starting
01:35:58,795 PM [test-akka.actor.default-dispatcher-23] [INFO] ShardManager - Starting ShardManager shard-manager-config55
01:35:58,796 PM [test-akka.actor.default-dispatcher-5] [INFO] ShardManager - Recovery complete : shard-manager-config55
01:35:58,796 PM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - Got updated SchemaContext: # of modules 1
01:35:58,805 PM [test-akka.actor.default-dispatcher-23] [DEBUG] ShardManager - shard-manager-config55: onCreateShard: CreateShard [moduleShardConfig=ModuleShardConfiguration [namespace=foo-ns, moduleName=foo-module, shardName=foo, shardMemberNames=[MemberName{name=member-1}, MemberName{name=member-5}, MemberName{name=member-6}], shardStrategyName=null], shardPropsCreator=org.opendaylight.controller.cluster.datastore.Shard$Builder@7c4594e8]
01:35:58,806 PM [test-akka.actor.default-dispatcher-23] [DEBUG] ShardManager - shard-manager-config55 doCreateShard: shardId: member-1-shard-foo-config55, memberNames: [MemberName{name=member-1}, MemberName{name=member-5}, MemberName{name=member-6}], peerAddresses: {member-6-shard-foo-config55=null, member-5-shard-foo-config55=null}, isActiveMember: true
01:35:58,806 PM [test-akka.actor.default-dispatcher-23] [DEBUG] ShardManager - shard-manager-config55: findLocalShard : foo
01:35:58,806 PM [test-akka.actor.default-dispatcher-23] [DEBUG] ShardManager - shard-manager-config55: Scheduling 300000 ms timer to wait for shard ShardInformation [shardId=member-1-shard-foo-config55, leaderAvailable=false, actorInitialized=false, followerSyncStatus=false, role=null, leaderId=null, activeMember=true]
01:35:58,807 PM [test-shard-dispatcher-16] [INFO] Shard - Shard created : member-1-shard-foo-config55, persistent : false
01:35:58,808 PM [test-akka.actor.default-dispatcher-23] [INFO] RoleChangeNotifier - RoleChangeNotifier:akka://test@127.0.0.1:2565/user/$C/member-1-shard-foo-config55/member-1-shard-foo-config55-notifier#698394344 created and ready for shard:member-1-shard-foo-config55
01:35:58,808 PM [test-akka.actor.default-dispatcher-23] [DEBUG] ShardSnapshotActor - Actor created Actor[akka://test/user/$C/member-1-shard-foo-config55/shard-member-1:snapshot-read#-38958386]
01:35:58,809 PM [test-shard-dispatcher-16] [INFO] Shard - Starting recovery for member-1-shard-foo-config55 with journal batch size 1
01:35:58,811 PM [test-shard-dispatcher-16] [DEBUG] Shard - member-1-shard-foo-config55: onReceiveRecover: Received message class akka.persistence.RecoveryCompleted$ from Actor[akka://test/deadLetters]
01:35:58,812 PM [test-shard-dispatcher-16] [INFO] Shard - member-1-shard-foo-config55: Recovery completed  - Switching actor to Follower - last log index = -1, last log term = -1, snapshot index = -1, snapshot term = -1, journal size = 0
01:35:58,812 PM [test-shard-dispatcher-16] [DEBUG] DataTreeChangeListenerSupport - member-1-shard-foo-config55: onLeadershipChange, isLeader: false, hasLeader : false
01:35:58,812 PM [test-shard-dispatcher-16] [DEBUG] Shard - member-1-shard-foo-config55: onStateChanged: Closing all transaction chains because shard member-1-shard-foo-config55 is no longer the leader
01:35:58,812 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardManager - shard-manager-config55: Initializing shard [foo]
01:35:58,812 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardInformation - Shard member-1-shard-foo-config55 is initialized
01:35:58,812 PM [test-akka.actor.default-dispatcher-11] [DEBUG] ShardInformation - Shard member-1-shard-foo-config55 is initialized - notifying 1 OnShardInitialized callbacks
01:35:58,812 PM [test-akka.actor.default-dispatcher-11] [INFO] RoleChangeNotifier - RoleChangeNotifier for member-1-shard-foo-config55 , received role change from null to Follower
01:35:58,812 PM [test-akka.actor.default-dispatcher-11] [INFO] RoleChangeNotifier - RoleChangeNotifier for member-1-shard-foo-config55 , registered listener akka://test/user/$C
01:35:58,812 PM [test-akka.actor.default-dispatcher-11] [INFO] ShardManager - shard-manager-config55: Received role changed for member-1-shard-foo-config55 from null to Follower
01:35:58,812 PM [test-akka.actor.default-dispatcher-5] [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@7c4594e8]
01:35:58,812 PM [test-akka.actor.default-dispatcher-5] [DEBUG] ShardManager - shard-manager-config55: Shard foo already exists
01:35:58,813 PM [main] [INFO] ShardManagerTest - testOnCreateShard ending
01:35:58,914 PM [main] [INFO] TestActorFactory - Killing actor Actor[akka://test/user/$C#530138518]
01:35:58,925 PM [test-shard-dispatcher-16] [INFO] Shard - Stopping Shard member-1-shard-foo-config55
01:35:58,925 PM [test-shard-dispatcher-16] [DEBUG] MessageAssembler - member-1-shard-foo-config55 (Follower): Closing
01:35:58,925 PM [test-shard-dispatcher-16] [DEBUG] Shard - member-1-shard-foo-config55: Aborting 0 pending queued transactions
01:35:58,926 PM [test-akka.actor.default-dispatcher-19] [INFO] ShardManager - Stopping ShardManager shard-manager-config55
01:35:58,927 PM [test-akka.actor.default-dispatcher-19] [INFO] ShardManager - Stopping ShardManager shard-manager-config1
01:35:58,927 PM [test-akka.actor.default-dispatcher-19] [INFO] ShardManager - Stopping ShardManager shard-manager-config35
01:35:58,927 PM [test-akka.actor.default-dispatcher-19] [INFO] ShardManager - Stopping ShardManager shard-manager-config43
01:35:58,928 PM [test-akka.actor.default-dispatcher-19] [INFO] ShardManager - Stopping ShardManager shard-manager-config11
01:35:58,928 PM [test-akka.actor.default-dispatcher-19] [INFO] ShardManager - Stopping ShardManager shard-manager-config21
01:35:58,928 PM [test-akka.actor.default-dispatcher-19] [INFO] ShardManager - Stopping ShardManager shard-manager-config46
01:35:58,930 PM [test-akka.actor.default-dispatcher-5] [INFO] RemoteActorRefProvider$RemotingTerminator - Shutting down remote daemon.
01:35:58,930 PM [test-akka.actor.default-dispatcher-5] [INFO] RemoteActorRefProvider$RemotingTerminator - Remote daemon shut down; proceeding with flushing remote transports.
01:35:58,933 PM [test-akka.actor.default-dispatcher-5] [INFO] RemoteActorRefProvider$RemotingTerminator - Remoting shut down.
[WARN] [03/11/2024 13:35:58.940] [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