[DEBUG] [07/02/2025 00:00:41.667] [main] [EventStream(pekko://test)] logger log1-TestEventListener started 12:00:41,667 AM [test-pekko.actor.default-dispatcher-6] [INFO] Slf4jLogger - Slf4jLogger started [DEBUG] [07/02/2025 00:00:41.667] [main] [EventStream(pekko://test)] logger log2-Slf4jLogger started [DEBUG] [07/02/2025 00:00:41.667] [main] [EventStream(pekko://test)] Default Loggers started [INFO] [07/02/2025 00:00:41.683] [main] [ArteryTransport(pekko://test)] Remoting started with transport [Artery tcp]; listening on address [pekko://test@10.30.171.227:17355] with UID [6238419423470955746] 12:00:41,684 AM [test-pekko.actor.default-dispatcher-6] [INFO] ArteryTransport - Remoting started with transport [Artery tcp]; listening on address [pekko://test@10.30.171.227:17355] with UID [6238419423470955746] [INFO] [07/02/2025 00:00:41.684] [main] [Cluster(pekko://test)] Cluster Node [pekko://test@10.30.171.227:17355] - Starting up, Pekko version [1.0.3] ... 12:00:41,684 AM [test-pekko.actor.default-dispatcher-7] [INFO] Cluster - Cluster Node [pekko://test@10.30.171.227:17355] - Starting up, Pekko version [1.0.3] ... 12:00:41,686 AM [test-pekko.actor.default-dispatcher-7] [INFO] Cluster - Cluster Node [pekko://test@10.30.171.227:17355] - Registered cluster JMX MBean [pekko:type=Cluster] 12:00:41,686 AM [test-pekko.actor.default-dispatcher-7] [INFO] Cluster - Cluster Node [pekko://test@10.30.171.227:17355] - Started up successfully [INFO] [07/02/2025 00:00:41.686] [main] [Cluster(pekko://test)] Cluster Node [pekko://test@10.30.171.227:17355] - Registered cluster JMX MBean [pekko:type=Cluster] [INFO] [07/02/2025 00:00:41.686] [main] [Cluster(pekko://test)] Cluster Node [pekko://test@10.30.171.227:17355] - Started up successfully 12:00:41,686 AM [test-pekko.actor.default-dispatcher-7] [INFO] Cluster - Cluster Node [pekko://test@10.30.171.227:17355] - No downing-provider-class configured, manual cluster downing required, see https://pekko.apache.org/docs/pekko/current/typed/cluster.html#downing 12:00:41,687 AM [test-pekko.actor.default-dispatcher-7] [INFO] Cluster - Cluster Node [pekko://test@10.30.171.227:17355] - No seed-nodes configured, manual cluster join required, see https://pekko.apache.org/docs/pekko/current/typed/cluster.html#joining [INFO] [07/02/2025 00:00:41.686] [test-pekko.actor.internal-dispatcher-3] [Cluster(pekko://test)] Cluster Node [pekko://test@10.30.171.227:17355] - No downing-provider-class configured, manual cluster downing required, see https://pekko.apache.org/docs/pekko/current/typed/cluster.html#downing [INFO] [07/02/2025 00:00:41.686] [test-pekko.actor.internal-dispatcher-3] [Cluster(pekko://test)] Cluster Node [pekko://test@10.30.171.227:17355] - No seed-nodes configured, manual cluster join required, see https://pekko.apache.org/docs/pekko/current/typed/cluster.html#joining 12:00:41,697 AM [main] [INFO] RaftActorTest - testRestoreFromSnapshotWithRecoveredData starting [WARN] [07/02/2025 00:00:41.699] [test-pekko.actor.default-dispatcher-6] [pekko://test/user/termination-monitor] received dead letter from TestActor[pekko://test/user/test-actor-247]: org.opendaylight.controller.cluster.common.actor.Monitor@442f55b4 12:00:41,699 AM [test-pekko.actor.default-dispatcher-7] [INFO] EmptyLocalActorRef - pekkoDeadLetter Message [org.opendaylight.controller.cluster.common.actor.Monitor] from TestActor[pekko://test/user/test-actor-247] to Actor[pekko://test/user/termination-monitor] was not delivered. [1] dead letters encountered. If this is not an expected behavior then Actor[pekko://test/user/termination-monitor] may have terminated unexpectedly. This logging can be turned off or adjusted with configuration settings 'pekko.log-dead-letters' and 'pekko.log-dead-letters-during-shutdown'. [INFO] [pekkoDeadLetter][07/02/2025 00:00:41.699] [test-pekko.actor.default-dispatcher-7] [pekko://test/user/termination-monitor] Message [org.opendaylight.controller.cluster.common.actor.Monitor] from TestActor[pekko://test/user/test-actor-247] to Actor[pekko://test/user/termination-monitor] was not delivered. [1] dead letters encountered. If this is not an expected behavior then Actor[pekko://test/user/termination-monitor] may have terminated unexpectedly. This logging can be turned off or adjusted with configuration settings 'pekko.log-dead-letters' and 'pekko.log-dead-letters-during-shutdown'. 12:00:41,705 AM [test-pekko.actor.default-dispatcher-12] [INFO] RaftActor - test-actor-247: Starting recovery with journal batch size 1000 12:00:41,705 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] RaftStorage - test-actor-247: started executor 12:00:41,705 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] RaftStorage - test-actor-247: started executor 12:00:41,706 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] EntryJournalV1 - test-actor-247: metadata journal open: replayFrom=1 applyTo=0 12:00:41,706 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] EntryJournalV1 - test-actor-247: journal open: firstIndex=1 lastIndex=0 replayFrom=1 fileEntries=0 12:00:41,707 AM [test-pekko.actor.default-dispatcher-12] [INFO] PekkoRaftStorage - test-actor-247: journal open: applyTo=0 12:00:41,707 AM [test-actor-247-writer-100] [DEBUG] JournalWriteTask - test-actor-247: journal writer started 12:00:41,707 AM [test-actor-247-writer-100] [DEBUG] JournalWriteTask - test-actor-247: waiting to receive commands 12:00:41,709 AM [test-pekko.actor.default-dispatcher-11] [DEBUG] PropertiesTermInfoStore - /tmp/org.opendaylight.controller.cluster.raft.RaftActorTest13404562414697766041/test-actor-247/TermInfo.properties does not exist 12:00:41,709 AM [test-pekko.actor.default-dispatcher-11] [DEBUG] RaftStorage - test-actor-247: skipping unrecognized file /tmp/org.opendaylight.controller.cluster.raft.RaftActorTest13404562414697766041/test-actor-247/journal-v1-1.log 12:00:41,709 AM [test-pekko.actor.default-dispatcher-11] [DEBUG] RaftStorage - test-actor-247: skipping unrecognized file /tmp/org.opendaylight.controller.cluster.raft.RaftActorTest13404562414697766041/test-actor-247/metadata-v1-1.log 12:00:41,709 AM [test-pekko.actor.default-dispatcher-11] [DEBUG] RaftStorage - test-actor-247: no eligible files found 12:00:41,709 AM [test-pekko.actor.default-dispatcher-11] [DEBUG] PekkoRecovery - test-actor-247: Received ReplicatedLogEntry for recovery: index: 0, size: 1 12:00:41,709 AM [test-pekko.actor.default-dispatcher-11] [INFO] PekkoRecovery - test-actor-247: Recovery completed - Switching actor to Follower - last log index = 0, last log term = 1, snapshot index = -1, snapshot term = -1, journal size = 1 12:00:41,711 AM [test-pekko.actor.default-dispatcher-11] [DEBUG] PropertiesTermInfoStore - test-actor-247: Set currentTerm=0, votedFor=null 12:00:41,711 AM [test-pekko.actor.default-dispatcher-11] [INFO] PekkoRecovery - test-actor-247: Local TermInfo store seeded with TermInfo{term=0} 12:00:41,711 AM [test-pekko.actor.default-dispatcher-11] [WARN] PekkoRecovery - test-actor-247: The provided restore snapshot was not applied because the persistence store is not empty 12:00:41,711 AM [test-pekko.actor.default-dispatcher-11] [DEBUG] RaftActor - test-actor-247: Pekko recovery completed with org.opendaylight.controller.cluster.raft.RecoveryLog@6c9ec5fc 12:00:41,711 AM [test-pekko.actor.default-dispatcher-11] [DEBUG] AbstractReplicatedLog - test-actor-247: Moving last applied index from -1 to -1 12:00:41,711 AM [test-pekko.actor.default-dispatcher-11] [DEBUG] JournalRecovery - test-actor-247: empty journal: appending 1 entries 12:00:41,712 AM [test-pekko.actor.default-dispatcher-11] [DEBUG] EntryJournalV1 - test-actor-247: updated meta to JournalMeta[replayFrom=1, applyTo=0] 12:00:41,715 AM [test-pekko.actor.default-dispatcher-11] [DEBUG] JournalRecovery - test-actor-247: journal recovery completedin 4.115 ms with journalIndex=1 12:00:41,716 AM [test-pekko.actor.default-dispatcher-11] [INFO] DefaultConfigParamsImpl - Trying to use custom RaftPolicy org.opendaylight.controller.cluster.raft.policy.DisableElectionsRaftPolicy 12:00:42,217 AM [main] [INFO] RaftActorTest - testRestoreFromSnapshotWithRecoveredData ending 12:00:42,217 AM [main] [INFO] TestActorFactory - Killing actor TestActor[pekko://test/user/test-actor-247] 12:00:42,228 AM [test-pekko.actor.default-dispatcher-11] [DEBUG] PekkoRaftStorage - test-actor-247: terminating thread VirtualThread[#674,test-actor-247-writer-100]/waiting 12:00:42,229 AM [test-actor-247-writer-100] [DEBUG] JournalWriteTask - test-actor-247: received 1 commands after 521.9 ms 12:00:42,229 AM [test-actor-247-writer-100] [DEBUG] JournalWriteTask - test-actor-247: completed 1 commands in 14.63 μs 12:00:42,229 AM [test-actor-247-writer-100] [DEBUG] JournalWriteTask - test-actor-247: journal writer stopped 12:00:42,229 AM [test-pekko.actor.default-dispatcher-11] [DEBUG] EntryJournalV1 - test-actor-247: journal closed 12:00:42,229 AM [test-pekko.actor.default-dispatcher-11] [INFO] PekkoRaftStorage - test-actor-247: journal closed 12:00:42,229 AM [test-pekko.actor.default-dispatcher-11] [DEBUG] RaftStorage - test-actor-247: stopped executor with 0 remaining tasks 12:00:42,229 AM [test-pekko.actor.default-dispatcher-11] [DEBUG] RaftStorage - test-actor-247: stopped executor with 0 remaining tasks [WARN] [07/02/2025 00:00:42.233] [test-pekko.actor.default-dispatcher-11] [pekko://test/user/termination-monitor] received dead letter from TestActor[pekko://test/user/leader-248]: org.opendaylight.controller.cluster.common.actor.Monitor@7c6a4a12 [INFO] [pekkoDeadLetter][07/02/2025 00:00:42.233] [test-pekko.actor.default-dispatcher-12] [pekko://test/user/termination-monitor] Message [org.opendaylight.controller.cluster.common.actor.Monitor] from TestActor[pekko://test/user/leader-248] to Actor[pekko://test/user/termination-monitor] was not delivered. [2] dead letters encountered. If this is not an expected behavior then Actor[pekko://test/user/termination-monitor] may have terminated unexpectedly. This logging can be turned off or adjusted with configuration settings 'pekko.log-dead-letters' and 'pekko.log-dead-letters-during-shutdown'. 12:00:42,233 AM [test-pekko.actor.default-dispatcher-12] [INFO] EmptyLocalActorRef - pekkoDeadLetter Message [org.opendaylight.controller.cluster.common.actor.Monitor] from TestActor[pekko://test/user/leader-248] to Actor[pekko://test/user/termination-monitor] was not delivered. [2] dead letters encountered. If this is not an expected behavior then Actor[pekko://test/user/termination-monitor] may have terminated unexpectedly. This logging can be turned off or adjusted with configuration settings 'pekko.log-dead-letters' and 'pekko.log-dead-letters-during-shutdown'. 12:00:42,235 AM [main] [INFO] RaftActor - leader-248: Starting recovery with journal batch size 1000 12:00:42,235 AM [main] [DEBUG] RaftStorage - leader-248: started executor 12:00:42,235 AM [main] [DEBUG] RaftStorage - leader-248: started executor 12:00:42,236 AM [main] [DEBUG] EntryJournalV1 - leader-248: metadata journal open: replayFrom=1 applyTo=0 12:00:42,236 AM [main] [DEBUG] EntryJournalV1 - leader-248: journal open: firstIndex=1 lastIndex=0 replayFrom=1 fileEntries=0 12:00:42,236 AM [main] [INFO] PekkoRaftStorage - leader-248: journal open: applyTo=0 12:00:42,236 AM [leader-248-writer-101] [DEBUG] JournalWriteTask - leader-248: journal writer started 12:00:42,236 AM [leader-248-writer-101] [DEBUG] JournalWriteTask - leader-248: waiting to receive commands 12:00:42,238 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] PropertiesTermInfoStore - /tmp/org.opendaylight.controller.cluster.raft.RaftActorTest16900861572607933219/leader-248/TermInfo.properties does not exist 12:00:42,238 AM [test-pekko.actor.default-dispatcher-12] [INFO] PekkoRecovery - leader-248: Recovery completed - Switching actor to Follower - last log index = -1, last log term = -1, snapshot index = -1, snapshot term = -1, journal size = 0 12:00:42,241 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] PropertiesTermInfoStore - leader-248: Set currentTerm=0, votedFor=null 12:00:42,241 AM [test-pekko.actor.default-dispatcher-12] [INFO] PekkoRecovery - leader-248: Local TermInfo store seeded with TermInfo{term=0} 12:00:42,241 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] RaftActor - leader-248: Pekko recovery completed with org.opendaylight.controller.cluster.raft.RecoveryLog@5317aed2 12:00:42,242 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] DefaultConfigParamsImpl - No custom RaftPolicy specified. Using DefaultRaftPolicy 12:00:42,242 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] Follower - leader-248 (Follower): Received TimeoutNow - switching to Candidate 12:00:42,242 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] Candidate - leader-248 (Candidate): Election: Candidate has following voting peers: [] 12:00:42,245 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] PropertiesTermInfoStore - leader-248: Set currentTerm=1, votedFor=leader-248 12:00:42,245 AM [test-pekko.actor.default-dispatcher-12] [INFO] Candidate - leader-248 (Candidate): Starting new election term 1 12:00:42,245 AM [test-pekko.actor.default-dispatcher-12] [INFO] RaftActorBehavior - leader-248 (Follower) :- Switching from behavior Follower to Candidate, election term: 1 12:00:42,245 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] Candidate - leader-248 (Candidate): Received ElectionTimeout 12:00:42,245 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] AbstractLeader - leader-248 (Leader): Election: Leader has following peers: [] 12:00:42,246 AM [test-pekko.actor.default-dispatcher-12] [INFO] RaftActorBehavior - leader-248 (Candidate) :- Switching from behavior Candidate to Leader, election term: 1 12:00:42,342 AM [main] [INFO] TestActorFactory - Killing actor TestActor[pekko://test/user/leader-248] 12:00:42,353 AM [main] [DEBUG] PekkoRaftStorage - leader-248: terminating thread VirtualThread[#675,leader-248-writer-101]/waiting 12:00:42,353 AM [leader-248-writer-101] [DEBUG] JournalWriteTask - leader-248: received 1 commands after 116.4 ms 12:00:42,353 AM [leader-248-writer-101] [DEBUG] JournalWriteTask - leader-248: completed 1 commands in 14.38 μs 12:00:42,353 AM [leader-248-writer-101] [DEBUG] JournalWriteTask - leader-248: journal writer stopped 12:00:42,353 AM [main] [DEBUG] EntryJournalV1 - leader-248: journal closed 12:00:42,353 AM [main] [INFO] PekkoRaftStorage - leader-248: journal closed 12:00:42,353 AM [main] [DEBUG] RaftStorage - leader-248: stopped executor with 0 remaining tasks 12:00:42,353 AM [main] [DEBUG] RaftStorage - leader-248: stopped executor with 0 remaining tasks [WARN] [07/02/2025 00:00:42.357] [test-pekko.actor.default-dispatcher-6] [pekko://test/user/termination-monitor] received dead letter from Actor[pekko://test/user/testFindLeader#1638003551]: org.opendaylight.controller.cluster.common.actor.Monitor@15bfb823 [INFO] [pekkoDeadLetter][07/02/2025 00:00:42.357] [test-pekko.actor.default-dispatcher-11] [pekko://test/user/termination-monitor] Message [org.opendaylight.controller.cluster.common.actor.Monitor] from Actor[pekko://test/user/testFindLeader#1638003551] to Actor[pekko://test/user/termination-monitor] was not delivered. [3] dead letters encountered. If this is not an expected behavior then Actor[pekko://test/user/termination-monitor] may have terminated unexpectedly. This logging can be turned off or adjusted with configuration settings 'pekko.log-dead-letters' and 'pekko.log-dead-letters-during-shutdown'. 12:00:42,357 AM [test-pekko.actor.default-dispatcher-6] [INFO] EmptyLocalActorRef - pekkoDeadLetter Message [org.opendaylight.controller.cluster.common.actor.Monitor] from Actor[pekko://test/user/testFindLeader#1638003551] to Actor[pekko://test/user/termination-monitor] was not delivered. [3] dead letters encountered. If this is not an expected behavior then Actor[pekko://test/user/termination-monitor] may have terminated unexpectedly. This logging can be turned off or adjusted with configuration settings 'pekko.log-dead-letters' and 'pekko.log-dead-letters-during-shutdown'. 12:00:42,358 AM [test-pekko.actor.default-dispatcher-12] [INFO] RaftActor - testFindLeader: Starting recovery with journal batch size 1000 12:00:42,358 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] RaftStorage - testFindLeader: started executor 12:00:42,358 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] RaftStorage - testFindLeader: started executor 12:00:42,359 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] EntryJournalV1 - testFindLeader: metadata journal open: replayFrom=1 applyTo=0 12:00:42,360 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] EntryJournalV1 - testFindLeader: journal open: firstIndex=1 lastIndex=0 replayFrom=1 fileEntries=0 12:00:42,360 AM [test-pekko.actor.default-dispatcher-12] [INFO] PekkoRaftStorage - testFindLeader: journal open: applyTo=0 12:00:42,360 AM [testFindLeader-writer-102] [DEBUG] JournalWriteTask - testFindLeader: journal writer started 12:00:42,360 AM [testFindLeader-writer-102] [DEBUG] JournalWriteTask - testFindLeader: waiting to receive commands 12:00:42,361 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] PropertiesTermInfoStore - /tmp/org.opendaylight.controller.cluster.raft.RaftActorTest4648390659380461680/testFindLeader/TermInfo.properties does not exist 12:00:42,361 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] RaftStorage - testFindLeader: skipping unrecognized file /tmp/org.opendaylight.controller.cluster.raft.RaftActorTest4648390659380461680/testFindLeader/journal-v1-1.log 12:00:42,361 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] RaftStorage - testFindLeader: skipping unrecognized file /tmp/org.opendaylight.controller.cluster.raft.RaftActorTest4648390659380461680/testFindLeader/metadata-v1-1.log 12:00:42,361 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] RaftStorage - testFindLeader: no eligible files found 12:00:42,361 AM [test-pekko.actor.default-dispatcher-12] [INFO] PekkoRecovery - testFindLeader: Recovery completed - Switching actor to Follower - last log index = -1, last log term = -1, snapshot index = -1, snapshot term = -1, journal size = 0 12:00:42,364 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] PropertiesTermInfoStore - testFindLeader: Set currentTerm=0, votedFor=null 12:00:42,364 AM [test-pekko.actor.default-dispatcher-12] [INFO] PekkoRecovery - testFindLeader: Local TermInfo store seeded with TermInfo{term=0} 12:00:42,364 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] RaftActor - testFindLeader: Pekko recovery completed with org.opendaylight.controller.cluster.raft.RecoveryLog@13801920 12:00:42,364 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] AbstractReplicatedLog - testFindLeader: Moving last applied index from -1 to -1 12:00:42,364 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] JournalRecovery - testFindLeader: empty journal: appending 0 entries 12:00:42,364 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] EntryJournalV1 - testFindLeader: updated meta to JournalMeta[replayFrom=1, applyTo=0] 12:00:42,364 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] JournalRecovery - testFindLeader: journal recovery completedin 323.2 μs with journalIndex=1 12:00:42,365 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] DefaultConfigParamsImpl - No custom RaftPolicy specified. Using DefaultRaftPolicy 12:00:42,365 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] Follower - testFindLeader (Follower): Received TimeoutNow - switching to Candidate 12:00:42,365 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] Candidate - testFindLeader (Candidate): Election: Candidate has following voting peers: [] 12:00:42,367 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] PropertiesTermInfoStore - testFindLeader: Set currentTerm=1, votedFor=testFindLeader 12:00:42,367 AM [test-pekko.actor.default-dispatcher-12] [INFO] Candidate - testFindLeader (Candidate): Starting new election term 1 12:00:42,367 AM [test-pekko.actor.default-dispatcher-12] [INFO] RaftActorBehavior - testFindLeader (Follower) :- Switching from behavior Follower to Candidate, election term: 1 12:00:42,367 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] Candidate - testFindLeader (Candidate): Received ElectionTimeout 12:00:42,367 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] AbstractLeader - testFindLeader (Leader): Election: Leader has following peers: [] 12:00:42,367 AM [test-pekko.actor.default-dispatcher-12] [INFO] RaftActorBehavior - testFindLeader (Candidate) :- Switching from behavior Candidate to Leader, election term: 1 12:00:42,417 AM [main] [INFO] RaftActorTest - testLeaderTransitioning starting 12:00:42,419 AM [test-pekko.actor.default-dispatcher-11] [INFO] EmptyLocalActorRef - pekkoDeadLetter Message [org.opendaylight.controller.cluster.common.actor.Monitor] from TestActor[pekko://test/user/test-actor-249] to Actor[pekko://test/user/termination-monitor] was not delivered. [4] dead letters encountered. If this is not an expected behavior then Actor[pekko://test/user/termination-monitor] may have terminated unexpectedly. This logging can be turned off or adjusted with configuration settings 'pekko.log-dead-letters' and 'pekko.log-dead-letters-during-shutdown'. [WARN] [07/02/2025 00:00:42.418] [test-pekko.actor.default-dispatcher-6] [pekko://test/user/termination-monitor] received dead letter from TestActor[pekko://test/user/test-actor-249]: org.opendaylight.controller.cluster.common.actor.Monitor@2beaaf1 [INFO] [pekkoDeadLetter][07/02/2025 00:00:42.418] [test-pekko.actor.default-dispatcher-11] [pekko://test/user/termination-monitor] Message [org.opendaylight.controller.cluster.common.actor.Monitor] from TestActor[pekko://test/user/test-actor-249] to Actor[pekko://test/user/termination-monitor] was not delivered. [4] dead letters encountered. If this is not an expected behavior then Actor[pekko://test/user/termination-monitor] may have terminated unexpectedly. This logging can be turned off or adjusted with configuration settings 'pekko.log-dead-letters' and 'pekko.log-dead-letters-during-shutdown'. 12:00:42,419 AM [test-pekko.actor.default-dispatcher-12] [INFO] RaftActor - test-actor-249: Starting recovery with journal batch size 1000 12:00:42,419 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] RaftStorage - test-actor-249: started executor 12:00:42,420 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] RaftStorage - test-actor-249: started executor 12:00:42,420 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] EntryJournalV1 - test-actor-249: metadata journal open: replayFrom=1 applyTo=0 12:00:42,421 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] EntryJournalV1 - test-actor-249: journal open: firstIndex=1 lastIndex=0 replayFrom=1 fileEntries=0 12:00:42,421 AM [test-pekko.actor.default-dispatcher-12] [INFO] PekkoRaftStorage - test-actor-249: journal open: applyTo=0 12:00:42,421 AM [test-actor-249-writer-103] [DEBUG] JournalWriteTask - test-actor-249: journal writer started 12:00:42,421 AM [test-actor-249-writer-103] [DEBUG] JournalWriteTask - test-actor-249: waiting to receive commands 12:00:42,422 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] PropertiesTermInfoStore - /tmp/org.opendaylight.controller.cluster.raft.RaftActorTest12133462360094852691/test-actor-249/TermInfo.properties does not exist 12:00:42,422 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] RaftStorage - test-actor-249: skipping unrecognized file /tmp/org.opendaylight.controller.cluster.raft.RaftActorTest12133462360094852691/test-actor-249/journal-v1-1.log 12:00:42,422 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] RaftStorage - test-actor-249: skipping unrecognized file /tmp/org.opendaylight.controller.cluster.raft.RaftActorTest12133462360094852691/test-actor-249/metadata-v1-1.log 12:00:42,422 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] RaftStorage - test-actor-249: no eligible files found 12:00:42,422 AM [test-pekko.actor.default-dispatcher-12] [INFO] PekkoRecovery - test-actor-249: Recovery completed - Switching actor to Follower - last log index = -1, last log term = -1, snapshot index = -1, snapshot term = -1, journal size = 0 12:00:42,425 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] PropertiesTermInfoStore - test-actor-249: Set currentTerm=0, votedFor=null 12:00:42,425 AM [test-pekko.actor.default-dispatcher-12] [INFO] PekkoRecovery - test-actor-249: Local TermInfo store seeded with TermInfo{term=0} 12:00:42,425 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] RaftActor - test-actor-249: Pekko recovery completed with org.opendaylight.controller.cluster.raft.RecoveryLog@619ff41d 12:00:42,425 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] AbstractReplicatedLog - test-actor-249: Moving last applied index from -1 to -1 12:00:42,425 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] JournalRecovery - test-actor-249: empty journal: appending 0 entries 12:00:42,425 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] EntryJournalV1 - test-actor-249: updated meta to JournalMeta[replayFrom=1, applyTo=0] 12:00:42,425 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] JournalRecovery - test-actor-249: journal recovery completedin 438.0 μs with journalIndex=1 12:00:42,426 AM [test-pekko.actor.default-dispatcher-12] [INFO] DefaultConfigParamsImpl - Trying to use custom RaftPolicy org.opendaylight.controller.cluster.raft.policy.DisableElectionsRaftPolicy 12:00:42,426 AM [test-pekko.actor.default-dispatcher-12] [INFO] Follower - test-actor-249 (Follower): Term 1 in "AppendEntries{term=1, leaderId=leader, prevLogIndex=0, prevLogTerm=1, leaderCommit=0, replicatedToAllIndex=-1, payloadVersion=1, recipientRaftVersion=5, leaderRaftVersion=5, entries==[]}" message is greater than follower's term 0 - updating term 12:00:42,428 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] PropertiesTermInfoStore - test-actor-249: Set currentTerm=1, votedFor=null 12:00:42,428 AM [test-pekko.actor.default-dispatcher-12] [INFO] Follower - test-actor-249 (Follower): The followers log is empty and the senders prevLogIndex is 0 12:00:42,428 AM [test-pekko.actor.default-dispatcher-12] [INFO] Follower - test-actor-249 (Follower): Follower is out-of-sync so sending negative reply: AppendEntriesReply{term=1, success=false, followerId=test-actor-249, logLastIndex=-1, logLastTerm=-1, forceInstallSnapshot=false, needsLeaderAddress=true, payloadVersion=5, raftVersion=5, recipientRaftVersion=5} 12:00:42,428 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] SyncStatusTracker - test-actor-249: Last sync leader does not match current leader leader, need to catch up to 0 [WARN] [07/02/2025 00:00:42.429] [test-pekko.actor.default-dispatcher-11] [pekko://test/deadLetters] received dead letter from TestActor[pekko://test/user/test-actor-249]: AppendEntriesReply{term=1, success=false, followerId=test-actor-249, logLastIndex=-1, logLastTerm=-1, forceInstallSnapshot=false, needsLeaderAddress=true, payloadVersion=5, raftVersion=5, recipientRaftVersion=5} 12:00:42,429 AM [test-pekko.actor.default-dispatcher-7] [INFO] RemoteActorRefProvider$RemoteDeadLetterActorRef - pekkoDeadLetter Message [org.opendaylight.controller.cluster.raft.messages.AppendEntriesReply] from TestActor[pekko://test/user/test-actor-249] to Actor[pekko://test/deadLetters] was not delivered. [5] dead letters encountered. If this is not an expected behavior then Actor[pekko://test/deadLetters] may have terminated unexpectedly. This logging can be turned off or adjusted with configuration settings 'pekko.log-dead-letters' and 'pekko.log-dead-letters-during-shutdown'. [WARN] [07/02/2025 00:00:42.429] [test-pekko.actor.default-dispatcher-11] [pekko://test/user/test-actor-249] unhandled message from Actor[pekko://test/deadLetters]: FollowerInitialSyncUpStatus[memberId=test-actor-249, initialSyncDone=false] 12:00:42,429 AM [test-pekko.actor.default-dispatcher-7] [INFO] TestActorRef - pekkoDeadLetter Message [org.opendaylight.controller.cluster.raft.base.messages.FollowerInitialSyncUpStatus] to TestActor[pekko://test/user/test-actor-249] was unhandled. [6] dead letters encountered. This logging can be turned off or adjusted with configuration settings 'pekko.log-dead-letters' and 'pekko.log-dead-letters-during-shutdown'. [INFO] [pekkoDeadLetter][07/02/2025 00:00:42.429] [test-pekko.actor.default-dispatcher-6] [pekko://test/deadLetters] Message [org.opendaylight.controller.cluster.raft.messages.AppendEntriesReply] from TestActor[pekko://test/user/test-actor-249] to Actor[pekko://test/deadLetters] was not delivered. [5] dead letters encountered. If this is not an expected behavior then Actor[pekko://test/deadLetters] may have terminated unexpectedly. This logging can be turned off or adjusted with configuration settings 'pekko.log-dead-letters' and 'pekko.log-dead-letters-during-shutdown'. [INFO] [pekkoDeadLetter][07/02/2025 00:00:42.429] [test-pekko.actor.default-dispatcher-6] [pekko://test/user/test-actor-249] Message [org.opendaylight.controller.cluster.raft.base.messages.FollowerInitialSyncUpStatus] to TestActor[pekko://test/user/test-actor-249] was unhandled. [6] dead letters encountered. This logging can be turned off or adjusted with configuration settings 'pekko.log-dead-letters' and 'pekko.log-dead-letters-during-shutdown'. 12:00:42,477 AM [test-pekko.actor.default-dispatcher-11] [DEBUG] RaftActor - test-actor-249: onLeaderTransitioning: LeaderTransitioning [leaderId=leader] 12:00:42,527 AM [main] [INFO] RaftActorTest - testLeaderTransitioning ending 12:00:42,527 AM [main] [INFO] TestActorFactory - Killing actor Actor[pekko://test/user/$a#1597207639] 12:00:42,538 AM [main] [INFO] TestActorFactory - Killing actor TestActor[pekko://test/user/test-actor-249] 12:00:42,538 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] PekkoRaftStorage - test-actor-249: terminating thread VirtualThread[#677,test-actor-249-writer-103]/waiting 12:00:42,538 AM [test-actor-249-writer-103] [DEBUG] JournalWriteTask - test-actor-249: received 1 commands after 117.3 ms 12:00:42,538 AM [test-actor-249-writer-103] [DEBUG] JournalWriteTask - test-actor-249: completed 1 commands in 17.90 μs 12:00:42,538 AM [test-actor-249-writer-103] [DEBUG] JournalWriteTask - test-actor-249: journal writer stopped 12:00:42,539 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] EntryJournalV1 - test-actor-249: journal closed 12:00:42,539 AM [test-pekko.actor.default-dispatcher-12] [INFO] PekkoRaftStorage - test-actor-249: journal closed 12:00:42,539 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] RaftStorage - test-actor-249: stopped executor with 0 remaining tasks 12:00:42,539 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] RaftStorage - test-actor-249: stopped executor with 0 remaining tasks [WARN] [07/02/2025 00:00:42.542] [test-pekko.actor.default-dispatcher-11] [pekko://test/user/termination-monitor] received dead letter from Actor[pekko://test/user/$c#1752718950]: org.opendaylight.controller.cluster.common.actor.Monitor@5516a9be [INFO] [pekkoDeadLetter][07/02/2025 00:00:42.543] [test-pekko.actor.default-dispatcher-7] [pekko://test/user/termination-monitor] Message [org.opendaylight.controller.cluster.common.actor.Monitor] from Actor[pekko://test/user/$c#1752718950] to Actor[pekko://test/user/termination-monitor] was not delivered. [7] dead letters encountered. If this is not an expected behavior then Actor[pekko://test/user/termination-monitor] may have terminated unexpectedly. This logging can be turned off or adjusted with configuration settings 'pekko.log-dead-letters' and 'pekko.log-dead-letters-during-shutdown'. 12:00:42,543 AM [test-pekko.actor.default-dispatcher-11] [INFO] EmptyLocalActorRef - pekkoDeadLetter Message [org.opendaylight.controller.cluster.common.actor.Monitor] from Actor[pekko://test/user/$c#1752718950] to Actor[pekko://test/user/termination-monitor] was not delivered. [7] dead letters encountered. If this is not an expected behavior then Actor[pekko://test/user/termination-monitor] may have terminated unexpectedly. This logging can be turned off or adjusted with configuration settings 'pekko.log-dead-letters' and 'pekko.log-dead-letters-during-shutdown'. 12:00:42,544 AM [test-pekko.actor.default-dispatcher-12] [INFO] RaftActor - notifier-250: Starting recovery with journal batch size 1000 12:00:42,544 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] RaftStorage - notifier-250: started executor 12:00:42,544 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] RaftStorage - notifier-250: started executor 12:00:42,545 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] EntryJournalV1 - notifier-250: metadata journal open: replayFrom=1 applyTo=0 12:00:42,545 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] EntryJournalV1 - notifier-250: journal open: firstIndex=1 lastIndex=0 replayFrom=1 fileEntries=0 12:00:42,545 AM [test-pekko.actor.default-dispatcher-12] [INFO] PekkoRaftStorage - notifier-250: journal open: applyTo=0 12:00:42,545 AM [notifier-250-writer-104] [DEBUG] JournalWriteTask - notifier-250: journal writer started 12:00:42,545 AM [notifier-250-writer-104] [DEBUG] JournalWriteTask - notifier-250: waiting to receive commands 12:00:42,546 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] PropertiesTermInfoStore - /tmp/org.opendaylight.controller.cluster.raft.RaftActorTest15419641179275083508/notifier-250/TermInfo.properties does not exist 12:00:42,547 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] RaftStorage - notifier-250: skipping unrecognized file /tmp/org.opendaylight.controller.cluster.raft.RaftActorTest15419641179275083508/notifier-250/journal-v1-1.log 12:00:42,547 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] RaftStorage - notifier-250: skipping unrecognized file /tmp/org.opendaylight.controller.cluster.raft.RaftActorTest15419641179275083508/notifier-250/metadata-v1-1.log 12:00:42,547 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] RaftStorage - notifier-250: no eligible files found 12:00:42,547 AM [test-pekko.actor.default-dispatcher-12] [INFO] PekkoRecovery - notifier-250: Recovery completed - Switching actor to Follower - last log index = -1, last log term = -1, snapshot index = -1, snapshot term = -1, journal size = 0 12:00:42,549 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] PropertiesTermInfoStore - notifier-250: Set currentTerm=0, votedFor=null 12:00:42,549 AM [test-pekko.actor.default-dispatcher-12] [INFO] PekkoRecovery - notifier-250: Local TermInfo store seeded with TermInfo{term=0} 12:00:42,549 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] RaftActor - notifier-250: Pekko recovery completed with org.opendaylight.controller.cluster.raft.RecoveryLog@6d674d2d 12:00:42,549 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] AbstractReplicatedLog - notifier-250: Moving last applied index from -1 to -1 12:00:42,549 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] JournalRecovery - notifier-250: empty journal: appending 0 entries 12:00:42,549 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] EntryJournalV1 - notifier-250: updated meta to JournalMeta[replayFrom=1, applyTo=0] 12:00:42,549 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] JournalRecovery - notifier-250: journal recovery completedin 246.9 μs with journalIndex=1 12:00:42,713 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] DefaultConfigParamsImpl - No custom RaftPolicy specified. Using DefaultRaftPolicy 12:00:42,713 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] Follower - notifier-250 (Follower): Checking if this node is isolated in the cluster unreachable set [],all members [] self member: Member(pekko://test@10.30.171.227:17355, Removed) 12:00:42,713 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] Follower - notifier-250 (Follower): Received ElectionTimeout - switching to Candidate 12:00:42,714 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] Candidate - notifier-250 (Candidate): Election: Candidate has following voting peers: [leader] 12:00:42,716 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] PropertiesTermInfoStore - notifier-250: Set currentTerm=1, votedFor=notifier-250 12:00:42,716 AM [test-pekko.actor.default-dispatcher-12] [INFO] Candidate - notifier-250 (Candidate): Starting new election term 1 12:00:42,716 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] Candidate - notifier-250 (Candidate): Sending RequestVote{term=1, candidateId=notifier-250, lastLogIndex=-1, lastLogTerm=-1} to peer leader [WARN] [07/02/2025 00:00:42.717] [test-pekko.actor.default-dispatcher-11] [pekko://test/user/$c/fake/path] received dead letter from Actor[pekko://test/user/$c#1752718950]: RequestVote{term=1, candidateId=notifier-250, lastLogIndex=-1, lastLogTerm=-1} [INFO] [pekkoDeadLetter][07/02/2025 00:00:42.717] [test-pekko.actor.default-dispatcher-7] [pekko://test/user/$c/fake/path] Message [org.opendaylight.controller.cluster.raft.messages.RequestVote] from Actor[pekko://test/user/$c#1752718950] to Actor[pekko://test/user/$c/fake/path] was not delivered. [8] dead letters encountered. If this is not an expected behavior then Actor[pekko://test/user/$c/fake/path] may have terminated unexpectedly. This logging can be turned off or adjusted with configuration settings 'pekko.log-dead-letters' and 'pekko.log-dead-letters-during-shutdown'. 12:00:42,717 AM [test-pekko.actor.default-dispatcher-7] [INFO] EmptyLocalActorRef - pekkoDeadLetter Message [org.opendaylight.controller.cluster.raft.messages.RequestVote] from Actor[pekko://test/user/$c#1752718950] to Actor[pekko://test/user/$c/fake/path] was not delivered. [8] dead letters encountered. If this is not an expected behavior then Actor[pekko://test/user/$c/fake/path] may have terminated unexpectedly. This logging can be turned off or adjusted with configuration settings 'pekko.log-dead-letters' and 'pekko.log-dead-letters-during-shutdown'. 12:00:42,717 AM [test-pekko.actor.default-dispatcher-12] [INFO] RaftActorBehavior - notifier-250 (Follower) :- Switching from behavior Follower to Candidate, election term: 1 12:00:42,903 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] Candidate - notifier-250 (Candidate): Received ElectionTimeout 12:00:42,908 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] PropertiesTermInfoStore - notifier-250: Set currentTerm=2, votedFor=notifier-250 12:00:42,908 AM [test-pekko.actor.default-dispatcher-7] [INFO] Candidate - notifier-250 (Candidate): Starting new election term 2 12:00:42,909 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] Candidate - notifier-250 (Candidate): Sending RequestVote{term=2, candidateId=notifier-250, lastLogIndex=-1, lastLogTerm=-1} to peer leader [WARN] [07/02/2025 00:00:42.909] [test-pekko.actor.default-dispatcher-7] [pekko://test/user/$c/fake/path] received dead letter from Actor[pekko://test/user/$c#1752718950]: RequestVote{term=2, candidateId=notifier-250, lastLogIndex=-1, lastLogTerm=-1} [INFO] [pekkoDeadLetter][07/02/2025 00:00:42.909] [test-pekko.actor.default-dispatcher-7] [pekko://test/user/$c/fake/path] Message [org.opendaylight.controller.cluster.raft.messages.RequestVote] from Actor[pekko://test/user/$c#1752718950] to Actor[pekko://test/user/$c/fake/path] was not delivered. [9] dead letters encountered. If this is not an expected behavior then Actor[pekko://test/user/$c/fake/path] may have terminated unexpectedly. This logging can be turned off or adjusted with configuration settings 'pekko.log-dead-letters' and 'pekko.log-dead-letters-during-shutdown'. 12:00:42,909 AM [test-pekko.actor.default-dispatcher-11] [INFO] EmptyLocalActorRef - pekkoDeadLetter Message [org.opendaylight.controller.cluster.raft.messages.RequestVote] from Actor[pekko://test/user/$c#1752718950] to Actor[pekko://test/user/$c/fake/path] was not delivered. [9] dead letters encountered. If this is not an expected behavior then Actor[pekko://test/user/$c/fake/path] may have terminated unexpectedly. This logging can be turned off or adjusted with configuration settings 'pekko.log-dead-letters' and 'pekko.log-dead-letters-during-shutdown'. 12:00:43,83 AM [test-pekko.actor.default-dispatcher-11] [DEBUG] Candidate - notifier-250 (Candidate): Received ElectionTimeout 12:00:43,87 AM [test-pekko.actor.default-dispatcher-11] [DEBUG] PropertiesTermInfoStore - notifier-250: Set currentTerm=3, votedFor=notifier-250 12:00:43,87 AM [test-pekko.actor.default-dispatcher-11] [INFO] Candidate - notifier-250 (Candidate): Starting new election term 3 12:00:43,87 AM [test-pekko.actor.default-dispatcher-11] [DEBUG] Candidate - notifier-250 (Candidate): Sending RequestVote{term=3, candidateId=notifier-250, lastLogIndex=-1, lastLogTerm=-1} to peer leader 12:00:43,88 AM [test-pekko.actor.default-dispatcher-11] [INFO] EmptyLocalActorRef - pekkoDeadLetter Message [org.opendaylight.controller.cluster.raft.messages.RequestVote] from Actor[pekko://test/user/$c#1752718950] to Actor[pekko://test/user/$c/fake/path] 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[pekko://test/user/$c/fake/path] may have terminated unexpectedly. This logging can be turned off or adjusted with configuration settings 'pekko.log-dead-letters' and 'pekko.log-dead-letters-during-shutdown'. [WARN] [07/02/2025 00:00:43.088] [test-pekko.actor.default-dispatcher-12] [pekko://test/user/$c/fake/path] received dead letter from Actor[pekko://test/user/$c#1752718950]: RequestVote{term=3, candidateId=notifier-250, lastLogIndex=-1, lastLogTerm=-1} [INFO] [pekkoDeadLetter][07/02/2025 00:00:43.087] [test-pekko.actor.default-dispatcher-7] [pekko://test/user/$c/fake/path] Message [org.opendaylight.controller.cluster.raft.messages.RequestVote] from Actor[pekko://test/user/$c#1752718950] to Actor[pekko://test/user/$c/fake/path] 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[pekko://test/user/$c/fake/path] may have terminated unexpectedly. This logging can be turned off or adjusted with configuration settings 'pekko.log-dead-letters' and 'pekko.log-dead-letters-during-shutdown'. 12:00:43,303 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] Candidate - notifier-250 (Candidate): Received ElectionTimeout 12:00:43,306 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] PropertiesTermInfoStore - notifier-250: Set currentTerm=4, votedFor=notifier-250 12:00:43,306 AM [test-pekko.actor.default-dispatcher-12] [INFO] Candidate - notifier-250 (Candidate): Starting new election term 4 12:00:43,306 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] Candidate - notifier-250 (Candidate): Sending RequestVote{term=4, candidateId=notifier-250, lastLogIndex=-1, lastLogTerm=-1} to peer leader [WARN] [07/02/2025 00:00:43.307] [test-pekko.actor.default-dispatcher-11] [pekko://test/user/$c/fake/path] received dead letter from Actor[pekko://test/user/$c#1752718950]: RequestVote{term=4, candidateId=notifier-250, lastLogIndex=-1, lastLogTerm=-1} 12:00:43,523 AM [test-pekko.actor.default-dispatcher-11] [DEBUG] Candidate - notifier-250 (Candidate): Received ElectionTimeout 12:00:43,526 AM [test-pekko.actor.default-dispatcher-11] [DEBUG] PropertiesTermInfoStore - notifier-250: Set currentTerm=5, votedFor=notifier-250 12:00:43,526 AM [test-pekko.actor.default-dispatcher-11] [INFO] Candidate - notifier-250 (Candidate): Starting new election term 5 12:00:43,526 AM [test-pekko.actor.default-dispatcher-11] [DEBUG] Candidate - notifier-250 (Candidate): Sending RequestVote{term=5, candidateId=notifier-250, lastLogIndex=-1, lastLogTerm=-1} to peer leader [WARN] [07/02/2025 00:00:43.527] [test-pekko.actor.default-dispatcher-12] [pekko://test/user/$c/fake/path] received dead letter from Actor[pekko://test/user/$c#1752718950]: RequestVote{term=5, candidateId=notifier-250, lastLogIndex=-1, lastLogTerm=-1} 12:00:43,673 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] Candidate - notifier-250 (Candidate): Received ElectionTimeout 12:00:43,676 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] PropertiesTermInfoStore - notifier-250: Set currentTerm=6, votedFor=notifier-250 12:00:43,676 AM [test-pekko.actor.default-dispatcher-7] [INFO] Candidate - notifier-250 (Candidate): Starting new election term 6 12:00:43,676 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] Candidate - notifier-250 (Candidate): Sending RequestVote{term=6, candidateId=notifier-250, lastLogIndex=-1, lastLogTerm=-1} to peer leader [WARN] [07/02/2025 00:00:43.677] [test-pekko.actor.default-dispatcher-12] [pekko://test/user/$c/fake/path] received dead letter from Actor[pekko://test/user/$c#1752718950]: RequestVote{term=6, candidateId=notifier-250, lastLogIndex=-1, lastLogTerm=-1} 12:00:43,853 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] Candidate - notifier-250 (Candidate): Received ElectionTimeout 12:00:43,856 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] PropertiesTermInfoStore - notifier-250: Set currentTerm=7, votedFor=notifier-250 12:00:43,856 AM [test-pekko.actor.default-dispatcher-12] [INFO] Candidate - notifier-250 (Candidate): Starting new election term 7 12:00:43,856 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] Candidate - notifier-250 (Candidate): Sending RequestVote{term=7, candidateId=notifier-250, lastLogIndex=-1, lastLogTerm=-1} to peer leader [WARN] [07/02/2025 00:00:43.857] [test-pekko.actor.default-dispatcher-11] [pekko://test/user/$c/fake/path] received dead letter from Actor[pekko://test/user/$c#1752718950]: RequestVote{term=7, candidateId=notifier-250, lastLogIndex=-1, lastLogTerm=-1} 12:00:44,53 AM [test-pekko.actor.default-dispatcher-11] [DEBUG] Candidate - notifier-250 (Candidate): Received ElectionTimeout 12:00:44,55 AM [test-pekko.actor.default-dispatcher-11] [DEBUG] PropertiesTermInfoStore - notifier-250: Set currentTerm=8, votedFor=notifier-250 12:00:44,55 AM [test-pekko.actor.default-dispatcher-11] [INFO] Candidate - notifier-250 (Candidate): Starting new election term 8 12:00:44,55 AM [test-pekko.actor.default-dispatcher-11] [DEBUG] Candidate - notifier-250 (Candidate): Sending RequestVote{term=8, candidateId=notifier-250, lastLogIndex=-1, lastLogTerm=-1} to peer leader [WARN] [07/02/2025 00:00:44.056] [test-pekko.actor.default-dispatcher-7] [pekko://test/user/$c/fake/path] received dead letter from Actor[pekko://test/user/$c#1752718950]: RequestVote{term=8, candidateId=notifier-250, lastLogIndex=-1, lastLogTerm=-1} 12:00:44,203 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] Candidate - notifier-250 (Candidate): Received ElectionTimeout 12:00:44,206 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] PropertiesTermInfoStore - notifier-250: Set currentTerm=9, votedFor=notifier-250 12:00:44,206 AM [test-pekko.actor.default-dispatcher-7] [INFO] Candidate - notifier-250 (Candidate): Starting new election term 9 12:00:44,206 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] Candidate - notifier-250 (Candidate): Sending RequestVote{term=9, candidateId=notifier-250, lastLogIndex=-1, lastLogTerm=-1} to peer leader [WARN] [07/02/2025 00:00:44.207] [test-pekko.actor.default-dispatcher-12] [pekko://test/user/$c/fake/path] received dead letter from Actor[pekko://test/user/$c#1752718950]: RequestVote{term=9, candidateId=notifier-250, lastLogIndex=-1, lastLogTerm=-1} 12:00:44,393 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] Candidate - notifier-250 (Candidate): Received ElectionTimeout 12:00:44,395 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] PropertiesTermInfoStore - notifier-250: Set currentTerm=10, votedFor=notifier-250 12:00:44,396 AM [test-pekko.actor.default-dispatcher-12] [INFO] Candidate - notifier-250 (Candidate): Starting new election term 10 12:00:44,396 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] Candidate - notifier-250 (Candidate): Sending RequestVote{term=10, candidateId=notifier-250, lastLogIndex=-1, lastLogTerm=-1} to peer leader [WARN] [07/02/2025 00:00:44.396] [test-pekko.actor.default-dispatcher-7] [pekko://test/user/$c/fake/path] received dead letter from Actor[pekko://test/user/$c#1752718950]: RequestVote{term=10, candidateId=notifier-250, lastLogIndex=-1, lastLogTerm=-1} 12:00:44,613 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] Candidate - notifier-250 (Candidate): Received ElectionTimeout 12:00:44,618 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] PropertiesTermInfoStore - notifier-250: Set currentTerm=11, votedFor=notifier-250 12:00:44,618 AM [test-pekko.actor.default-dispatcher-7] [INFO] Candidate - notifier-250 (Candidate): Starting new election term 11 12:00:44,618 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] Candidate - notifier-250 (Candidate): Sending RequestVote{term=11, candidateId=notifier-250, lastLogIndex=-1, lastLogTerm=-1} to peer leader [WARN] [07/02/2025 00:00:44.619] [test-pekko.actor.default-dispatcher-12] [pekko://test/user/$c/fake/path] received dead letter from Actor[pekko://test/user/$c#1752718950]: RequestVote{term=11, candidateId=notifier-250, lastLogIndex=-1, lastLogTerm=-1} 12:00:44,753 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] Candidate - notifier-250 (Candidate): Received ElectionTimeout 12:00:44,757 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] PropertiesTermInfoStore - notifier-250: Set currentTerm=12, votedFor=notifier-250 12:00:44,757 AM [test-pekko.actor.default-dispatcher-12] [INFO] Candidate - notifier-250 (Candidate): Starting new election term 12 12:00:44,757 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] Candidate - notifier-250 (Candidate): Sending RequestVote{term=12, candidateId=notifier-250, lastLogIndex=-1, lastLogTerm=-1} to peer leader [WARN] [07/02/2025 00:00:44.757] [test-pekko.actor.default-dispatcher-7] [pekko://test/user/$c/fake/path] received dead letter from Actor[pekko://test/user/$c#1752718950]: RequestVote{term=12, candidateId=notifier-250, lastLogIndex=-1, lastLogTerm=-1} 12:00:44,902 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] Candidate - notifier-250 (Candidate): Received ElectionTimeout 12:00:44,905 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] PropertiesTermInfoStore - notifier-250: Set currentTerm=13, votedFor=notifier-250 12:00:44,905 AM [test-pekko.actor.default-dispatcher-7] [INFO] Candidate - notifier-250 (Candidate): Starting new election term 13 12:00:44,906 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] Candidate - notifier-250 (Candidate): Sending RequestVote{term=13, candidateId=notifier-250, lastLogIndex=-1, lastLogTerm=-1} to peer leader [WARN] [07/02/2025 00:00:44.906] [test-pekko.actor.default-dispatcher-11] [pekko://test/user/$c/fake/path] received dead letter from Actor[pekko://test/user/$c#1752718950]: RequestVote{term=13, candidateId=notifier-250, lastLogIndex=-1, lastLogTerm=-1} 12:00:45,73 AM [test-pekko.actor.default-dispatcher-11] [DEBUG] Candidate - notifier-250 (Candidate): Received ElectionTimeout 12:00:45,76 AM [test-pekko.actor.default-dispatcher-11] [DEBUG] PropertiesTermInfoStore - notifier-250: Set currentTerm=14, votedFor=notifier-250 12:00:45,76 AM [test-pekko.actor.default-dispatcher-11] [INFO] Candidate - notifier-250 (Candidate): Starting new election term 14 12:00:45,76 AM [test-pekko.actor.default-dispatcher-11] [DEBUG] Candidate - notifier-250 (Candidate): Sending RequestVote{term=14, candidateId=notifier-250, lastLogIndex=-1, lastLogTerm=-1} to peer leader [WARN] [07/02/2025 00:00:45.077] [test-pekko.actor.default-dispatcher-12] [pekko://test/user/$c/fake/path] received dead letter from Actor[pekko://test/user/$c#1752718950]: RequestVote{term=14, candidateId=notifier-250, lastLogIndex=-1, lastLogTerm=-1} 12:00:45,273 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] Candidate - notifier-250 (Candidate): Received ElectionTimeout 12:00:45,276 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] PropertiesTermInfoStore - notifier-250: Set currentTerm=15, votedFor=notifier-250 12:00:45,276 AM [test-pekko.actor.default-dispatcher-12] [INFO] Candidate - notifier-250 (Candidate): Starting new election term 15 12:00:45,276 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] Candidate - notifier-250 (Candidate): Sending RequestVote{term=15, candidateId=notifier-250, lastLogIndex=-1, lastLogTerm=-1} to peer leader [WARN] [07/02/2025 00:00:45.276] [test-pekko.actor.default-dispatcher-11] [pekko://test/user/$c/fake/path] received dead letter from Actor[pekko://test/user/$c#1752718950]: RequestVote{term=15, candidateId=notifier-250, lastLogIndex=-1, lastLogTerm=-1} 12:00:45,483 AM [test-pekko.actor.default-dispatcher-11] [DEBUG] Candidate - notifier-250 (Candidate): Received ElectionTimeout 12:00:45,485 AM [test-pekko.actor.default-dispatcher-11] [DEBUG] PropertiesTermInfoStore - notifier-250: Set currentTerm=16, votedFor=notifier-250 12:00:45,485 AM [test-pekko.actor.default-dispatcher-11] [INFO] Candidate - notifier-250 (Candidate): Starting new election term 16 12:00:45,485 AM [test-pekko.actor.default-dispatcher-11] [DEBUG] Candidate - notifier-250 (Candidate): Sending RequestVote{term=16, candidateId=notifier-250, lastLogIndex=-1, lastLogTerm=-1} to peer leader [WARN] [07/02/2025 00:00:45.485] [test-pekko.actor.default-dispatcher-7] [pekko://test/user/$c/fake/path] received dead letter from Actor[pekko://test/user/$c#1752718950]: RequestVote{term=16, candidateId=notifier-250, lastLogIndex=-1, lastLogTerm=-1} 12:00:45,673 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] Candidate - notifier-250 (Candidate): Received ElectionTimeout 12:00:45,676 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] PropertiesTermInfoStore - notifier-250: Set currentTerm=17, votedFor=notifier-250 12:00:45,676 AM [test-pekko.actor.default-dispatcher-7] [INFO] Candidate - notifier-250 (Candidate): Starting new election term 17 12:00:45,676 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] Candidate - notifier-250 (Candidate): Sending RequestVote{term=17, candidateId=notifier-250, lastLogIndex=-1, lastLogTerm=-1} to peer leader [WARN] [07/02/2025 00:00:45.676] [test-pekko.actor.default-dispatcher-11] [pekko://test/user/$c/fake/path] received dead letter from Actor[pekko://test/user/$c#1752718950]: RequestVote{term=17, candidateId=notifier-250, lastLogIndex=-1, lastLogTerm=-1} 12:00:45,833 AM [test-pekko.actor.default-dispatcher-11] [DEBUG] Candidate - notifier-250 (Candidate): Received ElectionTimeout 12:00:45,835 AM [test-pekko.actor.default-dispatcher-11] [DEBUG] PropertiesTermInfoStore - notifier-250: Set currentTerm=18, votedFor=notifier-250 12:00:45,835 AM [test-pekko.actor.default-dispatcher-11] [INFO] Candidate - notifier-250 (Candidate): Starting new election term 18 12:00:45,835 AM [test-pekko.actor.default-dispatcher-11] [DEBUG] Candidate - notifier-250 (Candidate): Sending RequestVote{term=18, candidateId=notifier-250, lastLogIndex=-1, lastLogTerm=-1} to peer leader [WARN] [07/02/2025 00:00:45.836] [test-pekko.actor.default-dispatcher-12] [pekko://test/user/$c/fake/path] received dead letter from Actor[pekko://test/user/$c#1752718950]: RequestVote{term=18, candidateId=notifier-250, lastLogIndex=-1, lastLogTerm=-1} 12:00:46,3 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] Candidate - notifier-250 (Candidate): Received ElectionTimeout 12:00:46,6 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] PropertiesTermInfoStore - notifier-250: Set currentTerm=19, votedFor=notifier-250 12:00:46,6 AM [test-pekko.actor.default-dispatcher-12] [INFO] Candidate - notifier-250 (Candidate): Starting new election term 19 12:00:46,6 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] Candidate - notifier-250 (Candidate): Sending RequestVote{term=19, candidateId=notifier-250, lastLogIndex=-1, lastLogTerm=-1} to peer leader [WARN] [07/02/2025 00:00:46.007] [test-pekko.actor.default-dispatcher-7] [pekko://test/user/$c/fake/path] received dead letter from Actor[pekko://test/user/$c#1752718950]: RequestVote{term=19, candidateId=notifier-250, lastLogIndex=-1, lastLogTerm=-1} 12:00:46,173 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] Candidate - notifier-250 (Candidate): Received ElectionTimeout 12:00:46,176 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] PropertiesTermInfoStore - notifier-250: Set currentTerm=20, votedFor=notifier-250 12:00:46,176 AM [test-pekko.actor.default-dispatcher-7] [INFO] Candidate - notifier-250 (Candidate): Starting new election term 20 12:00:46,176 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] Candidate - notifier-250 (Candidate): Sending RequestVote{term=20, candidateId=notifier-250, lastLogIndex=-1, lastLogTerm=-1} to peer leader [WARN] [07/02/2025 00:00:46.176] [test-pekko.actor.default-dispatcher-11] [pekko://test/user/$c/fake/path] received dead letter from Actor[pekko://test/user/$c#1752718950]: RequestVote{term=20, candidateId=notifier-250, lastLogIndex=-1, lastLogTerm=-1} 12:00:46,313 AM [test-pekko.actor.default-dispatcher-11] [DEBUG] Candidate - notifier-250 (Candidate): Received ElectionTimeout 12:00:46,318 AM [test-pekko.actor.default-dispatcher-11] [DEBUG] PropertiesTermInfoStore - notifier-250: Set currentTerm=21, votedFor=notifier-250 12:00:46,318 AM [test-pekko.actor.default-dispatcher-11] [INFO] Candidate - notifier-250 (Candidate): Starting new election term 21 12:00:46,318 AM [test-pekko.actor.default-dispatcher-11] [DEBUG] Candidate - notifier-250 (Candidate): Sending RequestVote{term=21, candidateId=notifier-250, lastLogIndex=-1, lastLogTerm=-1} to peer leader [WARN] [07/02/2025 00:00:46.318] [test-pekko.actor.default-dispatcher-12] [pekko://test/user/$c/fake/path] received dead letter from Actor[pekko://test/user/$c#1752718950]: RequestVote{term=21, candidateId=notifier-250, lastLogIndex=-1, lastLogTerm=-1} 12:00:46,513 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] Candidate - notifier-250 (Candidate): Received ElectionTimeout 12:00:46,516 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] PropertiesTermInfoStore - notifier-250: Set currentTerm=22, votedFor=notifier-250 12:00:46,516 AM [test-pekko.actor.default-dispatcher-12] [INFO] Candidate - notifier-250 (Candidate): Starting new election term 22 12:00:46,516 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] Candidate - notifier-250 (Candidate): Sending RequestVote{term=22, candidateId=notifier-250, lastLogIndex=-1, lastLogTerm=-1} to peer leader [WARN] [07/02/2025 00:00:46.516] [test-pekko.actor.default-dispatcher-11] [pekko://test/user/$c/fake/path] received dead letter from Actor[pekko://test/user/$c#1752718950]: RequestVote{term=22, candidateId=notifier-250, lastLogIndex=-1, lastLogTerm=-1} 12:00:46,693 AM [test-pekko.actor.default-dispatcher-11] [DEBUG] Candidate - notifier-250 (Candidate): Received ElectionTimeout 12:00:46,695 AM [test-pekko.actor.default-dispatcher-11] [DEBUG] PropertiesTermInfoStore - notifier-250: Set currentTerm=23, votedFor=notifier-250 12:00:46,695 AM [test-pekko.actor.default-dispatcher-11] [INFO] Candidate - notifier-250 (Candidate): Starting new election term 23 12:00:46,695 AM [test-pekko.actor.default-dispatcher-11] [DEBUG] Candidate - notifier-250 (Candidate): Sending RequestVote{term=23, candidateId=notifier-250, lastLogIndex=-1, lastLogTerm=-1} to peer leader [WARN] [07/02/2025 00:00:46.696] [test-pekko.actor.default-dispatcher-7] [pekko://test/user/$c/fake/path] received dead letter from Actor[pekko://test/user/$c#1752718950]: RequestVote{term=23, candidateId=notifier-250, lastLogIndex=-1, lastLogTerm=-1} 12:00:46,893 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] Candidate - notifier-250 (Candidate): Received ElectionTimeout 12:00:46,896 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] PropertiesTermInfoStore - notifier-250: Set currentTerm=24, votedFor=notifier-250 12:00:46,896 AM [test-pekko.actor.default-dispatcher-7] [INFO] Candidate - notifier-250 (Candidate): Starting new election term 24 12:00:46,896 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] Candidate - notifier-250 (Candidate): Sending RequestVote{term=24, candidateId=notifier-250, lastLogIndex=-1, lastLogTerm=-1} to peer leader [WARN] [07/02/2025 00:00:46.897] [test-pekko.actor.default-dispatcher-7] [pekko://test/user/$c/fake/path] received dead letter from Actor[pekko://test/user/$c#1752718950]: RequestVote{term=24, candidateId=notifier-250, lastLogIndex=-1, lastLogTerm=-1} 12:00:47,73 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] Candidate - notifier-250 (Candidate): Received ElectionTimeout 12:00:47,76 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] PropertiesTermInfoStore - notifier-250: Set currentTerm=25, votedFor=notifier-250 12:00:47,76 AM [test-pekko.actor.default-dispatcher-7] [INFO] Candidate - notifier-250 (Candidate): Starting new election term 25 12:00:47,76 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] Candidate - notifier-250 (Candidate): Sending RequestVote{term=25, candidateId=notifier-250, lastLogIndex=-1, lastLogTerm=-1} to peer leader [WARN] [07/02/2025 00:00:47.077] [test-pekko.actor.default-dispatcher-7] [pekko://test/user/$c/fake/path] received dead letter from Actor[pekko://test/user/$c#1752718950]: RequestVote{term=25, candidateId=notifier-250, lastLogIndex=-1, lastLogTerm=-1} 12:00:47,283 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] Candidate - notifier-250 (Candidate): Received ElectionTimeout 12:00:47,286 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] PropertiesTermInfoStore - notifier-250: Set currentTerm=26, votedFor=notifier-250 12:00:47,286 AM [test-pekko.actor.default-dispatcher-7] [INFO] Candidate - notifier-250 (Candidate): Starting new election term 26 12:00:47,286 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] Candidate - notifier-250 (Candidate): Sending RequestVote{term=26, candidateId=notifier-250, lastLogIndex=-1, lastLogTerm=-1} to peer leader [WARN] [07/02/2025 00:00:47.287] [test-pekko.actor.default-dispatcher-12] [pekko://test/user/$c/fake/path] received dead letter from Actor[pekko://test/user/$c#1752718950]: RequestVote{term=26, candidateId=notifier-250, lastLogIndex=-1, lastLogTerm=-1} 12:00:47,483 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] Candidate - notifier-250 (Candidate): Received ElectionTimeout 12:00:47,486 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] PropertiesTermInfoStore - notifier-250: Set currentTerm=27, votedFor=notifier-250 12:00:47,486 AM [test-pekko.actor.default-dispatcher-12] [INFO] Candidate - notifier-250 (Candidate): Starting new election term 27 12:00:47,486 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] Candidate - notifier-250 (Candidate): Sending RequestVote{term=27, candidateId=notifier-250, lastLogIndex=-1, lastLogTerm=-1} to peer leader [WARN] [07/02/2025 00:00:47.486] [test-pekko.actor.default-dispatcher-7] [pekko://test/user/$c/fake/path] received dead letter from Actor[pekko://test/user/$c#1752718950]: RequestVote{term=27, candidateId=notifier-250, lastLogIndex=-1, lastLogTerm=-1} 12:00:47,563 AM [main] [INFO] TestActorFactory - Killing actor Actor[pekko://test/user/$b#-26467463] 12:00:47,574 AM [main] [INFO] TestActorFactory - Killing actor Actor[pekko://test/user/$c#1752718950] 12:00:47,574 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] PekkoRaftStorage - notifier-250: terminating thread VirtualThread[#678,notifier-250-writer-104]/waiting 12:00:47,574 AM [notifier-250-writer-104] [DEBUG] JournalWriteTask - notifier-250: received 1 commands after 5.029 s 12:00:47,574 AM [notifier-250-writer-104] [DEBUG] JournalWriteTask - notifier-250: completed 1 commands in 19.78 μs 12:00:47,574 AM [notifier-250-writer-104] [DEBUG] JournalWriteTask - notifier-250: journal writer stopped 12:00:47,575 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] EntryJournalV1 - notifier-250: journal closed 12:00:47,575 AM [test-pekko.actor.default-dispatcher-7] [INFO] PekkoRaftStorage - notifier-250: journal closed 12:00:47,575 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] RaftStorage - notifier-250: stopped executor with 0 remaining tasks 12:00:47,575 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] RaftStorage - notifier-250: stopped executor with 0 remaining tasks [WARN] [07/02/2025 00:00:47.578] [test-pekko.actor.default-dispatcher-7] [pekko://test/user/termination-monitor] received dead letter from TestActor[pekko://test/user/leader-251]: org.opendaylight.controller.cluster.common.actor.Monitor@3b401f08 12:00:47,579 AM [main] [INFO] RaftActor - leader-251: Starting recovery with journal batch size 1000 12:00:47,579 AM [main] [DEBUG] RaftStorage - leader-251: started executor 12:00:47,579 AM [main] [DEBUG] RaftStorage - leader-251: started executor 12:00:47,579 AM [main] [DEBUG] EntryJournalV1 - leader-251: metadata journal open: replayFrom=1 applyTo=0 12:00:47,580 AM [main] [DEBUG] EntryJournalV1 - leader-251: journal open: firstIndex=1 lastIndex=0 replayFrom=1 fileEntries=0 12:00:47,580 AM [main] [INFO] PekkoRaftStorage - leader-251: journal open: applyTo=0 12:00:47,580 AM [leader-251-writer-105] [DEBUG] JournalWriteTask - leader-251: journal writer started 12:00:47,580 AM [leader-251-writer-105] [DEBUG] JournalWriteTask - leader-251: waiting to receive commands 12:00:47,581 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] PropertiesTermInfoStore - /tmp/org.opendaylight.controller.cluster.raft.RaftActorTest14741032680359468749/leader-251/TermInfo.properties does not exist 12:00:47,582 AM [test-pekko.actor.default-dispatcher-7] [INFO] PekkoRecovery - leader-251: Recovery completed - Switching actor to Follower - last log index = -1, last log term = -1, snapshot index = -1, snapshot term = -1, journal size = 0 12:00:47,584 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] PropertiesTermInfoStore - leader-251: Set currentTerm=0, votedFor=null 12:00:47,584 AM [test-pekko.actor.default-dispatcher-7] [INFO] PekkoRecovery - leader-251: Local TermInfo store seeded with TermInfo{term=0} 12:00:47,585 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] RaftActor - leader-251: Pekko recovery completed with org.opendaylight.controller.cluster.raft.RecoveryLog@14966b4 12:00:47,586 AM [test-pekko.actor.default-dispatcher-7] [INFO] DefaultConfigParamsImpl - Trying to use custom RaftPolicy org.opendaylight.controller.cluster.raft.policy.DisableElectionsRaftPolicy 12:00:47,588 AM [main] [DEBUG] PropertiesTermInfoStore - leader-251: Set currentTerm=100, votedFor= 12:00:47,591 AM [main] [DEBUG] PropertiesTermInfoStore - leader-251: Set currentTerm=110, votedFor= 12:00:47,591 AM [main] [DEBUG] AbstractLeader - leader-251 (Leader): Election: Leader has following peers: [] 12:00:47,591 AM [main] [INFO] TestActorFactory - Killing actor TestActor[pekko://test/user/leader-251] 12:00:47,602 AM [main] [DEBUG] PekkoRaftStorage - leader-251: terminating thread VirtualThread[#679,leader-251-writer-105]/waiting 12:00:47,602 AM [leader-251-writer-105] [DEBUG] JournalWriteTask - leader-251: received 1 commands after 22.06 ms 12:00:47,602 AM [leader-251-writer-105] [DEBUG] JournalWriteTask - leader-251: completed 1 commands in 14.58 μs 12:00:47,602 AM [leader-251-writer-105] [DEBUG] JournalWriteTask - leader-251: journal writer stopped 12:00:47,602 AM [main] [DEBUG] EntryJournalV1 - leader-251: journal closed 12:00:47,602 AM [main] [INFO] PekkoRaftStorage - leader-251: journal closed 12:00:47,602 AM [main] [DEBUG] RaftStorage - leader-251: stopped executor with 0 remaining tasks 12:00:47,603 AM [main] [DEBUG] RaftStorage - leader-251: stopped executor with 0 remaining tasks [WARN] [07/02/2025 00:00:47.606] [test-pekko.actor.default-dispatcher-11] [pekko://test/user/termination-monitor] received dead letter from Actor[pekko://test/user/testConstruction#66845166]: org.opendaylight.controller.cluster.common.actor.Monitor@74d8befe 12:00:47,607 AM [test-pekko.actor.default-dispatcher-7] [INFO] RaftActor - testConstruction: Starting recovery with journal batch size 1000 12:00:47,607 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] RaftStorage - testConstruction: started executor 12:00:47,607 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] RaftStorage - testConstruction: started executor 12:00:47,607 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] EntryJournalV1 - testConstruction: metadata journal open: replayFrom=1 applyTo=0 12:00:47,608 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] EntryJournalV1 - testConstruction: journal open: firstIndex=1 lastIndex=0 replayFrom=1 fileEntries=0 12:00:47,608 AM [test-pekko.actor.default-dispatcher-7] [INFO] PekkoRaftStorage - testConstruction: journal open: applyTo=0 12:00:47,608 AM [testConstruction-writer-106] [DEBUG] JournalWriteTask - testConstruction: journal writer started 12:00:47,608 AM [testConstruction-writer-106] [DEBUG] JournalWriteTask - testConstruction: waiting to receive commands 12:00:47,610 AM [test-pekko.actor.default-dispatcher-11] [DEBUG] PropertiesTermInfoStore - /tmp/org.opendaylight.controller.cluster.raft.RaftActorTest7628799992503703227/testConstruction/TermInfo.properties does not exist 12:00:47,610 AM [test-pekko.actor.default-dispatcher-11] [DEBUG] RaftStorage - testConstruction: skipping unrecognized file /tmp/org.opendaylight.controller.cluster.raft.RaftActorTest7628799992503703227/testConstruction/journal-v1-1.log 12:00:47,610 AM [test-pekko.actor.default-dispatcher-11] [DEBUG] RaftStorage - testConstruction: skipping unrecognized file /tmp/org.opendaylight.controller.cluster.raft.RaftActorTest7628799992503703227/testConstruction/metadata-v1-1.log 12:00:47,610 AM [test-pekko.actor.default-dispatcher-11] [DEBUG] RaftStorage - testConstruction: no eligible files found 12:00:47,610 AM [test-pekko.actor.default-dispatcher-11] [INFO] PekkoRecovery - testConstruction: Recovery completed - Switching actor to Follower - last log index = -1, last log term = -1, snapshot index = -1, snapshot term = -1, journal size = 0 12:00:47,612 AM [test-pekko.actor.default-dispatcher-11] [DEBUG] PropertiesTermInfoStore - testConstruction: Set currentTerm=0, votedFor=null 12:00:47,612 AM [test-pekko.actor.default-dispatcher-11] [INFO] PekkoRecovery - testConstruction: Local TermInfo store seeded with TermInfo{term=0} 12:00:47,612 AM [test-pekko.actor.default-dispatcher-11] [DEBUG] RaftActor - testConstruction: Pekko recovery completed with org.opendaylight.controller.cluster.raft.RecoveryLog@21e3f2ab 12:00:47,613 AM [test-pekko.actor.default-dispatcher-11] [DEBUG] AbstractReplicatedLog - testConstruction: Moving last applied index from -1 to -1 12:00:47,613 AM [test-pekko.actor.default-dispatcher-11] [DEBUG] JournalRecovery - testConstruction: empty journal: appending 0 entries 12:00:47,613 AM [test-pekko.actor.default-dispatcher-11] [DEBUG] EntryJournalV1 - testConstruction: updated meta to JournalMeta[replayFrom=1, applyTo=0] 12:00:47,613 AM [test-pekko.actor.default-dispatcher-11] [DEBUG] JournalRecovery - testConstruction: journal recovery completedin 304.6 μs with journalIndex=1 12:00:47,613 AM [test-pekko.actor.default-dispatcher-11] [DEBUG] DefaultConfigParamsImpl - No custom RaftPolicy specified. Using DefaultRaftPolicy 12:00:47,613 AM [test-pekko.actor.default-dispatcher-11] [DEBUG] Follower - testConstruction (Follower): Received TimeoutNow - switching to Candidate 12:00:47,613 AM [test-pekko.actor.default-dispatcher-11] [DEBUG] Candidate - testConstruction (Candidate): Election: Candidate has following voting peers: [] 12:00:47,615 AM [test-pekko.actor.default-dispatcher-11] [DEBUG] PropertiesTermInfoStore - testConstruction: Set currentTerm=1, votedFor=testConstruction 12:00:47,615 AM [test-pekko.actor.default-dispatcher-11] [INFO] Candidate - testConstruction (Candidate): Starting new election term 1 12:00:47,615 AM [test-pekko.actor.default-dispatcher-11] [INFO] RaftActorBehavior - testConstruction (Follower) :- Switching from behavior Follower to Candidate, election term: 1 12:00:47,615 AM [test-pekko.actor.default-dispatcher-11] [DEBUG] Candidate - testConstruction (Candidate): Received ElectionTimeout 12:00:47,615 AM [test-pekko.actor.default-dispatcher-11] [DEBUG] AbstractLeader - testConstruction (Leader): Election: Leader has following peers: [] 12:00:47,615 AM [test-pekko.actor.default-dispatcher-11] [INFO] RaftActorBehavior - testConstruction (Candidate) :- Switching from behavior Candidate to Leader, election term: 1 [WARN] [07/02/2025 00:00:47.668] [test-pekko.actor.default-dispatcher-11] [pekko://test/user/termination-monitor] received dead letter from TestActor[pekko://test/user/leader-252]: org.opendaylight.controller.cluster.common.actor.Monitor@59385783 12:00:47,669 AM [main] [INFO] RaftActor - leader-252: Starting recovery with journal batch size 1000 12:00:47,669 AM [main] [DEBUG] RaftStorage - leader-252: started executor 12:00:47,670 AM [main] [DEBUG] RaftStorage - leader-252: started executor 12:00:47,670 AM [main] [DEBUG] EntryJournalV1 - leader-252: metadata journal open: replayFrom=1 applyTo=0 12:00:47,671 AM [main] [DEBUG] EntryJournalV1 - leader-252: journal open: firstIndex=1 lastIndex=0 replayFrom=1 fileEntries=0 12:00:47,671 AM [main] [INFO] PekkoRaftStorage - leader-252: journal open: applyTo=0 12:00:47,671 AM [leader-252-writer-107] [DEBUG] JournalWriteTask - leader-252: journal writer started 12:00:47,671 AM [leader-252-writer-107] [DEBUG] JournalWriteTask - leader-252: waiting to receive commands 12:00:47,671 AM [main] [DEBUG] AbstractReplicatedLog - leader-252: Moving last applied index from -1 to 4 12:00:47,671 AM [main] [DEBUG] PropertiesTermInfoStore - leader-252: Set currentTerm=1, votedFor=leader-252 12:00:47,672 AM [test-pekko.actor.default-dispatcher-11] [DEBUG] PropertiesTermInfoStore - /tmp/org.opendaylight.controller.cluster.raft.RaftActorTest10421314054556491744/leader-252/TermInfo.properties does not exist 12:00:47,672 AM [test-pekko.actor.default-dispatcher-11] [INFO] PekkoRecovery - leader-252: Recovery completed - Switching actor to Follower - last log index = -1, last log term = -1, snapshot index = -1, snapshot term = -1, journal size = 0 12:00:47,675 AM [test-pekko.actor.default-dispatcher-11] [DEBUG] PropertiesTermInfoStore - leader-252: Set currentTerm=1, votedFor=leader-252 12:00:47,675 AM [test-pekko.actor.default-dispatcher-11] [INFO] PekkoRecovery - leader-252: Local TermInfo store seeded with TermInfo{term=1, votedFor=leader-252} 12:00:47,675 AM [test-pekko.actor.default-dispatcher-11] [DEBUG] RaftActor - leader-252: Pekko recovery completed with org.opendaylight.controller.cluster.raft.RecoveryLog@186384d5 12:00:47,675 AM [main] [DEBUG] AbstractLeader - leader-252 (Leader): Election: Leader has following peers: [follower-253] 12:00:47,675 AM [main] [DEBUG] AbstractLeader - leader-252 (Leader): Checking sendAppendEntries for follower follower-253: active: false, followerNextIndex: -1, leaderLastIndex: -1, leaderSnapShotIndex: -1 12:00:47,676 AM [main] [INFO] SnapshotManager - leader-252: Initiating snapshot capture CaptureSnapshot [lastAppliedIndex=-1, lastAppliedTerm=-1, lastIndex=6, lastTerm=1, installSnapshotInitiated=, replicatedToAllIndex=4, replicatedToAllTerm=1, unAppliedEntries size=8, mandatoryTrim=false] to install on xyzzy 12:00:47,676 AM [main] [DEBUG] SnapshotManager - leader-252: lastSequenceNumber prior to capture: 0 12:00:47,676 AM [main] [INFO] MockRaftActor - leader-252: support() called 12:00:47,677 AM [main] [DEBUG] AbstractLeader - leader-252 (Leader): handleAppendEntriesReply - FollowerLogInformation for follower-253 updated: matchIndex: 5, nextIndex: 6 12:00:47,677 AM [main] [DEBUG] AbstractLeader - leader-252 (Leader): Applying to log - commitIndex: 5, lastAppliedIndex: -1 12:00:47,677 AM [main] [DEBUG] RaftActorBehavior - leader-252 (Leader): Setting last applied to 0 12:00:47,677 AM [main] [DEBUG] AbstractReplicatedLog - leader-252: Moving last applied index from -1 to 0 12:00:47,677 AM [main] [DEBUG] RaftActor - leader-252: Applying state for log index 0 data 0 12:00:47,677 AM [main] [INFO] MockRaftActor - leader-252: applyState called: 0 12:00:47,677 AM [main] [DEBUG] RaftActorBehavior - leader-252 (Leader): Setting last applied to 1 12:00:47,677 AM [main] [DEBUG] AbstractReplicatedLog - leader-252: Moving last applied index from 0 to 1 12:00:47,677 AM [main] [DEBUG] RaftActor - leader-252: Applying state for log index 1 data 1 12:00:47,677 AM [main] [INFO] MockRaftActor - leader-252: applyState called: 1 12:00:47,677 AM [main] [DEBUG] RaftActorBehavior - leader-252 (Leader): Setting last applied to 2 12:00:47,677 AM [main] [DEBUG] AbstractReplicatedLog - leader-252: Moving last applied index from 1 to 2 12:00:47,677 AM [main] [DEBUG] RaftActor - leader-252: Applying state for log index 2 data 2 12:00:47,677 AM [main] [INFO] MockRaftActor - leader-252: applyState called: 2 12:00:47,677 AM [main] [DEBUG] RaftActorBehavior - leader-252 (Leader): Setting last applied to 3 12:00:47,677 AM [main] [DEBUG] AbstractReplicatedLog - leader-252: Moving last applied index from 2 to 3 12:00:47,677 AM [main] [DEBUG] RaftActor - leader-252: Applying state for log index 3 data 3 12:00:47,677 AM [main] [INFO] MockRaftActor - leader-252: applyState called: 3 12:00:47,677 AM [main] [DEBUG] RaftActorBehavior - leader-252 (Leader): Setting last applied to 4 12:00:47,677 AM [main] [DEBUG] AbstractReplicatedLog - leader-252: Moving last applied index from 3 to 4 12:00:47,677 AM [main] [DEBUG] RaftActor - leader-252: Applying state for log index 4 data 4 12:00:47,677 AM [main] [INFO] MockRaftActor - leader-252: applyState called: 4 12:00:47,677 AM [main] [DEBUG] RaftActorBehavior - leader-252 (Leader): Setting last applied to 5 12:00:47,677 AM [main] [DEBUG] AbstractReplicatedLog - leader-252: Moving last applied index from 4 to 5 12:00:47,677 AM [main] [DEBUG] RaftActor - leader-252: Applying state for log index 5 data 5 12:00:47,677 AM [main] [INFO] MockRaftActor - leader-252: applyState called: 5 12:00:47,677 AM [main] [DEBUG] AbstractLeader - leader-252 (Leader): Checking sendAppendEntries for follower follower-253: active: true, followerNextIndex: 6, leaderLastIndex: 7, leaderSnapShotIndex: -1 12:00:47,677 AM [main] [DEBUG] AbstractLeader - leader-252 (Leader): sendAppendEntries: 6 is present for follower follower-253 12:00:47,677 AM [main] [DEBUG] AbstractLeader - leader-252 (Leader): Sending AppendEntries to follower follower-253: AppendEntries{term=1, leaderId=leader-252, prevLogIndex=5, prevLogTerm=1, leaderCommit=5, replicatedToAllIndex=-1, payloadVersion=5, recipientRaftVersion=5, leaderRaftVersion=5, entries==[JournaledLogEntry{index=6, term=1, command=6, pending=false}, JournaledLogEntry{index=7, term=1, command=7, pending=false}]} 12:00:47,677 AM [main] [DEBUG] AbstractLeader - leader-252 (Leader): handleAppendEntriesReply - FollowerLogInformation for follower-253 updated: matchIndex: 6, nextIndex: 7 12:00:47,678 AM [main] [DEBUG] AbstractLeader - leader-252 (Leader): Applying to log - commitIndex: 6, lastAppliedIndex: 5 12:00:47,678 AM [main] [DEBUG] RaftActorBehavior - leader-252 (Leader): Setting last applied to 6 12:00:47,678 AM [main] [DEBUG] AbstractReplicatedLog - leader-252: Moving last applied index from 5 to 6 12:00:47,678 AM [main] [DEBUG] RaftActor - leader-252: Applying state for log index 6 data 6 12:00:47,678 AM [main] [INFO] MockRaftActor - leader-252: applyState called: 6 12:00:47,678 AM [main] [DEBUG] AbstractLeader - leader-252 (Leader): Checking sendAppendEntries for follower follower-253: active: true, followerNextIndex: 7, leaderLastIndex: 7, leaderSnapShotIndex: -1 12:00:47,678 AM [main] [DEBUG] AbstractLeader - leader-252 (Leader): sendAppendEntries: 7 is present for follower follower-253 12:00:47,678 AM [main] [DEBUG] AbstractLeader - leader-252 (Leader): Sending AppendEntries to follower follower-253: AppendEntries{term=1, leaderId=leader-252, prevLogIndex=6, prevLogTerm=1, leaderCommit=6, replicatedToAllIndex=-1, payloadVersion=5, recipientRaftVersion=5, leaderRaftVersion=5, entries==[JournaledLogEntry{index=7, term=1, command=7, pending=false}]} 12:00:47,678 AM [main] [INFO] SnapshotManager - leader-252: Persising snapshot at EntryInfo[index=-1, term=-1]/EntryInfo[index=6, term=1] 12:00:47,678 AM [main] [INFO] MockRaftActor - leader-252: support() called 12:00:47,678 AM [main] [INFO] SnapshotManager - leader-252: Removed in-memory snapshotted entries, adjusted snaphsotIndex: 4 and term: 1 12:00:47,678 AM [main] [DEBUG] AbstractLeader - leader-252 (Leader): sendInstallSnapshot 12:00:47,678 AM [main] [DEBUG] SnapshotManager - leader-252: Snapshot success with first journal index 6 12:00:47,678 AM [main] [DEBUG] RaftActorSnapshotMessageSupport - leader-252: SnapshotComplete received 12:00:47,678 AM [main] [DEBUG] AbstractLeader - leader-252 (Leader): handleAppendEntriesReply - FollowerLogInformation for follower-253 updated: matchIndex: 7, nextIndex: 8 12:00:47,678 AM [main] [DEBUG] AbstractLeader - leader-252 (Leader): Applying to log - commitIndex: 7, lastAppliedIndex: 6 12:00:47,678 AM [main] [DEBUG] RaftActorBehavior - leader-252 (Leader): Setting last applied to 7 12:00:47,678 AM [main] [DEBUG] AbstractReplicatedLog - leader-252: Moving last applied index from 6 to 7 12:00:47,678 AM [main] [DEBUG] RaftActor - leader-252: Applying state for log index 7 data 7 12:00:47,678 AM [main] [INFO] MockRaftActor - leader-252: applyState called: 7 12:00:47,679 AM [main] [DEBUG] SnapshotManager - leader-252: fakeSnapshot purging log to 6 for term 1 12:00:47,679 AM [main] [DEBUG] AbstractLeader - leader-252 (Leader): Checking sendAppendEntries for follower follower-253: active: true, followerNextIndex: 8, leaderLastIndex: 8, leaderSnapShotIndex: 6 12:00:47,679 AM [main] [DEBUG] AbstractLeader - leader-252 (Leader): sendAppendEntries: 8 is present for follower follower-253 12:00:47,679 AM [main] [DEBUG] AbstractLeader - leader-252 (Leader): Sending AppendEntries to follower follower-253: AppendEntries{term=1, leaderId=leader-252, prevLogIndex=7, prevLogTerm=1, leaderCommit=7, replicatedToAllIndex=6, payloadVersion=5, recipientRaftVersion=5, leaderRaftVersion=5, entries==[JournaledLogEntry{index=8, term=1, command=foo-8, pending=false}]} 12:00:47,679 AM [main] [INFO] TestActorFactory - Killing actor Actor[pekko://test/user/$d#-1957776772] 12:00:47,690 AM [main] [INFO] TestActorFactory - Killing actor TestActor[pekko://test/user/leader-252] 12:00:47,690 AM [main] [DEBUG] PekkoRaftStorage - leader-252: terminating thread VirtualThread[#681,leader-252-writer-107]/waiting 12:00:47,690 AM [leader-252-writer-107] [DEBUG] JournalWriteTask - leader-252: received 1 commands after 18.85 ms 12:00:47,690 AM [leader-252-writer-107] [DEBUG] JournalWriteTask - leader-252: completed 1 commands in 16.08 μs 12:00:47,690 AM [leader-252-writer-107] [DEBUG] JournalWriteTask - leader-252: journal writer stopped 12:00:47,690 AM [main] [DEBUG] EntryJournalV1 - leader-252: journal closed 12:00:47,690 AM [main] [INFO] PekkoRaftStorage - leader-252: journal closed 12:00:47,690 AM [main] [DEBUG] RaftStorage - leader-252: stopped executor with 0 remaining tasks 12:00:47,690 AM [main] [DEBUG] RaftStorage - leader-252: stopped executor with 0 remaining tasks [WARN] [07/02/2025 00:00:47.694] [test-pekko.actor.default-dispatcher-7] [pekko://test/user/termination-monitor] received dead letter from TestActor[pekko://test/user/leader-254]: org.opendaylight.controller.cluster.common.actor.Monitor@3d1a5994 12:00:47,695 AM [main] [INFO] RaftActor - leader-254: Starting recovery with journal batch size 1000 12:00:47,695 AM [main] [DEBUG] RaftStorage - leader-254: started executor 12:00:47,695 AM [main] [DEBUG] RaftStorage - leader-254: started executor 12:00:47,696 AM [main] [DEBUG] EntryJournalV1 - leader-254: metadata journal open: replayFrom=1 applyTo=0 12:00:47,697 AM [main] [DEBUG] EntryJournalV1 - leader-254: journal open: firstIndex=1 lastIndex=0 replayFrom=1 fileEntries=0 12:00:47,697 AM [main] [INFO] PekkoRaftStorage - leader-254: journal open: applyTo=0 12:00:47,697 AM [leader-254-writer-108] [DEBUG] JournalWriteTask - leader-254: journal writer started 12:00:47,697 AM [leader-254-writer-108] [DEBUG] JournalWriteTask - leader-254: waiting to receive commands 12:00:47,698 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] PropertiesTermInfoStore - /tmp/org.opendaylight.controller.cluster.raft.RaftActorTest7447601550346454911/leader-254/TermInfo.properties does not exist 12:00:47,698 AM [test-pekko.actor.default-dispatcher-7] [INFO] PekkoRecovery - leader-254: Recovery completed - Switching actor to Follower - last log index = -1, last log term = -1, snapshot index = -1, snapshot term = -1, journal size = 0 12:00:47,701 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] PropertiesTermInfoStore - leader-254: Set currentTerm=0, votedFor=null 12:00:47,701 AM [test-pekko.actor.default-dispatcher-7] [INFO] PekkoRecovery - leader-254: Local TermInfo store seeded with TermInfo{term=0} 12:00:47,701 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] RaftActor - leader-254: Pekko recovery completed with org.opendaylight.controller.cluster.raft.RecoveryLog@62b9c26 12:00:47,701 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] DefaultConfigParamsImpl - No custom RaftPolicy specified. Using DefaultRaftPolicy 12:00:47,701 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] Follower - leader-254 (Follower): Received TimeoutNow - switching to Candidate 12:00:47,701 AM [main] [DEBUG] RaftActor - leader-254: Applying state for log index 5 data F 12:00:47,701 AM [main] [INFO] MockRaftActor - leader-254: applyState called: F 12:00:47,701 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] Candidate - leader-254 (Candidate): Election: Candidate has following voting peers: [] 12:00:47,703 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] PropertiesTermInfoStore - leader-254: Set currentTerm=1, votedFor=leader-254 12:00:47,703 AM [test-pekko.actor.default-dispatcher-7] [INFO] Candidate - leader-254 (Candidate): Starting new election term 1 12:00:47,703 AM [test-pekko.actor.default-dispatcher-7] [INFO] RaftActorBehavior - leader-254 (Follower) :- Switching from behavior Follower to Candidate, election term: 1 12:00:47,703 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] Candidate - leader-254 (Candidate): Received ElectionTimeout 12:00:47,704 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] AbstractLeader - leader-254 (Leader): Election: Leader has following peers: [] 12:00:47,704 AM [test-pekko.actor.default-dispatcher-7] [INFO] RaftActorBehavior - leader-254 (Candidate) :- Switching from behavior Candidate to Leader, election term: 1 12:00:47,704 AM [main] [INFO] TestActorFactory - Killing actor TestActor[pekko://test/user/leader-254] 12:00:47,715 AM [main] [DEBUG] PekkoRaftStorage - leader-254: terminating thread VirtualThread[#682,leader-254-writer-108]/waiting 12:00:47,715 AM [leader-254-writer-108] [DEBUG] JournalWriteTask - leader-254: received 1 commands after 18.19 ms 12:00:47,715 AM [leader-254-writer-108] [DEBUG] JournalWriteTask - leader-254: completed 1 commands in 18.81 μs 12:00:47,715 AM [leader-254-writer-108] [DEBUG] JournalWriteTask - leader-254: journal writer stopped 12:00:47,715 AM [main] [DEBUG] EntryJournalV1 - leader-254: journal closed 12:00:47,715 AM [main] [INFO] PekkoRaftStorage - leader-254: journal closed 12:00:47,715 AM [main] [DEBUG] RaftStorage - leader-254: stopped executor with 0 remaining tasks 12:00:47,715 AM [main] [DEBUG] RaftStorage - leader-254: stopped executor with 0 remaining tasks [WARN] [07/02/2025 00:00:47.718] [test-pekko.actor.default-dispatcher-7] [pekko://test/user/termination-monitor] received dead letter from TestActor[pekko://test/user/follower-255]: org.opendaylight.controller.cluster.common.actor.Monitor@62821083 12:00:47,719 AM [test-pekko.actor.default-dispatcher-11] [INFO] RaftActor - follower-255: Starting recovery with journal batch size 1000 12:00:47,719 AM [test-pekko.actor.default-dispatcher-11] [DEBUG] RaftStorage - follower-255: started executor 12:00:47,720 AM [test-pekko.actor.default-dispatcher-11] [DEBUG] RaftStorage - follower-255: started executor 12:00:47,720 AM [test-pekko.actor.default-dispatcher-11] [DEBUG] EntryJournalV1 - follower-255: metadata journal open: replayFrom=1 applyTo=0 12:00:47,721 AM [test-pekko.actor.default-dispatcher-11] [DEBUG] EntryJournalV1 - follower-255: journal open: firstIndex=1 lastIndex=0 replayFrom=1 fileEntries=0 12:00:47,721 AM [test-pekko.actor.default-dispatcher-11] [INFO] PekkoRaftStorage - follower-255: journal open: applyTo=0 12:00:47,721 AM [follower-255-writer-109] [DEBUG] JournalWriteTask - follower-255: journal writer started 12:00:47,721 AM [follower-255-writer-109] [DEBUG] JournalWriteTask - follower-255: waiting to receive commands 12:00:47,723 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] PropertiesTermInfoStore - /tmp/org.opendaylight.controller.cluster.raft.RaftActorTest18362462226316669305/follower-255/TermInfo.properties does not exist 12:00:47,723 AM [test-pekko.actor.default-dispatcher-7] [INFO] PekkoRecovery - follower-255: Recovery completed - Switching actor to Follower - last log index = -1, last log term = -1, snapshot index = -1, snapshot term = -1, journal size = 0 12:00:47,726 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] PropertiesTermInfoStore - follower-255: Set currentTerm=0, votedFor=null 12:00:47,726 AM [test-pekko.actor.default-dispatcher-7] [INFO] PekkoRecovery - follower-255: Local TermInfo store seeded with TermInfo{term=0} 12:00:47,726 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] RaftActor - follower-255: Pekko recovery completed with org.opendaylight.controller.cluster.raft.RecoveryLog@19562998 12:00:47,726 AM [main] [INFO] TestActorFactory - Killing actor TestActor[pekko://test/user/follower-255] 12:00:47,727 AM [test-pekko.actor.default-dispatcher-11] [DEBUG] PekkoRaftStorage - follower-255: terminating thread VirtualThread[#683,follower-255-writer-109]/waiting 12:00:47,727 AM [follower-255-writer-109] [DEBUG] JournalWriteTask - follower-255: received 1 commands after 5.435 ms 12:00:47,727 AM [follower-255-writer-109] [DEBUG] JournalWriteTask - follower-255: completed 1 commands in 10.73 μs 12:00:47,727 AM [follower-255-writer-109] [DEBUG] JournalWriteTask - follower-255: journal writer stopped 12:00:47,727 AM [test-pekko.actor.default-dispatcher-11] [DEBUG] EntryJournalV1 - follower-255: journal closed 12:00:47,727 AM [test-pekko.actor.default-dispatcher-11] [INFO] PekkoRaftStorage - follower-255: journal closed 12:00:47,727 AM [test-pekko.actor.default-dispatcher-11] [DEBUG] RaftStorage - follower-255: stopped executor with 0 remaining tasks 12:00:47,727 AM [test-pekko.actor.default-dispatcher-11] [DEBUG] RaftStorage - follower-255: stopped executor with 0 remaining tasks [WARN] [07/02/2025 00:00:47.728] [test-pekko.actor.default-dispatcher-7] [pekko://test/user/termination-monitor] received dead letter from TestActor[pekko://test/user/follower-256]: org.opendaylight.controller.cluster.common.actor.Monitor@65c4bb3d 12:00:47,729 AM [test-pekko.actor.default-dispatcher-11] [INFO] RaftActor - follower-255: Starting recovery with journal batch size 1000 12:00:47,729 AM [test-pekko.actor.default-dispatcher-11] [DEBUG] RaftStorage - follower-255: started executor 12:00:47,729 AM [test-pekko.actor.default-dispatcher-11] [DEBUG] RaftStorage - follower-255: started executor 12:00:47,729 AM [test-pekko.actor.default-dispatcher-11] [DEBUG] EntryJournalV1 - follower-255: metadata journal open: replayFrom=1 applyTo=0 12:00:47,729 AM [test-pekko.actor.default-dispatcher-11] [DEBUG] EntryJournalV1 - follower-255: journal open: firstIndex=1 lastIndex=0 replayFrom=1 fileEntries=0 12:00:47,729 AM [test-pekko.actor.default-dispatcher-11] [INFO] PekkoRaftStorage - follower-255: journal open: applyTo=0 12:00:47,730 AM [follower-255-writer-110] [DEBUG] JournalWriteTask - follower-255: journal writer started 12:00:47,730 AM [follower-255-writer-110] [DEBUG] JournalWriteTask - follower-255: waiting to receive commands 12:00:47,731 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] PropertiesTermInfoStore - follower-255: Set currentTerm=0, votedFor=null 12:00:47,731 AM [test-pekko.actor.default-dispatcher-7] [INFO] PekkoRecovery - follower-255: Recovery completed - Switching actor to Follower - last log index = -1, last log term = -1, snapshot index = -1, snapshot term = -1, journal size = 0 12:00:47,731 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] PekkoRecovery - follower-255: restoring local TermInfo{term=0} 12:00:47,731 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] PropertiesTermInfoStore - follower-255: Set currentTerm=0, votedFor=null 12:00:47,731 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] RaftActor - follower-255: Pekko recovery completed with org.opendaylight.controller.cluster.raft.RecoveryLog@7e473eda 12:00:47,731 AM [main] [INFO] TestActorFactory - Killing actor TestActor[pekko://test/user/follower-256] 12:00:47,731 AM [test-pekko.actor.default-dispatcher-11] [DEBUG] PekkoRaftStorage - follower-255: terminating thread VirtualThread[#684,follower-255-writer-110]/waiting 12:00:47,732 AM [follower-255-writer-110] [DEBUG] JournalWriteTask - follower-255: received 1 commands after 1.981 ms 12:00:47,732 AM [follower-255-writer-110] [DEBUG] JournalWriteTask - follower-255: completed 1 commands in 10.06 μs 12:00:47,732 AM [follower-255-writer-110] [DEBUG] JournalWriteTask - follower-255: journal writer stopped 12:00:47,732 AM [test-pekko.actor.default-dispatcher-11] [DEBUG] EntryJournalV1 - follower-255: journal closed 12:00:47,732 AM [test-pekko.actor.default-dispatcher-11] [INFO] PekkoRaftStorage - follower-255: journal closed 12:00:47,732 AM [test-pekko.actor.default-dispatcher-11] [DEBUG] RaftStorage - follower-255: stopped executor with 0 remaining tasks 12:00:47,732 AM [test-pekko.actor.default-dispatcher-11] [DEBUG] RaftStorage - follower-255: stopped executor with 0 remaining tasks 12:00:47,733 AM [main] [INFO] RaftActorTest - testNonVotingOnRecovery starting [WARN] [07/02/2025 00:00:47.734] [test-pekko.actor.default-dispatcher-7] [pekko://test/user/termination-monitor] received dead letter from TestActor[pekko://test/user/test-actor-257]: org.opendaylight.controller.cluster.common.actor.Monitor@46847d99 12:00:47,735 AM [test-pekko.actor.default-dispatcher-11] [INFO] RaftActor - test-actor-257: Starting recovery with journal batch size 1000 12:00:47,735 AM [test-pekko.actor.default-dispatcher-11] [DEBUG] RaftStorage - test-actor-257: started executor 12:00:47,735 AM [test-pekko.actor.default-dispatcher-11] [DEBUG] RaftStorage - test-actor-257: started executor 12:00:47,735 AM [test-pekko.actor.default-dispatcher-11] [DEBUG] EntryJournalV1 - test-actor-257: metadata journal open: replayFrom=1 applyTo=0 12:00:47,736 AM [test-pekko.actor.default-dispatcher-11] [DEBUG] EntryJournalV1 - test-actor-257: journal open: firstIndex=1 lastIndex=0 replayFrom=1 fileEntries=0 12:00:47,736 AM [test-pekko.actor.default-dispatcher-11] [INFO] PekkoRaftStorage - test-actor-257: journal open: applyTo=0 12:00:47,736 AM [test-actor-257-writer-111] [DEBUG] JournalWriteTask - test-actor-257: journal writer started 12:00:47,736 AM [test-actor-257-writer-111] [DEBUG] JournalWriteTask - test-actor-257: waiting to receive commands 12:00:47,737 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] PropertiesTermInfoStore - /tmp/org.opendaylight.controller.cluster.raft.RaftActorTest9736307931691669323/test-actor-257/TermInfo.properties does not exist 12:00:47,737 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] RaftStorage - test-actor-257: skipping unrecognized file /tmp/org.opendaylight.controller.cluster.raft.RaftActorTest9736307931691669323/test-actor-257/journal-v1-1.log 12:00:47,737 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] RaftStorage - test-actor-257: skipping unrecognized file /tmp/org.opendaylight.controller.cluster.raft.RaftActorTest9736307931691669323/test-actor-257/metadata-v1-1.log 12:00:47,737 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] RaftStorage - test-actor-257: no eligible files found 12:00:47,737 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] PekkoRecovery - test-actor-257: Received ReplicatedLogEntry for recovery: index: 0, size: 131 12:00:47,737 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] PeerInfos - test-actor-257: Updated server config: isVoting: false, peers: [] 12:00:47,737 AM [test-pekko.actor.default-dispatcher-7] [INFO] PekkoRecovery - test-actor-257: Recovery completed - Switching actor to Follower - last log index = 0, last log term = 1, snapshot index = -1, snapshot term = -1, journal size = 1 12:00:47,740 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] PropertiesTermInfoStore - test-actor-257: Set currentTerm=0, votedFor=null 12:00:47,740 AM [test-pekko.actor.default-dispatcher-7] [INFO] PekkoRecovery - test-actor-257: Local TermInfo store seeded with TermInfo{term=0} 12:00:47,740 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] RaftActor - test-actor-257: Pekko recovery completed with org.opendaylight.controller.cluster.raft.RecoveryLog@69aea69a 12:00:47,740 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] AbstractReplicatedLog - test-actor-257: Moving last applied index from -1 to -1 12:00:47,740 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] JournalRecovery - test-actor-257: empty journal: appending 1 entries 12:00:47,740 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] EntryJournalV1 - test-actor-257: updated meta to JournalMeta[replayFrom=1, applyTo=0] 12:00:47,744 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] JournalRecovery - test-actor-257: journal recovery completedin 3.627 ms with journalIndex=1 12:00:47,744 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] DefaultConfigParamsImpl - No custom RaftPolicy specified. Using DefaultRaftPolicy 12:00:48,144 AM [main] [INFO] RaftActorTest - testNonVotingOnRecovery ending 12:00:48,144 AM [main] [INFO] TestActorFactory - Killing actor TestActor[pekko://test/user/test-actor-257] 12:00:48,155 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] PekkoRaftStorage - test-actor-257: terminating thread VirtualThread[#685,test-actor-257-writer-111]/waiting 12:00:48,155 AM [test-actor-257-writer-111] [DEBUG] JournalWriteTask - test-actor-257: received 1 commands after 419.6 ms 12:00:48,155 AM [test-actor-257-writer-111] [DEBUG] JournalWriteTask - test-actor-257: completed 1 commands in 17.92 μs 12:00:48,156 AM [test-actor-257-writer-111] [DEBUG] JournalWriteTask - test-actor-257: journal writer stopped 12:00:48,156 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] EntryJournalV1 - test-actor-257: journal closed 12:00:48,156 AM [test-pekko.actor.default-dispatcher-7] [INFO] PekkoRaftStorage - test-actor-257: journal closed 12:00:48,156 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] RaftStorage - test-actor-257: stopped executor with 0 remaining tasks 12:00:48,156 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] RaftStorage - test-actor-257: stopped executor with 0 remaining tasks 12:00:48,158 AM [main] [INFO] RaftActorTest - testRaftActorRecoveryWithPersistenceEnabled starting [WARN] [07/02/2025 00:00:48.159] [test-pekko.actor.default-dispatcher-11] [pekko://test/user/termination-monitor] received dead letter from Actor[pekko://test/user/follower-258#1605804707]: org.opendaylight.controller.cluster.common.actor.Monitor@753afed8 12:00:48,160 AM [test-pekko.actor.default-dispatcher-7] [INFO] RaftActor - follower-258: Starting recovery with journal batch size 1000 12:00:48,160 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] RaftStorage - follower-258: started executor 12:00:48,160 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] RaftStorage - follower-258: started executor 12:00:48,161 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] EntryJournalV1 - follower-258: metadata journal open: replayFrom=1 applyTo=0 12:00:48,162 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] EntryJournalV1 - follower-258: journal open: firstIndex=1 lastIndex=0 replayFrom=1 fileEntries=0 12:00:48,162 AM [test-pekko.actor.default-dispatcher-7] [INFO] PekkoRaftStorage - follower-258: journal open: applyTo=0 12:00:48,162 AM [follower-258-writer-112] [DEBUG] JournalWriteTask - follower-258: journal writer started 12:00:48,162 AM [follower-258-writer-112] [DEBUG] JournalWriteTask - follower-258: waiting to receive commands 12:00:48,163 AM [test-pekko.actor.default-dispatcher-11] [DEBUG] PropertiesTermInfoStore - /tmp/org.opendaylight.controller.cluster.raft.RaftActorTest18222069569561665002/follower-258/TermInfo.properties does not exist 12:00:48,164 AM [test-pekko.actor.default-dispatcher-11] [DEBUG] RaftStorage - follower-258: skipping unrecognized file /tmp/org.opendaylight.controller.cluster.raft.RaftActorTest18222069569561665002/follower-258/journal-v1-1.log 12:00:48,164 AM [test-pekko.actor.default-dispatcher-11] [DEBUG] RaftStorage - follower-258: skipping unrecognized file /tmp/org.opendaylight.controller.cluster.raft.RaftActorTest18222069569561665002/follower-258/metadata-v1-1.log 12:00:48,164 AM [test-pekko.actor.default-dispatcher-11] [DEBUG] RaftStorage - follower-258: no eligible files found 12:00:48,164 AM [test-pekko.actor.default-dispatcher-11] [INFO] PekkoRecovery - follower-258: Recovery completed - Switching actor to Follower - last log index = -1, last log term = -1, snapshot index = -1, snapshot term = -1, journal size = 0 12:00:48,167 AM [test-pekko.actor.default-dispatcher-11] [DEBUG] PropertiesTermInfoStore - follower-258: Set currentTerm=0, votedFor=null 12:00:48,167 AM [test-pekko.actor.default-dispatcher-11] [INFO] PekkoRecovery - follower-258: Local TermInfo store seeded with TermInfo{term=0} 12:00:48,167 AM [test-pekko.actor.default-dispatcher-11] [DEBUG] RaftActor - follower-258: Pekko recovery completed with org.opendaylight.controller.cluster.raft.RecoveryLog@4c93f34a 12:00:48,167 AM [test-pekko.actor.default-dispatcher-11] [DEBUG] AbstractReplicatedLog - follower-258: Moving last applied index from -1 to -1 12:00:48,167 AM [test-pekko.actor.default-dispatcher-11] [DEBUG] JournalRecovery - follower-258: empty journal: appending 0 entries 12:00:48,167 AM [test-pekko.actor.default-dispatcher-11] [DEBUG] EntryJournalV1 - follower-258: updated meta to JournalMeta[replayFrom=1, applyTo=0] 12:00:48,168 AM [test-pekko.actor.default-dispatcher-11] [DEBUG] JournalRecovery - follower-258: journal recovery completedin 544.4 μs with journalIndex=1 12:00:48,175 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] PekkoRaftStorage - follower-258: terminating thread VirtualThread[#686,follower-258-writer-112]/waiting 12:00:48,175 AM [follower-258-writer-112] [DEBUG] JournalWriteTask - follower-258: received 1 commands after 12.93 ms 12:00:48,175 AM [follower-258-writer-112] [DEBUG] JournalWriteTask - follower-258: completed 1 commands in 13.74 μs 12:00:48,175 AM [follower-258-writer-112] [DEBUG] JournalWriteTask - follower-258: journal writer stopped 12:00:48,175 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] EntryJournalV1 - follower-258: journal closed 12:00:48,175 AM [test-pekko.actor.default-dispatcher-7] [INFO] PekkoRaftStorage - follower-258: journal closed 12:00:48,175 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] RaftStorage - follower-258: stopped executor with 0 remaining tasks 12:00:48,175 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] RaftStorage - follower-258: stopped executor with 0 remaining tasks [WARN] [07/02/2025 00:00:48.176] [test-pekko.actor.default-dispatcher-7] [pekko://test/user/termination-monitor] received dead letter from TestActor[pekko://test/user/$$a]: org.opendaylight.controller.cluster.common.actor.Monitor@45dd4f8a 12:00:48,177 AM [main] [INFO] RaftActor - follower-258: Starting recovery with journal batch size 1000 12:00:48,177 AM [main] [DEBUG] RaftStorage - follower-258: started executor 12:00:48,178 AM [main] [DEBUG] RaftStorage - follower-258: started executor 12:00:48,178 AM [main] [DEBUG] EntryJournalV1 - follower-258: metadata journal open: replayFrom=1 applyTo=0 12:00:48,180 AM [main] [DEBUG] EntryJournalV1 - follower-258: journal open: firstIndex=1 lastIndex=0 replayFrom=1 fileEntries=0 12:00:48,180 AM [main] [INFO] PekkoRaftStorage - follower-258: journal open: applyTo=0 12:00:48,180 AM [follower-258-writer-113] [DEBUG] JournalWriteTask - follower-258: journal writer started 12:00:48,180 AM [follower-258-writer-113] [DEBUG] JournalWriteTask - follower-258: waiting to receive commands 12:00:48,181 AM [test-pekko.persistence.dispatchers.default-plugin-dispatcher-14] [DEBUG] PropertiesTermInfoStore - follower-258: Set currentTerm=0, votedFor=null 12:00:48,181 AM [test-pekko.persistence.dispatchers.default-plugin-dispatcher-14] [DEBUG] RaftStorage - follower-258: skipping unrecognized file /tmp/org.opendaylight.controller.cluster.raft.RaftActorTest18222069569561665002/follower-258/TermInfo.properties 12:00:48,181 AM [test-pekko.persistence.dispatchers.default-plugin-dispatcher-14] [DEBUG] RaftStorage - follower-258: skipping unrecognized file /tmp/org.opendaylight.controller.cluster.raft.RaftActorTest18222069569561665002/follower-258/journal-v1-1.log 12:00:48,181 AM [test-pekko.persistence.dispatchers.default-plugin-dispatcher-14] [DEBUG] RaftStorage - follower-258: skipping unrecognized file /tmp/org.opendaylight.controller.cluster.raft.RaftActorTest18222069569561665002/follower-258/metadata-v1-1.log 12:00:48,181 AM [test-pekko.persistence.dispatchers.default-plugin-dispatcher-14] [DEBUG] RaftStorage - follower-258: no eligible files found 12:00:48,181 AM [test-pekko.persistence.dispatchers.default-plugin-dispatcher-14] [DEBUG] PekkoRecovery - follower-258: SnapshotOffer called. 12:00:48,181 AM [test-pekko.persistence.dispatchers.default-plugin-dispatcher-14] [DEBUG] PekkoRecovery - follower-258: initializing from snapshot taken at 2025-07-02T00:00:48.174Z 12:00:48,182 AM [test-pekko.persistence.dispatchers.default-plugin-dispatcher-14] [DEBUG] PropertiesTermInfoStore - follower-258: Set currentTerm=-1, votedFor=null 12:00:48,182 AM [test-pekko.persistence.dispatchers.default-plugin-dispatcher-14] [INFO] PekkoRecovery - Recovery snapshot applied for follower-258 in 353.7 μs: snapshotIndex=3, snapshotTerm=1, journal-size=1 12:00:48,182 AM [test-pekko.persistence.dispatchers.default-plugin-dispatcher-14] [INFO] PekkoRecovery - follower-258: migrating from Pekko persistent-snapshot taken at 2025-07-02T00:00:48.174Z 12:00:48,182 AM [test-pekko.persistence.dispatchers.default-plugin-dispatcher-14] [INFO] MockRaftActor - follower-258: support() called 12:00:48,182 AM [test-pekko.persistence.dispatchers.default-plugin-dispatcher-14] [DEBUG] RaftStorage - follower-258: starting snapshot writeout to /tmp/org.opendaylight.controller.cluster.raft.RaftActorTest18222069569561665002/follower-258/snapshot-00000000686476B0-0A5F0780.tmp 12:00:48,186 AM [test-pekko.persistence.dispatchers.default-plugin-dispatcher-14] [DEBUG] RaftStorage - follower-258: finished snapshot writeout to /tmp/org.opendaylight.controller.cluster.raft.RaftActorTest18222069569561665002/follower-258/snapshot-00000000686476B0-0A5F0780.v1 12:00:48,186 AM [test-pekko.persistence.dispatchers.default-plugin-dispatcher-14] [DEBUG] RaftStorage - follower-258: skipping unrecognized file /tmp/org.opendaylight.controller.cluster.raft.RaftActorTest18222069569561665002/follower-258/TermInfo.properties 12:00:48,186 AM [test-pekko.persistence.dispatchers.default-plugin-dispatcher-14] [DEBUG] RaftStorage - follower-258: skipping unrecognized file /tmp/org.opendaylight.controller.cluster.raft.RaftActorTest18222069569561665002/follower-258/journal-v1-1.log 12:00:48,186 AM [test-pekko.persistence.dispatchers.default-plugin-dispatcher-14] [DEBUG] RaftStorage - follower-258: skipping unrecognized file /tmp/org.opendaylight.controller.cluster.raft.RaftActorTest18222069569561665002/follower-258/metadata-v1-1.log 12:00:48,187 AM [test-pekko.persistence.dispatchers.default-plugin-dispatcher-14] [DEBUG] RaftStorage - follower-258: selected SNAPSHOT_V1 to handle file /tmp/org.opendaylight.controller.cluster.raft.RaftActorTest18222069569561665002/follower-258/snapshot-00000000686476B0-0A5F0780.v1 12:00:48,187 AM [test-pekko.persistence.dispatchers.default-plugin-dispatcher-14] [DEBUG] RaftStorage - follower-258: retaining snapshot SnapshotFileV1{lastIncluded=EntryInfo[index=3, term=1], timestamp=2025-07-02T00:00:48.174Z, file=/tmp/org.opendaylight.controller.cluster.raft.RaftActorTest18222069569561665002/follower-258/snapshot-00000000686476B0-0A5F0780.v1, size=513, entryCompress=NONE, stateCompress=NONE} 12:00:48,187 AM [test-pekko.persistence.dispatchers.default-plugin-dispatcher-14] [INFO] PekkoRecovery - follower-258: local snapshot saved in 4.672 ms, deleting Pekko-persisted snapshots 12:00:48,190 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] PekkoRecovery - follower-258: Received ReplicatedLogEntry for recovery: index: 5, size: 2 12:00:48,190 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] PekkoRecovery - follower-258: Received apply journal entries for recovery, applying to state: 4 to 5 12:00:48,190 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] AbstractReplicatedLog - follower-258: Moving last applied index from 3 to 5 12:00:48,190 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] PekkoRecovery - follower-258: Received ReplicatedLogEntry for recovery: index: 6, size: 3 12:00:48,190 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] PekkoRecovery - follower-258: Received ReplicatedLogEntry for recovery: index: 7, size: 4 12:00:48,190 AM [test-pekko.actor.default-dispatcher-7] [INFO] PekkoRecovery - follower-258: Recovery completed in 8.642 ms - Switching actor to Follower - last log index = 7, last log term = 1, snapshot index = 3, snapshot term = 1, journal size = 4 12:00:48,190 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] PekkoRecovery - follower-258: restoring local TermInfo{term=0} 12:00:48,190 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] PropertiesTermInfoStore - follower-258: Set currentTerm=0, votedFor=null 12:00:48,190 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] RaftActor - follower-258: Pekko recovery completed with org.opendaylight.controller.cluster.raft.RecoveryLog@4db55ffe 12:00:48,190 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] AbstractReplicatedLog - follower-258: Moving last applied index from -1 to 5 12:00:48,190 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] JournalRecovery - follower-258: empty journal: appending 4 entries 12:00:48,191 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] EntryJournalV1 - follower-258: updated meta to JournalMeta[replayFrom=1, applyTo=0] 12:00:48,198 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] JournalRecovery - follower-258: journal recovery completedin 8.073 ms with journalIndex=1 12:00:48,199 AM [main] [INFO] RaftActorTest - testRaftActorRecoveryWithPersistenceEnabled ending 12:00:48,199 AM [main] [INFO] TestActorFactory - Killing actor Actor[pekko://test/user/follower-258#1605804707] 12:00:48,199 AM [test-pekko.persistence.dispatchers.default-plugin-dispatcher-14] [DEBUG] RaftActor - follower-258: ignoring DeleteSnapshotsSuccess(SnapshotSelectionCriteria(9223372036854775807,9223372036854775807,0,0)) 12:00:48,210 AM [main] [INFO] TestActorFactory - Killing actor TestActor[pekko://test/user/$$a] 12:00:48,210 AM [main] [DEBUG] PekkoRaftStorage - follower-258: terminating thread VirtualThread[#687,follower-258-writer-113]/waiting 12:00:48,210 AM [follower-258-writer-113] [DEBUG] JournalWriteTask - follower-258: received 1 commands after 30.34 ms 12:00:48,210 AM [follower-258-writer-113] [DEBUG] JournalWriteTask - follower-258: completed 1 commands in 10.66 μs 12:00:48,210 AM [follower-258-writer-113] [DEBUG] JournalWriteTask - follower-258: journal writer stopped 12:00:48,211 AM [main] [DEBUG] EntryJournalV1 - follower-258: journal closed 12:00:48,211 AM [main] [INFO] PekkoRaftStorage - follower-258: journal closed 12:00:48,211 AM [main] [DEBUG] RaftStorage - follower-258: stopped executor with 0 remaining tasks 12:00:48,211 AM [main] [DEBUG] RaftStorage - follower-258: stopped executor with 0 remaining tasks [WARN] [07/02/2025 00:00:48.214] [test-pekko.actor.default-dispatcher-11] [pekko://test/user/termination-monitor] received dead letter from TestActor[pekko://test/user/leader-259]: org.opendaylight.controller.cluster.common.actor.Monitor@6d24ad2b 12:00:48,215 AM [main] [INFO] RaftActor - leader-259: Starting recovery with journal batch size 1000 12:00:48,215 AM [main] [DEBUG] RaftStorage - leader-259: started executor 12:00:48,215 AM [main] [DEBUG] RaftStorage - leader-259: started executor 12:00:48,216 AM [main] [DEBUG] EntryJournalV1 - leader-259: metadata journal open: replayFrom=1 applyTo=0 12:00:48,216 AM [main] [DEBUG] EntryJournalV1 - leader-259: journal open: firstIndex=1 lastIndex=0 replayFrom=1 fileEntries=0 12:00:48,216 AM [main] [INFO] PekkoRaftStorage - leader-259: journal open: applyTo=0 12:00:48,216 AM [leader-259-writer-114] [DEBUG] JournalWriteTask - leader-259: journal writer started 12:00:48,216 AM [leader-259-writer-114] [DEBUG] JournalWriteTask - leader-259: waiting to receive commands 12:00:48,218 AM [test-pekko.actor.default-dispatcher-11] [DEBUG] PropertiesTermInfoStore - /tmp/org.opendaylight.controller.cluster.raft.RaftActorTest7160941558126748442/leader-259/TermInfo.properties does not exist 12:00:48,218 AM [test-pekko.actor.default-dispatcher-11] [INFO] PekkoRecovery - leader-259: Recovery completed - Switching actor to Follower - last log index = -1, last log term = -1, snapshot index = -1, snapshot term = -1, journal size = 0 12:00:48,220 AM [test-pekko.actor.default-dispatcher-11] [DEBUG] PropertiesTermInfoStore - leader-259: Set currentTerm=0, votedFor=null 12:00:48,220 AM [test-pekko.actor.default-dispatcher-11] [INFO] PekkoRecovery - leader-259: Local TermInfo store seeded with TermInfo{term=0} 12:00:48,220 AM [test-pekko.actor.default-dispatcher-11] [DEBUG] RaftActor - leader-259: Pekko recovery completed with org.opendaylight.controller.cluster.raft.RecoveryLog@3c7fcd7 12:00:48,220 AM [main] [DEBUG] AbstractReplicatedLog - leader-259: Moving last applied index from -1 to 3 12:00:48,220 AM [main] [DEBUG] PropertiesTermInfoStore - leader-259: Set currentTerm=1, votedFor=leader-259 12:00:48,220 AM [main] [DEBUG] AbstractLeader - leader-259 (Leader): Election: Leader has following peers: [member1] 12:00:48,220 AM [main] [DEBUG] AbstractLeader - leader-259 (Leader): Checking sendAppendEntries for follower member1: active: false, followerNextIndex: 3, leaderLastIndex: 3, leaderSnapShotIndex: 3 [WARN] [07/02/2025 00:00:48.221] [test-pekko.actor.default-dispatcher-7] [pekko://test/user/leader-259/address] received dead letter from TestActor[pekko://test/user/leader-259]: AppendEntries{term=1, leaderId=leader-259, prevLogIndex=-1, prevLogTerm=-1, leaderCommit=-1, replicatedToAllIndex=-1, payloadVersion=5, recipientRaftVersion=4, leaderRaftVersion=5, entries==[]} 12:00:48,221 AM [main] [DEBUG] RaftActor - leader-259: Persist data index=4 term=1 command=duh 12:00:48,221 AM [main] [DEBUG] ReplicatedLogImpl - leader-259: Append log entry and persist JournaledLogEntry{index=4, term=1, command=duh, pending=true} 12:00:48,221 AM [main] [DEBUG] RaftStorageCompleter - test: 1 completion(s) pending 12:00:48,221 AM [main] [DEBUG] RaftStorageCompleter - test: running 1 completion(s) 12:00:48,221 AM [main] [DEBUG] ReplicatedLogImpl - leader-259: persist complete JournaledLogEntry{index=4, term=1, command=duh, pending=true} 12:00:48,221 AM [main] [INFO] SnapshotManager - leader-259: Initiating snapshot capture CaptureSnapshot [lastAppliedIndex=3, lastAppliedTerm=-1, lastIndex=4, lastTerm=1, installSnapshotInitiated=, replicatedToAllIndex=-1, replicatedToAllTerm=-1, unAppliedEntries size=1, mandatoryTrim=false] 12:00:48,221 AM [main] [DEBUG] SnapshotManager - leader-259: captured snapshot at lastSequenceNumber: 0 12:00:48,221 AM [main] [INFO] SnapshotManager - leader-259: Persising snapshot at EntryInfo[index=3, term=-1]/EntryInfo[index=4, term=1] 12:00:48,221 AM [main] [INFO] MockRaftActor - leader-259: support() called 12:00:48,221 AM [main] [INFO] SnapshotManager - leader-259: Removed in-memory snapshotted entries, adjusted snaphsotIndex: 3 and term: -1 12:00:48,222 AM [main] [DEBUG] AbstractLeader - leader-259 (Leader): Replicate message: identifier: MockIdentifier{value=x}, logIndex: 4, isSendImmediate: true 12:00:48,222 AM [main] [DEBUG] DefaultConfigParamsImpl - No custom RaftPolicy specified. Using DefaultRaftPolicy 12:00:48,222 AM [main] [DEBUG] AbstractLeader - leader-259 (Leader): Checking sendAppendEntries for follower member1: active: false, followerNextIndex: 3, leaderLastIndex: 4, leaderSnapShotIndex: 3 [WARN] [07/02/2025 00:00:48.222] [test-pekko.actor.default-dispatcher-7] [pekko://test/user/leader-259/address] received dead letter from TestActor[pekko://test/user/leader-259]: AppendEntries{term=1, leaderId=leader-259, prevLogIndex=-1, prevLogTerm=-1, leaderCommit=-1, replicatedToAllIndex=3, payloadVersion=5, recipientRaftVersion=4, leaderRaftVersion=5, entries==[]} 12:00:48,222 AM [main] [INFO] TestActorFactory - Killing actor TestActor[pekko://test/user/leader-259] 12:00:48,233 AM [main] [DEBUG] PekkoRaftStorage - leader-259: terminating thread VirtualThread[#688,leader-259-writer-114]/waiting 12:00:48,233 AM [leader-259-writer-114] [DEBUG] JournalWriteTask - leader-259: received 1 commands after 16.34 ms 12:00:48,233 AM [leader-259-writer-114] [DEBUG] JournalWriteTask - leader-259: completed 1 commands in 12.67 μs 12:00:48,233 AM [leader-259-writer-114] [DEBUG] JournalWriteTask - leader-259: journal writer stopped 12:00:48,233 AM [main] [DEBUG] EntryJournalV1 - leader-259: journal closed 12:00:48,233 AM [main] [INFO] PekkoRaftStorage - leader-259: journal closed 12:00:48,233 AM [main] [DEBUG] RaftStorage - leader-259: stopped executor with 0 remaining tasks 12:00:48,233 AM [main] [DEBUG] RaftStorage - leader-259: stopped executor with 0 remaining tasks [WARN] [07/02/2025 00:00:48.237] [test-pekko.actor.default-dispatcher-7] [pekko://test/user/termination-monitor] received dead letter from TestActor[pekko://test/user/notifier-260]: org.opendaylight.controller.cluster.common.actor.Monitor@68f487b2 12:00:48,238 AM [test-pekko.actor.default-dispatcher-11] [INFO] RaftActor - notifier-260: Starting recovery with journal batch size 1000 12:00:48,238 AM [test-pekko.actor.default-dispatcher-11] [DEBUG] RaftStorage - notifier-260: started executor 12:00:48,238 AM [test-pekko.actor.default-dispatcher-11] [DEBUG] RaftStorage - notifier-260: started executor 12:00:48,239 AM [test-pekko.actor.default-dispatcher-11] [DEBUG] EntryJournalV1 - notifier-260: metadata journal open: replayFrom=1 applyTo=0 12:00:48,240 AM [test-pekko.actor.default-dispatcher-11] [DEBUG] EntryJournalV1 - notifier-260: journal open: firstIndex=1 lastIndex=0 replayFrom=1 fileEntries=0 12:00:48,240 AM [test-pekko.actor.default-dispatcher-11] [INFO] PekkoRaftStorage - notifier-260: journal open: applyTo=0 12:00:48,240 AM [notifier-260-writer-115] [DEBUG] JournalWriteTask - notifier-260: journal writer started 12:00:48,240 AM [notifier-260-writer-115] [DEBUG] JournalWriteTask - notifier-260: waiting to receive commands 12:00:48,241 AM [test-pekko.actor.default-dispatcher-11] [DEBUG] PropertiesTermInfoStore - /tmp/org.opendaylight.controller.cluster.raft.RaftActorTest9139196713095145980/notifier-260/TermInfo.properties does not exist 12:00:48,241 AM [test-pekko.actor.default-dispatcher-11] [INFO] PekkoRecovery - notifier-260: Recovery completed - Switching actor to Follower - last log index = -1, last log term = -1, snapshot index = -1, snapshot term = -1, journal size = 0 12:00:48,245 AM [test-pekko.actor.default-dispatcher-11] [DEBUG] PropertiesTermInfoStore - notifier-260: Set currentTerm=0, votedFor=null 12:00:48,245 AM [test-pekko.actor.default-dispatcher-11] [INFO] PekkoRecovery - notifier-260: Local TermInfo store seeded with TermInfo{term=0} 12:00:48,245 AM [test-pekko.actor.default-dispatcher-11] [DEBUG] RaftActor - notifier-260: Pekko recovery completed with org.opendaylight.controller.cluster.raft.RecoveryLog@ea47bdb 12:00:48,246 AM [test-pekko.actor.default-dispatcher-11] [DEBUG] DefaultConfigParamsImpl - No custom RaftPolicy specified. Using DefaultRaftPolicy 12:00:48,246 AM [test-pekko.actor.default-dispatcher-11] [DEBUG] Follower - notifier-260 (Follower): Received TimeoutNow - switching to Candidate 12:00:48,246 AM [test-pekko.actor.default-dispatcher-11] [DEBUG] Candidate - notifier-260 (Candidate): Election: Candidate has following voting peers: [] 12:00:48,249 AM [test-pekko.actor.default-dispatcher-11] [DEBUG] PropertiesTermInfoStore - notifier-260: Set currentTerm=1, votedFor=notifier-260 12:00:48,249 AM [test-pekko.actor.default-dispatcher-11] [INFO] Candidate - notifier-260 (Candidate): Starting new election term 1 12:00:48,249 AM [test-pekko.actor.default-dispatcher-11] [INFO] RaftActorBehavior - notifier-260 (Follower) :- Switching from behavior Follower to Candidate, election term: 1 12:00:48,249 AM [test-pekko.actor.default-dispatcher-11] [DEBUG] Candidate - notifier-260 (Candidate): Received ElectionTimeout 12:00:48,249 AM [test-pekko.actor.default-dispatcher-11] [DEBUG] AbstractLeader - notifier-260 (Leader): Election: Leader has following peers: [] 12:00:48,249 AM [test-pekko.actor.default-dispatcher-11] [INFO] RaftActorBehavior - notifier-260 (Candidate) :- Switching from behavior Candidate to Leader, election term: 1 [WARN] [07/02/2025 00:00:48.291] [test-pekko.actor.default-dispatcher-12] [pekko://test/user/notifier-260] unhandled message from TestActor[pekko://test/user/notifier-260]: org.opendaylight.controller.cluster.raft.base.messages.TimeoutNow@10823d72 12:00:48,847 AM [main] [INFO] TestActorFactory - Killing actor Actor[pekko://test/user/$e#114112710] 12:00:48,849 AM [main] [INFO] TestActorFactory - Killing actor TestActor[pekko://test/user/notifier-260] 12:00:48,849 AM [test-pekko.actor.default-dispatcher-11] [DEBUG] PekkoRaftStorage - notifier-260: terminating thread VirtualThread[#689,notifier-260-writer-115]/waiting 12:00:48,849 AM [notifier-260-writer-115] [DEBUG] JournalWriteTask - notifier-260: received 1 commands after 609.2 ms 12:00:48,849 AM [notifier-260-writer-115] [DEBUG] JournalWriteTask - notifier-260: completed 1 commands in 20.70 μs 12:00:48,849 AM [notifier-260-writer-115] [DEBUG] JournalWriteTask - notifier-260: journal writer stopped 12:00:48,849 AM [test-pekko.actor.default-dispatcher-11] [DEBUG] EntryJournalV1 - notifier-260: journal closed 12:00:48,850 AM [test-pekko.actor.default-dispatcher-11] [INFO] PekkoRaftStorage - notifier-260: journal closed 12:00:48,850 AM [test-pekko.actor.default-dispatcher-11] [DEBUG] RaftStorage - notifier-260: stopped executor with 0 remaining tasks 12:00:48,850 AM [test-pekko.actor.default-dispatcher-11] [DEBUG] RaftStorage - notifier-260: stopped executor with 0 remaining tasks [WARN] [07/02/2025 00:00:48.852] [test-pekko.actor.default-dispatcher-11] [pekko://test/user/termination-monitor] received dead letter from TestActor[pekko://test/user/follower-261]: org.opendaylight.controller.cluster.common.actor.Monitor@27f0cf3a 12:00:48,853 AM [main] [INFO] RaftActor - follower-261: Starting recovery with journal batch size 1000 12:00:48,853 AM [main] [DEBUG] RaftStorage - follower-261: started executor 12:00:48,853 AM [main] [DEBUG] RaftStorage - follower-261: started executor 12:00:48,853 AM [main] [DEBUG] EntryJournalV1 - follower-261: metadata journal open: replayFrom=1 applyTo=0 12:00:48,854 AM [main] [DEBUG] EntryJournalV1 - follower-261: journal open: firstIndex=1 lastIndex=0 replayFrom=1 fileEntries=0 12:00:48,854 AM [main] [INFO] PekkoRaftStorage - follower-261: journal open: applyTo=0 12:00:48,854 AM [follower-261-writer-116] [DEBUG] JournalWriteTask - follower-261: journal writer started 12:00:48,854 AM [follower-261-writer-116] [DEBUG] JournalWriteTask - follower-261: waiting to receive commands 12:00:48,855 AM [test-pekko.actor.default-dispatcher-11] [DEBUG] PropertiesTermInfoStore - /tmp/org.opendaylight.controller.cluster.raft.RaftActorTest13471211843604187134/follower-261/TermInfo.properties does not exist 12:00:48,855 AM [test-pekko.actor.default-dispatcher-11] [INFO] PekkoRecovery - follower-261: Recovery completed - Switching actor to Follower - last log index = -1, last log term = -1, snapshot index = -1, snapshot term = -1, journal size = 0 12:00:48,857 AM [test-pekko.actor.default-dispatcher-11] [DEBUG] PropertiesTermInfoStore - follower-261: Set currentTerm=0, votedFor=null 12:00:48,857 AM [test-pekko.actor.default-dispatcher-11] [INFO] PekkoRecovery - follower-261: Local TermInfo store seeded with TermInfo{term=0} 12:00:48,857 AM [test-pekko.actor.default-dispatcher-11] [DEBUG] RaftActor - follower-261: Pekko recovery completed with org.opendaylight.controller.cluster.raft.RecoveryLog@61e9eae9 12:00:48,858 AM [main] [INFO] TestActorFactory - Killing actor TestActor[pekko://test/user/follower-261] 12:00:48,858 AM [main] [DEBUG] PekkoRaftStorage - follower-261: terminating thread VirtualThread[#690,follower-261-writer-116]/waiting 12:00:48,859 AM [follower-261-writer-116] [DEBUG] JournalWriteTask - follower-261: received 1 commands after 4.495 ms 12:00:48,859 AM [follower-261-writer-116] [DEBUG] JournalWriteTask - follower-261: completed 1 commands in 17.23 μs 12:00:48,859 AM [follower-261-writer-116] [DEBUG] JournalWriteTask - follower-261: journal writer stopped 12:00:48,859 AM [main] [DEBUG] EntryJournalV1 - follower-261: journal closed 12:00:48,859 AM [main] [INFO] PekkoRaftStorage - follower-261: journal closed 12:00:48,859 AM [main] [DEBUG] RaftStorage - follower-261: stopped executor with 0 remaining tasks 12:00:48,859 AM [main] [DEBUG] RaftStorage - follower-261: stopped executor with 0 remaining tasks [WARN] [07/02/2025 00:00:48.861] [test-pekko.actor.default-dispatcher-11] [pekko://test/user/termination-monitor] received dead letter from TestActor[pekko://test/user/leader-262]: org.opendaylight.controller.cluster.common.actor.Monitor@33b1c37 12:00:48,861 AM [main] [INFO] RaftActor - leader-262: Starting recovery with journal batch size 1000 12:00:48,861 AM [main] [DEBUG] RaftStorage - leader-262: started executor 12:00:48,862 AM [main] [DEBUG] RaftStorage - leader-262: started executor 12:00:48,862 AM [main] [DEBUG] EntryJournalV1 - leader-262: metadata journal open: replayFrom=1 applyTo=0 12:00:48,862 AM [main] [DEBUG] EntryJournalV1 - leader-262: journal open: firstIndex=1 lastIndex=0 replayFrom=1 fileEntries=0 12:00:48,862 AM [main] [INFO] PekkoRaftStorage - leader-262: journal open: applyTo=0 12:00:48,862 AM [leader-262-writer-117] [DEBUG] JournalWriteTask - leader-262: journal writer started 12:00:48,862 AM [leader-262-writer-117] [DEBUG] JournalWriteTask - leader-262: waiting to receive commands 12:00:48,863 AM [main] [DEBUG] AbstractReplicatedLog - leader-262: Moving last applied index from -1 to 3 12:00:48,863 AM [main] [DEBUG] PropertiesTermInfoStore - leader-262: Set currentTerm=1, votedFor=leader-262 12:00:48,863 AM [test-pekko.actor.default-dispatcher-11] [DEBUG] PropertiesTermInfoStore - /tmp/org.opendaylight.controller.cluster.raft.RaftActorTest9848759696354768554/leader-262/TermInfo.properties does not exist 12:00:48,864 AM [test-pekko.actor.default-dispatcher-11] [INFO] PekkoRecovery - leader-262: Recovery completed - Switching actor to Follower - last log index = -1, last log term = -1, snapshot index = -1, snapshot term = -1, journal size = 0 12:00:48,865 AM [test-pekko.actor.default-dispatcher-11] [DEBUG] PropertiesTermInfoStore - leader-262: Set currentTerm=1, votedFor=leader-262 12:00:48,865 AM [test-pekko.actor.default-dispatcher-11] [INFO] PekkoRecovery - leader-262: Local TermInfo store seeded with TermInfo{term=1, votedFor=leader-262} 12:00:48,865 AM [test-pekko.actor.default-dispatcher-11] [DEBUG] RaftActor - leader-262: Pekko recovery completed with org.opendaylight.controller.cluster.raft.RecoveryLog@7bf6d531 12:00:48,866 AM [main] [DEBUG] AbstractLeader - leader-262 (Leader): Election: Leader has following peers: [member1] 12:00:48,866 AM [main] [DEBUG] AbstractLeader - leader-262 (Leader): Checking sendAppendEntries for follower member1: active: false, followerNextIndex: -1, leaderLastIndex: 3, leaderSnapShotIndex: -1 [WARN] [07/02/2025 00:00:48.866] [test-pekko.actor.default-dispatcher-11] [pekko://test/user/leader-262/address] received dead letter from TestActor[pekko://test/user/leader-262]: AppendEntries{term=1, leaderId=leader-262, prevLogIndex=-1, prevLogTerm=-1, leaderCommit=-1, replicatedToAllIndex=-1, payloadVersion=5, recipientRaftVersion=4, leaderRaftVersion=5, entries==[]} 12:00:48,867 AM [main] [INFO] SnapshotManager - leader-262: Initiating snapshot capture CaptureSnapshot [lastAppliedIndex=-1, lastAppliedTerm=-1, lastIndex=3, lastTerm=1, installSnapshotInitiated=, replicatedToAllIndex=-1, replicatedToAllTerm=-1, unAppliedEntries size=4, mandatoryTrim=false] to install on member1 12:00:48,867 AM [main] [DEBUG] SnapshotManager - leader-262: lastSequenceNumber prior to capture: 0 12:00:48,867 AM [main] [DEBUG] RaftStorageCompleter - test: 1 completion(s) pending 12:00:48,867 AM [main] [DEBUG] RaftStorageCompleter - test: running 1 completion(s) 12:00:48,867 AM [main] [INFO] SnapshotManager - leader-262: Persising snapshot at EntryInfo[index=-1, term=-1]/EntryInfo[index=3, term=1] 12:00:48,867 AM [main] [INFO] SnapshotManager - leader-262: Removed in-memory snapshotted entries, adjusted snaphsotIndex: -1 and term: -1 12:00:48,867 AM [main] [DEBUG] AbstractLeader - leader-262 (Leader): sendInstallSnapshot 12:00:48,867 AM [main] [DEBUG] LeaderInstallSnapshotState - leader-262 (Leader): Snapshot 14 bytes, total chunks to send: 1 12:00:48,867 AM [main] [DEBUG] LeaderInstallSnapshotState - leader-262 (Leader): Next chunk: total length=14, offset=0, size=14, hashCode=-804174656 12:00:48,867 AM [main] [DEBUG] AbstractLeader - leader-262 (Leader): next snapshot chunk size for follower member1: 14 12:00:48,867 AM [main] [DEBUG] AbstractLeader - leader-262 (Leader): InstallSnapshot sent to follower Vector(address), Chunk: 1/1 12:00:48,867 AM [main] [INFO] TestActorFactory - Killing actor TestActor[pekko://test/user/leader-262] [WARN] [07/02/2025 00:00:48.867] [test-pekko.actor.default-dispatcher-11] [pekko://test/user/leader-262/address] received dead letter from TestActor[pekko://test/user/leader-262]: InstallSnapshot{term=1, leaderId=leader-262, lastIncludedIndex=-1, lastIncludedTerm=-1, datasize=14, chunk=1/1, lastChunkHashCode=OptionalInt[-1]} 12:00:48,868 AM [main] [DEBUG] PekkoRaftStorage - leader-262: terminating thread VirtualThread[#691,leader-262-writer-117]/waiting 12:00:48,868 AM [leader-262-writer-117] [DEBUG] JournalWriteTask - leader-262: received 1 commands after 5.809 ms 12:00:48,868 AM [leader-262-writer-117] [DEBUG] JournalWriteTask - leader-262: completed 1 commands in 7.650 μs 12:00:48,868 AM [leader-262-writer-117] [DEBUG] JournalWriteTask - leader-262: journal writer stopped 12:00:48,870 AM [main] [DEBUG] EntryJournalV1 - leader-262: journal closed 12:00:48,870 AM [main] [INFO] PekkoRaftStorage - leader-262: journal closed 12:00:48,870 AM [main] [DEBUG] RaftStorage - leader-262: stopped executor with 0 remaining tasks 12:00:48,870 AM [main] [DEBUG] RaftStorage - leader-262: stopped executor with 0 remaining tasks 12:00:48,874 AM [main] [INFO] RaftActor - leader-263: Starting recovery with journal batch size 1000 12:00:48,874 AM [main] [DEBUG] RaftStorage - leader-263: started executor 12:00:48,874 AM [main] [DEBUG] RaftStorage - leader-263: started executor 12:00:48,874 AM [main] [DEBUG] EntryJournalV1 - leader-263: metadata journal open: replayFrom=1 applyTo=0 12:00:48,875 AM [main] [DEBUG] EntryJournalV1 - leader-263: journal open: firstIndex=1 lastIndex=0 replayFrom=1 fileEntries=0 12:00:48,875 AM [main] [INFO] PekkoRaftStorage - leader-263: journal open: applyTo=0 12:00:48,875 AM [leader-263-writer-118] [DEBUG] JournalWriteTask - leader-263: journal writer started 12:00:48,875 AM [leader-263-writer-118] [DEBUG] JournalWriteTask - leader-263: waiting to receive commands 12:00:48,875 AM [main] [DEBUG] AbstractReplicatedLog - leader-263: Moving last applied index from -1 to 9 12:00:48,875 AM [main] [DEBUG] PropertiesTermInfoStore - leader-263: Set currentTerm=1, votedFor=leader-263 [WARN] [07/02/2025 00:00:48.875] [test-pekko.actor.default-dispatcher-11] [pekko://test/user/termination-monitor] received dead letter from TestActor[pekko://test/user/leader-263]: org.opendaylight.controller.cluster.common.actor.Monitor@4267dcc1 12:00:48,876 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] PropertiesTermInfoStore - /tmp/org.opendaylight.controller.cluster.raft.RaftActorTest18345822628154222712/leader-263/TermInfo.properties does not exist 12:00:48,876 AM [test-pekko.actor.default-dispatcher-7] [INFO] PekkoRecovery - leader-263: Recovery completed - Switching actor to Follower - last log index = -1, last log term = -1, snapshot index = -1, snapshot term = -1, journal size = 0 12:00:48,881 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] PropertiesTermInfoStore - leader-263: Set currentTerm=1, votedFor=leader-263 12:00:48,881 AM [test-pekko.actor.default-dispatcher-7] [INFO] PekkoRecovery - leader-263: Local TermInfo store seeded with TermInfo{term=1, votedFor=leader-263} 12:00:48,881 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] RaftActor - leader-263: Pekko recovery completed with org.opendaylight.controller.cluster.raft.RecoveryLog@b232555 12:00:48,881 AM [main] [DEBUG] AbstractLeader - leader-263 (Leader): Election: Leader has following peers: [follower-264, follower-265] 12:00:48,881 AM [main] [DEBUG] AbstractLeader - leader-263 (Leader): Checking sendAppendEntries for follower follower-264: active: false, followerNextIndex: -1, leaderLastIndex: -1, leaderSnapShotIndex: -1 12:00:48,881 AM [main] [DEBUG] AbstractLeader - leader-263 (Leader): Checking sendAppendEntries for follower follower-265: active: false, followerNextIndex: -1, leaderLastIndex: -1, leaderSnapShotIndex: -1 12:00:48,881 AM [main] [DEBUG] AbstractLeader - leader-263 (Leader): handleAppendEntriesReply - FollowerLogInformation for follower-264 updated: matchIndex: 9, nextIndex: 10 12:00:48,882 AM [main] [DEBUG] AbstractLeader - leader-263 (Leader): Checking sendAppendEntries for follower follower-264: active: true, followerNextIndex: 10, leaderLastIndex: 9, leaderSnapShotIndex: 4 12:00:48,882 AM [main] [DEBUG] AbstractLeader - leader-263 (Leader): handleAppendEntriesReply - FollowerLogInformation for follower-265 updated: matchIndex: 0, nextIndex: 1 12:00:48,882 AM [main] [DEBUG] AbstractLeader - leader-263 (Leader): Checking sendAppendEntries for follower follower-265: active: true, followerNextIndex: 1, leaderLastIndex: 9, leaderSnapShotIndex: 4 12:00:48,882 AM [main] [INFO] AbstractLeader - leader-263 (Leader): Initiating install snapshot to follower follower-265: follower nextIndex: 1, leader snapshotIndex: 4, leader lastIndex: 9, leader log size: 5 12:00:48,882 AM [main] [INFO] SnapshotManager - leader-263: Initiating snapshot capture CaptureSnapshot [lastAppliedIndex=4, lastAppliedTerm=-1, lastIndex=9, lastTerm=1, installSnapshotInitiated=, replicatedToAllIndex=9, replicatedToAllTerm=1, unAppliedEntries size=5, mandatoryTrim=false] to install on follower-265 12:00:48,882 AM [main] [DEBUG] SnapshotManager - leader-263: lastSequenceNumber prior to capture: -5 12:00:48,882 AM [main] [INFO] MockRaftActor - leader-263: support() called 12:00:48,883 AM [main] [DEBUG] RaftStorageCompleter - test: 1 completion(s) pending 12:00:48,883 AM [main] [DEBUG] AbstractLeader - leader-263 (Leader): handleAppendEntriesReply - FollowerLogInformation for follower-265 updated: matchIndex: 9, nextIndex: 10 12:00:48,883 AM [main] [DEBUG] RaftStorageCompleter - test: running 1 completion(s) 12:00:48,883 AM [main] [INFO] SnapshotManager - leader-263: Persising snapshot at EntryInfo[index=4, term=-1]/EntryInfo[index=9, term=1] 12:00:48,883 AM [main] [INFO] MockRaftActor - leader-263: support() called 12:00:48,883 AM [main] [INFO] SnapshotManager - leader-263: Removed in-memory snapshotted entries, adjusted snaphsotIndex: 9 and term: 1 12:00:48,884 AM [main] [DEBUG] AbstractLeader - leader-263 (Leader): sendInstallSnapshot 12:00:48,884 AM [main] [DEBUG] LeaderInstallSnapshotState - leader-263 (Leader): Snapshot 351 bytes, total chunks to send: 1 12:00:48,884 AM [main] [DEBUG] LeaderInstallSnapshotState - leader-263 (Leader): Next chunk: total length=351, offset=0, size=351, hashCode=1011228180 12:00:48,884 AM [main] [DEBUG] AbstractLeader - leader-263 (Leader): next snapshot chunk size for follower follower-265: 351 12:00:48,884 AM [main] [DEBUG] AbstractLeader - leader-263 (Leader): InstallSnapshot sent to follower Vector(user, follower-265), Chunk: 1/1 12:00:48,884 AM [main] [DEBUG] AbstractLeader - leader-263 (Leader): handleAppendEntriesReply - FollowerLogInformation for follower-265 updated: matchIndex: 5, nextIndex: 6 12:00:48,884 AM [main] [INFO] TestActorFactory - Killing actor Actor[pekko://test/user/follower-264#-2125807961] 12:00:48,885 AM [main] [INFO] TestActorFactory - Killing actor Actor[pekko://test/user/follower-265#1087855792] 12:00:48,885 AM [main] [INFO] TestActorFactory - Killing actor TestActor[pekko://test/user/leader-263] 12:00:48,885 AM [main] [DEBUG] PekkoRaftStorage - leader-263: terminating thread VirtualThread[#692,leader-263-writer-118]/waiting 12:00:48,885 AM [leader-263-writer-118] [DEBUG] JournalWriteTask - leader-263: received 1 commands after 10.00 ms 12:00:48,885 AM [leader-263-writer-118] [DEBUG] JournalWriteTask - leader-263: completed 1 commands in 10.26 μs 12:00:48,885 AM [leader-263-writer-118] [DEBUG] JournalWriteTask - leader-263: journal writer stopped 12:00:48,885 AM [main] [DEBUG] EntryJournalV1 - leader-263: journal closed 12:00:48,885 AM [main] [INFO] PekkoRaftStorage - leader-263: journal closed 12:00:48,885 AM [main] [DEBUG] RaftStorage - leader-263: stopped executor with 0 remaining tasks 12:00:48,885 AM [main] [DEBUG] RaftStorage - leader-263: stopped executor with 0 remaining tasks [WARN] [07/02/2025 00:00:48.888] [test-pekko.actor.default-dispatcher-11] [pekko://test/user/termination-monitor] received dead letter from TestActor[pekko://test/user/follower-266]: org.opendaylight.controller.cluster.common.actor.Monitor@571618fa 12:00:48,889 AM [main] [INFO] RaftActor - follower-266: Starting recovery with journal batch size 1000 12:00:48,889 AM [main] [DEBUG] RaftStorage - follower-266: started executor 12:00:48,889 AM [main] [DEBUG] RaftStorage - follower-266: started executor 12:00:48,889 AM [main] [DEBUG] EntryJournalV1 - follower-266: metadata journal open: replayFrom=1 applyTo=0 12:00:48,890 AM [main] [DEBUG] EntryJournalV1 - follower-266: journal open: firstIndex=1 lastIndex=0 replayFrom=1 fileEntries=0 12:00:48,890 AM [main] [INFO] PekkoRaftStorage - follower-266: journal open: applyTo=0 12:00:48,890 AM [follower-266-writer-119] [DEBUG] JournalWriteTask - follower-266: journal writer started 12:00:48,890 AM [follower-266-writer-119] [DEBUG] JournalWriteTask - follower-266: waiting to receive commands 12:00:48,891 AM [test-pekko.actor.default-dispatcher-11] [DEBUG] PropertiesTermInfoStore - /tmp/org.opendaylight.controller.cluster.raft.RaftActorTest3382621209324613604/follower-266/TermInfo.properties does not exist 12:00:48,891 AM [test-pekko.actor.default-dispatcher-11] [INFO] PekkoRecovery - follower-266: Recovery completed - Switching actor to Follower - last log index = -1, last log term = -1, snapshot index = -1, snapshot term = -1, journal size = 0 12:00:48,896 AM [test-pekko.actor.default-dispatcher-11] [DEBUG] PropertiesTermInfoStore - follower-266: Set currentTerm=0, votedFor=null 12:00:48,896 AM [test-pekko.actor.default-dispatcher-11] [INFO] PekkoRecovery - follower-266: Local TermInfo store seeded with TermInfo{term=0} 12:00:48,896 AM [test-pekko.actor.default-dispatcher-11] [DEBUG] RaftActor - follower-266: Pekko recovery completed with org.opendaylight.controller.cluster.raft.RecoveryLog@70a27b82 12:00:48,897 AM [main] [DEBUG] RaftActor - follower-266: RaftPolicy used with prev.config null, RaftPolicy used with newConfig null 12:00:48,897 AM [main] [DEBUG] RaftActor - follower-266: RaftPolicy used with prev.config null, RaftPolicy used with newConfig org.opendaylight.controller.cluster.raft.policy.DisableElectionsRaftPolicy 12:00:48,897 AM [main] [DEBUG] RaftActor - follower-266: Re-initializing to Follower with previous leaderId null 12:00:48,897 AM [main] [DEBUG] RaftActor - follower-266: RaftPolicy used with prev.config org.opendaylight.controller.cluster.raft.policy.DisableElectionsRaftPolicy, RaftPolicy used with newConfig org.opendaylight.controller.cluster.raft.policy.DisableElectionsRaftPolicy 12:00:48,897 AM [main] [DEBUG] RaftActor - follower-266: RaftPolicy used with prev.config org.opendaylight.controller.cluster.raft.policy.DisableElectionsRaftPolicy, RaftPolicy used with newConfig org.opendaylight.controller.cluster.raft.policy.DefaultRaftPolicy 12:00:48,897 AM [main] [DEBUG] RaftActor - follower-266: Re-initializing to Follower with previous leaderId null 12:00:48,897 AM [main] [DEBUG] RaftActor - follower-266: RaftPolicy used with prev.config org.opendaylight.controller.cluster.raft.policy.DefaultRaftPolicy, RaftPolicy used with newConfig org.opendaylight.controller.cluster.raft.policy.DefaultRaftPolicy 12:00:48,897 AM [main] [INFO] TestActorFactory - Killing actor TestActor[pekko://test/user/follower-266] 12:00:48,898 AM [main] [DEBUG] PekkoRaftStorage - follower-266: terminating thread VirtualThread[#693,follower-266-writer-119]/waiting 12:00:48,898 AM [follower-266-writer-119] [DEBUG] JournalWriteTask - follower-266: received 1 commands after 8.121 ms 12:00:48,898 AM [follower-266-writer-119] [DEBUG] JournalWriteTask - follower-266: completed 1 commands in 12.26 μs 12:00:48,898 AM [follower-266-writer-119] [DEBUG] JournalWriteTask - follower-266: journal writer stopped 12:00:48,899 AM [main] [DEBUG] EntryJournalV1 - follower-266: journal closed 12:00:48,899 AM [main] [INFO] PekkoRaftStorage - follower-266: journal closed 12:00:48,899 AM [main] [DEBUG] RaftStorage - follower-266: stopped executor with 0 remaining tasks 12:00:48,899 AM [main] [DEBUG] RaftStorage - follower-266: stopped executor with 0 remaining tasks [WARN] [07/02/2025 00:00:48.965] [test-pekko.actor.default-dispatcher-7] [pekko://test/user/termination-monitor] received dead letter from TestActor[pekko://test/user/$$b]: org.opendaylight.controller.cluster.common.actor.Monitor@6dadbdc3 12:00:48,966 AM [main] [INFO] RaftActor - leader-267: Starting recovery with journal batch size 1000 12:00:48,966 AM [main] [DEBUG] RaftStorage - leader-267: started executor 12:00:48,966 AM [main] [DEBUG] RaftStorage - leader-267: started executor 12:00:48,967 AM [main] [DEBUG] EntryJournalV1 - leader-267: metadata journal open: replayFrom=1 applyTo=0 12:00:48,968 AM [main] [DEBUG] EntryJournalV1 - leader-267: journal open: firstIndex=1 lastIndex=0 replayFrom=1 fileEntries=0 12:00:48,968 AM [main] [INFO] PekkoRaftStorage - leader-267: journal open: applyTo=0 12:00:48,968 AM [leader-267-writer-120] [DEBUG] JournalWriteTask - leader-267: journal writer started 12:00:48,968 AM [leader-267-writer-120] [DEBUG] JournalWriteTask - leader-267: waiting to receive commands 12:00:48,969 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] PropertiesTermInfoStore - /tmp/org.opendaylight.controller.cluster.raft.RaftActorTest1383729702218548580/leader-267/TermInfo.properties does not exist 12:00:48,969 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] RaftStorage - leader-267: skipping unrecognized file /tmp/org.opendaylight.controller.cluster.raft.RaftActorTest1383729702218548580/leader-267/journal-v1-1.log 12:00:48,969 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] RaftStorage - leader-267: skipping unrecognized file /tmp/org.opendaylight.controller.cluster.raft.RaftActorTest1383729702218548580/leader-267/metadata-v1-1.log 12:00:48,969 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] RaftStorage - leader-267: no eligible files found 12:00:48,969 AM [test-pekko.actor.default-dispatcher-7] [INFO] PekkoRecovery - leader-267: Recovery completed - Switching actor to Follower - last log index = -1, last log term = -1, snapshot index = -1, snapshot term = -1, journal size = 0 12:00:48,972 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] PropertiesTermInfoStore - leader-267: Set currentTerm=0, votedFor=null 12:00:48,972 AM [test-pekko.actor.default-dispatcher-7] [INFO] PekkoRecovery - leader-267: Local TermInfo store seeded with TermInfo{term=0} 12:00:48,972 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] RaftActor - leader-267: Pekko recovery completed with org.opendaylight.controller.cluster.raft.RecoveryLog@32bececa 12:00:48,972 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] AbstractReplicatedLog - leader-267: Moving last applied index from -1 to -1 12:00:48,972 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] JournalRecovery - leader-267: empty journal: appending 0 entries 12:00:48,972 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] EntryJournalV1 - leader-267: updated meta to JournalMeta[replayFrom=1, applyTo=0] 12:00:48,973 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] JournalRecovery - leader-267: journal recovery completedin 415.6 μs with journalIndex=1 12:00:48,975 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] DefaultConfigParamsImpl - No custom RaftPolicy specified. Using DefaultRaftPolicy 12:00:48,975 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] Follower - leader-267 (Follower): Received TimeoutNow - switching to Candidate 12:00:48,975 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] Candidate - leader-267 (Candidate): Election: Candidate has following voting peers: [] 12:00:48,977 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] PropertiesTermInfoStore - leader-267: Set currentTerm=1, votedFor=leader-267 12:00:48,977 AM [test-pekko.actor.default-dispatcher-7] [INFO] Candidate - leader-267 (Candidate): Starting new election term 1 12:00:48,977 AM [test-pekko.actor.default-dispatcher-7] [INFO] RaftActorBehavior - leader-267 (Follower) :- Switching from behavior Follower to Candidate, election term: 1 12:00:48,977 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] Candidate - leader-267 (Candidate): Received ElectionTimeout 12:00:48,977 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] AbstractLeader - leader-267 (Leader): Election: Leader has following peers: [] 12:00:48,977 AM [test-pekko.actor.default-dispatcher-7] [INFO] RaftActorBehavior - leader-267 (Candidate) :- Switching from behavior Candidate to Leader, election term: 1 12:00:48,980 AM [main] [INFO] TestActorFactory - Killing actor TestActor[pekko://test/user/$$b] 12:00:48,981 AM [main] [DEBUG] PekkoRaftStorage - leader-267: terminating thread VirtualThread[#694,leader-267-writer-120]/waiting 12:00:48,981 AM [leader-267-writer-120] [DEBUG] JournalWriteTask - leader-267: received 1 commands after 13.33 ms 12:00:48,981 AM [leader-267-writer-120] [DEBUG] JournalWriteTask - leader-267: completed 1 commands in 10.53 μs 12:00:48,981 AM [leader-267-writer-120] [DEBUG] JournalWriteTask - leader-267: journal writer stopped 12:00:48,981 AM [main] [DEBUG] EntryJournalV1 - leader-267: journal closed 12:00:48,982 AM [main] [INFO] PekkoRaftStorage - leader-267: journal closed 12:00:48,982 AM [main] [DEBUG] RaftStorage - leader-267: stopped executor with 0 remaining tasks 12:00:48,982 AM [main] [DEBUG] RaftStorage - leader-267: stopped executor with 0 remaining tasks 12:00:48,985 AM [main] [INFO] RaftActor - leader-268: Starting recovery with journal batch size 1000 12:00:48,986 AM [main] [DEBUG] RaftStorage - leader-268: started executor 12:00:48,986 AM [main] [DEBUG] RaftStorage - leader-268: started executor 12:00:48,986 AM [main] [DEBUG] EntryJournalV1 - leader-268: metadata journal open: replayFrom=1 applyTo=0 12:00:48,987 AM [main] [DEBUG] EntryJournalV1 - leader-268: journal open: firstIndex=1 lastIndex=0 replayFrom=1 fileEntries=0 12:00:48,987 AM [main] [INFO] PekkoRaftStorage - leader-268: journal open: applyTo=0 12:00:48,987 AM [leader-268-writer-121] [DEBUG] JournalWriteTask - leader-268: journal writer started 12:00:48,987 AM [leader-268-writer-121] [DEBUG] JournalWriteTask - leader-268: waiting to receive commands 12:00:48,988 AM [test-pekko.actor.default-dispatcher-11] [DEBUG] PropertiesTermInfoStore - /tmp/org.opendaylight.controller.cluster.raft.RaftActorTest5350983879727779401/leader-268/TermInfo.properties does not exist 12:00:48,988 AM [test-pekko.actor.default-dispatcher-11] [DEBUG] RaftStorage - leader-268: skipping unrecognized file /tmp/org.opendaylight.controller.cluster.raft.RaftActorTest5350983879727779401/leader-268/journal-v1-1.log 12:00:48,988 AM [test-pekko.actor.default-dispatcher-11] [DEBUG] RaftStorage - leader-268: skipping unrecognized file /tmp/org.opendaylight.controller.cluster.raft.RaftActorTest5350983879727779401/leader-268/metadata-v1-1.log 12:00:48,988 AM [test-pekko.actor.default-dispatcher-11] [DEBUG] RaftStorage - leader-268: no eligible files found 12:00:48,988 AM [test-pekko.actor.default-dispatcher-11] [INFO] PekkoRecovery - leader-268: Recovery completed - Switching actor to Follower - last log index = -1, last log term = -1, snapshot index = -1, snapshot term = -1, journal size = 0 [WARN] [07/02/2025 00:00:48.990] [test-pekko.actor.default-dispatcher-12] [pekko://test/user/$$b] unhandled message from TestActor[pekko://test/user/$$b]: ApplyLeaderSnapshot[leaderId=leader-267, term=0, lastEntry=EntryInfo[index=0, term=0], snapshot=PlainSnapshotSource{io=WrappedByteArray{size=1}}, serverConfig=null, callback=Mock for Callback, hashCode: 734270769] [WARN] [07/02/2025 00:00:48.990] [test-pekko.actor.default-dispatcher-12] [pekko://test/user/termination-monitor] received dead letter from TestActor[pekko://test/user/leader-268]: org.opendaylight.controller.cluster.common.actor.Monitor@44cfe3d0 12:00:48,990 AM [test-pekko.actor.default-dispatcher-11] [DEBUG] PropertiesTermInfoStore - leader-268: Set currentTerm=0, votedFor=null 12:00:48,990 AM [test-pekko.actor.default-dispatcher-11] [INFO] PekkoRecovery - leader-268: Local TermInfo store seeded with TermInfo{term=0} 12:00:48,990 AM [test-pekko.actor.default-dispatcher-11] [DEBUG] RaftActor - leader-268: Pekko recovery completed with org.opendaylight.controller.cluster.raft.RecoveryLog@6f210253 12:00:48,990 AM [test-pekko.actor.default-dispatcher-11] [DEBUG] AbstractReplicatedLog - leader-268: Moving last applied index from -1 to -1 12:00:48,990 AM [test-pekko.actor.default-dispatcher-11] [DEBUG] JournalRecovery - leader-268: empty journal: appending 0 entries 12:00:48,990 AM [test-pekko.actor.default-dispatcher-11] [DEBUG] EntryJournalV1 - leader-268: updated meta to JournalMeta[replayFrom=1, applyTo=0] 12:00:48,990 AM [test-pekko.actor.default-dispatcher-11] [DEBUG] JournalRecovery - leader-268: journal recovery completedin 235.6 μs with journalIndex=1 12:00:48,991 AM [main] [DEBUG] PropertiesTermInfoStore - leader-268: Set currentTerm=1, votedFor=leader-268 12:00:48,991 AM [main] [DEBUG] AbstractLeader - leader-268 (Leader): Election: Leader has following peers: [follower-269] 12:00:48,991 AM [main] [DEBUG] AbstractLeader - leader-268 (Leader): Checking sendAppendEntries for follower follower-269: active: false, followerNextIndex: -1, leaderLastIndex: -1, leaderSnapShotIndex: -1 12:00:48,991 AM [main] [DEBUG] AbstractLeader - leader-268 (Leader): handleAppendEntriesReply - FollowerLogInformation for follower-269 updated: matchIndex: -1, nextIndex: 0 12:00:48,991 AM [main] [DEBUG] AbstractLeader - leader-268 (Leader): Checking sendAppendEntries for follower follower-269: active: true, followerNextIndex: 0, leaderLastIndex: -1, leaderSnapShotIndex: -1 12:00:48,991 AM [main] [DEBUG] RaftActor - leader-268: Persist data index=0 term=1 command=1 12:00:48,991 AM [main] [DEBUG] ReplicatedLogImpl - leader-268: Append log entry and persist JournaledLogEntry{index=0, term=1, command=1, pending=true} 12:00:48,991 AM [main] [DEBUG] AbstractLeader - leader-268 (Leader): Replicate message: identifier: MockIdentifier{value=1}, logIndex: 0, isSendImmediate: false 12:00:48,992 AM [main] [DEBUG] DefaultConfigParamsImpl - No custom RaftPolicy specified. Using DefaultRaftPolicy 12:00:48,992 AM [leader-268-writer-121] [DEBUG] JournalWriteTask - leader-268: received 1 commands after 4.587 ms 12:00:48,994 AM [leader-268-writer-121] [DEBUG] RaftStorageCompleter - leader-268: 1 completion(s) pending 12:00:48,995 AM [leader-268-writer-121] [DEBUG] RaftStorageCompleter - leader-268: running 1 completion(s) 12:00:48,995 AM [leader-268-writer-121] [DEBUG] ReplicatedLogImpl - leader-268: persist complete JournaledLogEntry{index=0, term=1, command=1, pending=true} 12:00:48,995 AM [leader-268-writer-121] [DEBUG] RaftStorageCompleter - leader-268: completed synchronized callback AppendSubmittedCallback{entry=JournaledLogEntry{index=0, term=1, command=1, pending=false}, callback=org.opendaylight.controller.cluster.raft.RaftActor$$Lambda/0x00000007c087e110@5ab90b23} 12:00:48,995 AM [leader-268-writer-121] [DEBUG] JournalWriteTask - leader-268: completed 1 commands in 3.125 ms 12:00:48,995 AM [leader-268-writer-121] [DEBUG] JournalWriteTask - leader-268: waiting to receive commands 12:00:49,494 AM [main] [DEBUG] RaftActor - leader-268: Persist data index=1 term=1 command=2 12:00:49,494 AM [main] [DEBUG] ReplicatedLogImpl - leader-268: Append log entry and persist JournaledLogEntry{index=1, term=1, command=2, pending=true} 12:00:49,494 AM [main] [DEBUG] AbstractLeader - leader-268 (Leader): Replicate message: identifier: MockIdentifier{value=2}, logIndex: 1, isSendImmediate: false 12:00:49,494 AM [leader-268-writer-121] [DEBUG] JournalWriteTask - leader-268: received 1 commands after 499.8 ms 12:00:49,497 AM [leader-268-writer-121] [DEBUG] RaftStorageCompleter - leader-268: 1 completion(s) pending 12:00:49,497 AM [leader-268-writer-121] [DEBUG] RaftStorageCompleter - leader-268: running 1 completion(s) 12:00:49,497 AM [leader-268-writer-121] [DEBUG] ReplicatedLogImpl - leader-268: persist complete JournaledLogEntry{index=1, term=1, command=2, pending=true} 12:00:49,497 AM [leader-268-writer-121] [DEBUG] RaftStorageCompleter - leader-268: completed synchronized callback AppendSubmittedCallback{entry=JournaledLogEntry{index=1, term=1, command=2, pending=false}, callback=org.opendaylight.controller.cluster.raft.RaftActor$$Lambda/0x00000007c087e110@ece239b} 12:00:49,497 AM [leader-268-writer-121] [DEBUG] JournalWriteTask - leader-268: completed 1 commands in 2.497 ms 12:00:49,497 AM [leader-268-writer-121] [DEBUG] JournalWriteTask - leader-268: waiting to receive commands 12:00:49,997 AM [main] [DEBUG] RaftActor - leader-268: Persist data index=2 term=1 command=3 12:00:49,997 AM [main] [DEBUG] ReplicatedLogImpl - leader-268: Append log entry and persist JournaledLogEntry{index=2, term=1, command=3, pending=true} 12:00:49,997 AM [main] [DEBUG] AbstractLeader - leader-268 (Leader): Replicate message: identifier: MockIdentifier{value=3}, logIndex: 2, isSendImmediate: true 12:00:49,998 AM [main] [DEBUG] AbstractLeader - leader-268 (Leader): Checking sendAppendEntries for follower follower-269: active: true, followerNextIndex: 0, leaderLastIndex: 2, leaderSnapShotIndex: -1 12:00:49,998 AM [main] [DEBUG] AbstractLeader - leader-268 (Leader): sendAppendEntries: 0 is present for follower follower-269 12:00:49,998 AM [leader-268-writer-121] [DEBUG] JournalWriteTask - leader-268: received 1 commands after 500.5 ms 12:00:49,998 AM [main] [DEBUG] AbstractLeader - leader-268 (Leader): Sending AppendEntries to follower follower-269: AppendEntries{term=1, leaderId=leader-268, prevLogIndex=-1, prevLogTerm=-1, leaderCommit=-1, replicatedToAllIndex=-1, payloadVersion=5, recipientRaftVersion=5, leaderRaftVersion=5, entries==[JournaledLogEntry{index=0, term=1, command=1, pending=false}, JournaledLogEntry{index=1, term=1, command=2, pending=false}, JournaledLogEntry{index=2, term=1, command=3, pending=true}]} 12:00:49,998 AM [main] [INFO] TestActorFactory - Killing actor Actor[pekko://test/user/$f#-413626360] 12:00:50,4 AM [leader-268-writer-121] [DEBUG] RaftStorageCompleter - leader-268: 1 completion(s) pending 12:00:50,4 AM [leader-268-writer-121] [DEBUG] RaftStorageCompleter - leader-268: running 1 completion(s) 12:00:50,4 AM [leader-268-writer-121] [DEBUG] ReplicatedLogImpl - leader-268: persist complete JournaledLogEntry{index=2, term=1, command=3, pending=true} 12:00:50,4 AM [leader-268-writer-121] [DEBUG] RaftStorageCompleter - leader-268: completed synchronized callback AppendSubmittedCallback{entry=JournaledLogEntry{index=2, term=1, command=3, pending=false}, callback=org.opendaylight.controller.cluster.raft.RaftActor$$Lambda/0x00000007c087e110@64e0b5dc} 12:00:50,4 AM [leader-268-writer-121] [DEBUG] JournalWriteTask - leader-268: completed 1 commands in 6.472 ms 12:00:50,4 AM [leader-268-writer-121] [DEBUG] JournalWriteTask - leader-268: waiting to receive commands 12:00:50,9 AM [main] [INFO] TestActorFactory - Killing actor TestActor[pekko://test/user/leader-268] 12:00:50,10 AM [main] [DEBUG] PekkoRaftStorage - leader-268: terminating thread VirtualThread[#695,leader-268-writer-121]/waiting 12:00:50,10 AM [leader-268-writer-121] [DEBUG] JournalWriteTask - leader-268: received 1 commands after 5.526 ms 12:00:50,10 AM [leader-268-writer-121] [DEBUG] JournalWriteTask - leader-268: completed 1 commands in 14.31 μs 12:00:50,10 AM [leader-268-writer-121] [DEBUG] JournalWriteTask - leader-268: journal writer stopped 12:00:50,10 AM [main] [DEBUG] EntryJournalV1 - leader-268: journal closed 12:00:50,10 AM [main] [INFO] PekkoRaftStorage - leader-268: journal closed 12:00:50,10 AM [main] [DEBUG] RaftStorage - leader-268: stopped executor with 0 remaining tasks 12:00:50,10 AM [main] [DEBUG] RaftStorage - leader-268: stopped executor with 0 remaining tasks [WARN] [07/02/2025 00:00:50.016] [test-pekko.actor.default-dispatcher-12] [pekko://test/user/termination-monitor] received dead letter from TestActor[pekko://test/user/leader-270]: org.opendaylight.controller.cluster.common.actor.Monitor@2a10935d 12:00:50,17 AM [main] [INFO] RaftActor - leader-270: Starting recovery with journal batch size 1000 12:00:50,17 AM [main] [DEBUG] RaftStorage - leader-270: started executor 12:00:50,17 AM [main] [DEBUG] RaftStorage - leader-270: started executor 12:00:50,18 AM [main] [DEBUG] EntryJournalV1 - leader-270: metadata journal open: replayFrom=1 applyTo=0 12:00:50,19 AM [main] [DEBUG] EntryJournalV1 - leader-270: journal open: firstIndex=1 lastIndex=0 replayFrom=1 fileEntries=0 12:00:50,19 AM [main] [INFO] PekkoRaftStorage - leader-270: journal open: applyTo=0 12:00:50,19 AM [leader-270-writer-122] [DEBUG] JournalWriteTask - leader-270: journal writer started 12:00:50,19 AM [leader-270-writer-122] [DEBUG] JournalWriteTask - leader-270: waiting to receive commands 12:00:50,20 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] PropertiesTermInfoStore - /tmp/org.opendaylight.controller.cluster.raft.RaftActorTest13944792263035907658/leader-270/TermInfo.properties does not exist 12:00:50,21 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] RaftStorage - leader-270: skipping unrecognized file /tmp/org.opendaylight.controller.cluster.raft.RaftActorTest13944792263035907658/leader-270/journal-v1-1.log 12:00:50,21 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] RaftStorage - leader-270: skipping unrecognized file /tmp/org.opendaylight.controller.cluster.raft.RaftActorTest13944792263035907658/leader-270/metadata-v1-1.log 12:00:50,21 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] RaftStorage - leader-270: no eligible files found 12:00:50,21 AM [test-pekko.actor.default-dispatcher-12] [INFO] PekkoRecovery - leader-270: Recovery completed - Switching actor to Follower - last log index = -1, last log term = -1, snapshot index = -1, snapshot term = -1, journal size = 0 12:00:50,23 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] PropertiesTermInfoStore - leader-270: Set currentTerm=0, votedFor=null 12:00:50,23 AM [test-pekko.actor.default-dispatcher-12] [INFO] PekkoRecovery - leader-270: Local TermInfo store seeded with TermInfo{term=0} 12:00:50,23 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] RaftActor - leader-270: Pekko recovery completed with org.opendaylight.controller.cluster.raft.RecoveryLog@1544b557 12:00:50,24 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] AbstractReplicatedLog - leader-270: Moving last applied index from -1 to -1 12:00:50,24 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] JournalRecovery - leader-270: empty journal: appending 0 entries 12:00:50,24 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] EntryJournalV1 - leader-270: updated meta to JournalMeta[replayFrom=1, applyTo=0] 12:00:50,24 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] JournalRecovery - leader-270: journal recovery completedin 412.2 μs with journalIndex=1 12:00:50,26 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] DefaultConfigParamsImpl - No custom RaftPolicy specified. Using DefaultRaftPolicy 12:00:50,26 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] Follower - leader-270 (Follower): Received TimeoutNow - switching to Candidate 12:00:50,26 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] Candidate - leader-270 (Candidate): Election: Candidate has following voting peers: [] 12:00:50,29 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] PropertiesTermInfoStore - leader-270: Set currentTerm=1, votedFor=leader-270 12:00:50,29 AM [test-pekko.actor.default-dispatcher-12] [INFO] Candidate - leader-270 (Candidate): Starting new election term 1 12:00:50,29 AM [test-pekko.actor.default-dispatcher-12] [INFO] RaftActorBehavior - leader-270 (Follower) :- Switching from behavior Follower to Candidate, election term: 1 12:00:50,29 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] Candidate - leader-270 (Candidate): Received ElectionTimeout 12:00:50,29 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] AbstractLeader - leader-270 (Leader): Election: Leader has following peers: [] 12:00:50,29 AM [test-pekko.actor.default-dispatcher-12] [INFO] RaftActorBehavior - leader-270 (Candidate) :- Switching from behavior Candidate to Leader, election term: 1 12:00:50,201 AM [main] [INFO] TestActorFactory - Killing actor TestActor[pekko://test/user/leader-270] 12:00:50,212 AM [main] [DEBUG] PekkoRaftStorage - leader-270: terminating thread VirtualThread[#696,leader-270-writer-122]/waiting 12:00:50,212 AM [leader-270-writer-122] [DEBUG] JournalWriteTask - leader-270: received 1 commands after 193.0 ms 12:00:50,212 AM [leader-270-writer-122] [DEBUG] JournalWriteTask - leader-270: completed 1 commands in 17.92 μs 12:00:50,212 AM [leader-270-writer-122] [DEBUG] JournalWriteTask - leader-270: journal writer stopped 12:00:50,212 AM [main] [DEBUG] EntryJournalV1 - leader-270: journal closed 12:00:50,212 AM [main] [INFO] PekkoRaftStorage - leader-270: journal closed 12:00:50,212 AM [main] [DEBUG] RaftStorage - leader-270: stopped executor with 0 remaining tasks 12:00:50,212 AM [main] [DEBUG] RaftStorage - leader-270: stopped executor with 0 remaining tasks [WARN] [07/02/2025 00:00:50.215] [test-pekko.actor.default-dispatcher-12] [pekko://test/user/termination-monitor] received dead letter from TestActor[pekko://test/user/follower-271]: org.opendaylight.controller.cluster.common.actor.Monitor@2fa99e3a 12:00:50,216 AM [main] [INFO] RaftActor - follower-271: Starting recovery with journal batch size 1000 12:00:50,216 AM [main] [DEBUG] RaftStorage - follower-271: started executor 12:00:50,216 AM [main] [DEBUG] RaftStorage - follower-271: started executor 12:00:50,216 AM [main] [DEBUG] EntryJournalV1 - follower-271: metadata journal open: replayFrom=1 applyTo=0 12:00:50,217 AM [main] [DEBUG] EntryJournalV1 - follower-271: journal open: firstIndex=1 lastIndex=0 replayFrom=1 fileEntries=0 12:00:50,217 AM [main] [INFO] PekkoRaftStorage - follower-271: journal open: applyTo=0 12:00:50,217 AM [follower-271-writer-123] [DEBUG] JournalWriteTask - follower-271: journal writer started 12:00:50,217 AM [follower-271-writer-123] [DEBUG] JournalWriteTask - follower-271: waiting to receive commands 12:00:50,218 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] PropertiesTermInfoStore - /tmp/org.opendaylight.controller.cluster.raft.RaftActorTest16059168860083109257/follower-271/TermInfo.properties does not exist 12:00:50,219 AM [test-pekko.actor.default-dispatcher-12] [INFO] PekkoRecovery - follower-271: Recovery completed - Switching actor to Follower - last log index = -1, last log term = -1, snapshot index = -1, snapshot term = -1, journal size = 0 12:00:50,224 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] PropertiesTermInfoStore - follower-271: Set currentTerm=0, votedFor=null 12:00:50,224 AM [test-pekko.actor.default-dispatcher-12] [INFO] PekkoRecovery - follower-271: Local TermInfo store seeded with TermInfo{term=0} 12:00:50,224 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] RaftActor - follower-271: Pekko recovery completed with org.opendaylight.controller.cluster.raft.RecoveryLog@33cd0cc1 12:00:50,224 AM [main] [DEBUG] AbstractReplicatedLog - follower-271: Moving last applied index from -1 to 4 12:00:50,224 AM [main] [DEBUG] PropertiesTermInfoStore - follower-271: Set currentTerm=1, votedFor=follower-271 12:00:50,225 AM [main] [INFO] SnapshotManager - follower-271: Initiating snapshot capture CaptureSnapshot [lastAppliedIndex=-1, lastAppliedTerm=-1, lastIndex=5, lastTerm=1, installSnapshotInitiated=, replicatedToAllIndex=4, replicatedToAllTerm=1, unAppliedEntries size=6, mandatoryTrim=false] to install on xyzzy 12:00:50,225 AM [main] [DEBUG] SnapshotManager - follower-271: lastSequenceNumber prior to capture: 0 12:00:50,225 AM [main] [INFO] MockRaftActor - follower-271: support() called 12:00:50,225 AM [main] [DEBUG] RaftStorageCompleter - test: 1 completion(s) pending 12:00:50,226 AM [main] [DEBUG] Follower - follower-271 (Follower): handleAppendEntries: AppendEntries{term=1, leaderId=leader-272, prevLogIndex=5, prevLogTerm=1, leaderCommit=5, replicatedToAllIndex=5, payloadVersion=0, recipientRaftVersion=5, leaderRaftVersion=5, entries==[DefaultLogEntry[index=6, term=1, command=foo-6]]} 12:00:50,226 AM [main] [DEBUG] Follower - follower-271 (Follower): Number of entries to be appended = 1 12:00:50,226 AM [main] [DEBUG] Follower - follower-271 (Follower): After cleanup, lastIndex: 5, entries to be added from: 0 12:00:50,226 AM [main] [DEBUG] Follower - follower-271 (Follower): Append entry to log foo-6 12:00:50,226 AM [main] [DEBUG] ReplicatedLogImpl - follower-271: Append log entry and persist DefaultLogEntry[index=6, term=1, command=foo-6] 12:00:50,226 AM [main] [DEBUG] ReplicatedLogImpl - follower-271: persist complete JournaledLogEntry{index=6, term=1, command=foo-6, pending=false} 12:00:50,226 AM [main] [DEBUG] Follower - follower-271 (Follower): Log size is now 7 12:00:50,226 AM [main] [DEBUG] Follower - follower-271 (Follower): Commit index set to 5 12:00:50,226 AM [main] [DEBUG] Follower - follower-271 (Follower): handleAppendEntries returning : AppendEntriesReply{term=1, success=true, followerId=follower-271, logLastIndex=6, logLastTerm=1, forceInstallSnapshot=false, needsLeaderAddress=false, payloadVersion=5, raftVersion=5, recipientRaftVersion=5} 12:00:50,226 AM [main] [DEBUG] SyncStatusTracker - follower-271: Last sync leader does not match current leader leader-272, need to catch up to 5 12:00:50,226 AM [main] [DEBUG] Follower - follower-271 (Follower): applyLogToStateMachine, appendEntries.getLeaderCommit(): 5, context.getLastApplied(): -1, lastIndex(): 6 12:00:50,226 AM [main] [DEBUG] RaftActorBehavior - follower-271 (Follower): Setting last applied to 0 12:00:50,226 AM [main] [DEBUG] AbstractReplicatedLog - follower-271: Moving last applied index from -1 to 0 12:00:50,226 AM [main] [DEBUG] RaftActor - follower-271: Applying state for log index 0 data 0 12:00:50,226 AM [main] [INFO] MockRaftActor - follower-271: applyState called: 0 12:00:50,226 AM [main] [DEBUG] RaftActorBehavior - follower-271 (Follower): Setting last applied to 1 12:00:50,226 AM [main] [DEBUG] AbstractReplicatedLog - follower-271: Moving last applied index from 0 to 1 12:00:50,226 AM [main] [DEBUG] RaftActor - follower-271: Applying state for log index 1 data 1 12:00:50,226 AM [main] [INFO] MockRaftActor - follower-271: applyState called: 1 [WARN] [07/02/2025 00:00:50.226] [test-pekko.actor.default-dispatcher-12] [pekko://test/deadLetters] received dead letter from TestActor[pekko://test/user/follower-271]: AppendEntriesReply{term=1, success=true, followerId=follower-271, logLastIndex=6, logLastTerm=1, forceInstallSnapshot=false, needsLeaderAddress=false, payloadVersion=5, raftVersion=5, recipientRaftVersion=5} 12:00:50,226 AM [main] [DEBUG] RaftActorBehavior - follower-271 (Follower): Setting last applied to 2 12:00:50,226 AM [main] [DEBUG] AbstractReplicatedLog - follower-271: Moving last applied index from 1 to 2 12:00:50,226 AM [main] [DEBUG] RaftActor - follower-271: Applying state for log index 2 data 2 12:00:50,226 AM [main] [INFO] MockRaftActor - follower-271: applyState called: 2 12:00:50,226 AM [main] [DEBUG] RaftActorBehavior - follower-271 (Follower): Setting last applied to 3 12:00:50,226 AM [main] [DEBUG] AbstractReplicatedLog - follower-271: Moving last applied index from 2 to 3 [WARN] [07/02/2025 00:00:50.226] [test-pekko.actor.default-dispatcher-12] [pekko://test/user/follower-271] unhandled message from Actor[pekko://test/deadLetters]: FollowerInitialSyncUpStatus[memberId=follower-271, initialSyncDone=false] 12:00:50,226 AM [main] [DEBUG] RaftActor - follower-271: Applying state for log index 3 data 3 12:00:50,226 AM [main] [INFO] MockRaftActor - follower-271: applyState called: 3 12:00:50,226 AM [main] [DEBUG] RaftActorBehavior - follower-271 (Follower): Setting last applied to 4 12:00:50,226 AM [main] [DEBUG] AbstractReplicatedLog - follower-271: Moving last applied index from 3 to 4 12:00:50,226 AM [main] [DEBUG] RaftActor - follower-271: Applying state for log index 4 data 4 12:00:50,226 AM [main] [INFO] MockRaftActor - follower-271: applyState called: 4 12:00:50,226 AM [main] [DEBUG] RaftActorBehavior - follower-271 (Follower): Setting last applied to 5 12:00:50,226 AM [main] [DEBUG] AbstractReplicatedLog - follower-271: Moving last applied index from 4 to 5 12:00:50,226 AM [main] [DEBUG] RaftActor - follower-271: Applying state for log index 5 data 5 12:00:50,226 AM [main] [INFO] MockRaftActor - follower-271: applyState called: 5 12:00:50,226 AM [main] [DEBUG] Follower - follower-271 (Follower): handleAppendEntries: AppendEntries{term=1, leaderId=leader-272, prevLogIndex=6, prevLogTerm=1, leaderCommit=6, replicatedToAllIndex=6, payloadVersion=0, recipientRaftVersion=5, leaderRaftVersion=5, entries==[DefaultLogEntry[index=7, term=1, command=foo-7]]} 12:00:50,226 AM [main] [DEBUG] Follower - follower-271 (Follower): Number of entries to be appended = 1 12:00:50,226 AM [main] [DEBUG] Follower - follower-271 (Follower): After cleanup, lastIndex: 6, entries to be added from: 0 12:00:50,226 AM [main] [DEBUG] Follower - follower-271 (Follower): Append entry to log foo-7 12:00:50,226 AM [main] [DEBUG] ReplicatedLogImpl - follower-271: Append log entry and persist DefaultLogEntry[index=7, term=1, command=foo-7] 12:00:50,226 AM [main] [DEBUG] ReplicatedLogImpl - follower-271: persist complete JournaledLogEntry{index=7, term=1, command=foo-7, pending=false} 12:00:50,226 AM [main] [DEBUG] Follower - follower-271 (Follower): Log size is now 8 12:00:50,226 AM [main] [DEBUG] Follower - follower-271 (Follower): Commit index set to 6 12:00:50,226 AM [main] [DEBUG] Follower - follower-271 (Follower): handleAppendEntries returning : AppendEntriesReply{term=1, success=true, followerId=follower-271, logLastIndex=7, logLastTerm=1, forceInstallSnapshot=false, needsLeaderAddress=false, payloadVersion=5, raftVersion=5, recipientRaftVersion=5} 12:00:50,226 AM [main] [DEBUG] SyncStatusTracker - follower-271: Lagging 0 entries behind leader leader-272 and reached 6 (of expected 5) 12:00:50,226 AM [main] [DEBUG] Follower - follower-271 (Follower): applyLogToStateMachine, appendEntries.getLeaderCommit(): 6, context.getLastApplied(): 5, lastIndex(): 7 12:00:50,226 AM [main] [DEBUG] RaftActorBehavior - follower-271 (Follower): Setting last applied to 6 12:00:50,226 AM [main] [DEBUG] AbstractReplicatedLog - follower-271: Moving last applied index from 5 to 6 [WARN] [07/02/2025 00:00:50.226] [test-pekko.actor.default-dispatcher-12] [pekko://test/deadLetters] received dead letter from TestActor[pekko://test/user/follower-271]: AppendEntriesReply{term=1, success=true, followerId=follower-271, logLastIndex=7, logLastTerm=1, forceInstallSnapshot=false, needsLeaderAddress=false, payloadVersion=5, raftVersion=5, recipientRaftVersion=5} 12:00:50,226 AM [main] [DEBUG] RaftActor - follower-271: Applying state for log index 6 data foo-6 12:00:50,226 AM [main] [INFO] MockRaftActor - follower-271: applyState called: foo-6 [WARN] [07/02/2025 00:00:50.226] [test-pekko.actor.default-dispatcher-12] [pekko://test/user/follower-271] unhandled message from Actor[pekko://test/deadLetters]: FollowerInitialSyncUpStatus[memberId=follower-271, initialSyncDone=true] 12:00:50,226 AM [main] [DEBUG] RaftStorageCompleter - test: running 1 completion(s) 12:00:50,226 AM [main] [INFO] SnapshotManager - follower-271: Persising snapshot at EntryInfo[index=-1, term=-1]/EntryInfo[index=5, term=1] 12:00:50,226 AM [main] [INFO] MockRaftActor - follower-271: support() called 12:00:50,227 AM [main] [INFO] SnapshotManager - follower-271: Removed in-memory snapshotted entries, adjusted snaphsotIndex: 4 and term: 1 12:00:50,227 AM [main] [DEBUG] SnapshotManager - follower-271: Snapshot success with first journal index 6 12:00:50,227 AM [main] [DEBUG] RaftActorSnapshotMessageSupport - follower-271: SnapshotComplete received 12:00:50,227 AM [main] [DEBUG] Follower - follower-271 (Follower): handleAppendEntries: AppendEntries{term=1, leaderId=leader-272, prevLogIndex=7, prevLogTerm=1, leaderCommit=7, replicatedToAllIndex=7, payloadVersion=0, recipientRaftVersion=5, leaderRaftVersion=5, entries==[DefaultLogEntry[index=8, term=1, command=foo-7]]} 12:00:50,227 AM [main] [DEBUG] Follower - follower-271 (Follower): Number of entries to be appended = 1 12:00:50,227 AM [main] [DEBUG] Follower - follower-271 (Follower): After cleanup, lastIndex: 7, entries to be added from: 0 12:00:50,227 AM [main] [DEBUG] Follower - follower-271 (Follower): Append entry to log foo-7 12:00:50,227 AM [main] [DEBUG] ReplicatedLogImpl - follower-271: Append log entry and persist DefaultLogEntry[index=8, term=1, command=foo-7] 12:00:50,227 AM [main] [DEBUG] ReplicatedLogImpl - follower-271: persist complete JournaledLogEntry{index=8, term=1, command=foo-7, pending=false} 12:00:50,227 AM [main] [DEBUG] Follower - follower-271 (Follower): Log size is now 4 12:00:50,227 AM [main] [DEBUG] Follower - follower-271 (Follower): Commit index set to 7 12:00:50,227 AM [main] [DEBUG] Follower - follower-271 (Follower): handleAppendEntries returning : AppendEntriesReply{term=1, success=true, followerId=follower-271, logLastIndex=8, logLastTerm=1, forceInstallSnapshot=false, needsLeaderAddress=false, payloadVersion=5, raftVersion=5, recipientRaftVersion=5} 12:00:50,227 AM [main] [DEBUG] SyncStatusTracker - follower-271: Lagging 0 entries behind leader leader-272 and reached 7 (of expected 5) 12:00:50,227 AM [main] [DEBUG] Follower - follower-271 (Follower): applyLogToStateMachine, appendEntries.getLeaderCommit(): 7, context.getLastApplied(): 6, lastIndex(): 8 12:00:50,227 AM [main] [DEBUG] RaftActorBehavior - follower-271 (Follower): Setting last applied to 7 12:00:50,227 AM [main] [DEBUG] AbstractReplicatedLog - follower-271: Moving last applied index from 6 to 7 12:00:50,227 AM [main] [DEBUG] RaftActor - follower-271: Applying state for log index 7 data foo-7 12:00:50,227 AM [main] [INFO] MockRaftActor - follower-271: applyState called: foo-7 [WARN] [07/02/2025 00:00:50.227] [test-pekko.actor.default-dispatcher-12] [pekko://test/deadLetters] received dead letter from TestActor[pekko://test/user/follower-271]: AppendEntriesReply{term=1, success=true, followerId=follower-271, logLastIndex=8, logLastTerm=1, forceInstallSnapshot=false, needsLeaderAddress=false, payloadVersion=5, raftVersion=5, recipientRaftVersion=5} 12:00:50,227 AM [main] [DEBUG] SnapshotManager - follower-271: fakeSnapshot purging log to 6 for term 1 12:00:50,227 AM [main] [INFO] TestActorFactory - Killing actor Actor[pekko://test/user/$g#-297414096] 12:00:50,228 AM [main] [INFO] TestActorFactory - Killing actor TestActor[pekko://test/user/follower-271] 12:00:50,228 AM [main] [DEBUG] PekkoRaftStorage - follower-271: terminating thread VirtualThread[#697,follower-271-writer-123]/waiting 12:00:50,228 AM [follower-271-writer-123] [DEBUG] JournalWriteTask - follower-271: received 1 commands after 10.90 ms 12:00:50,228 AM [follower-271-writer-123] [DEBUG] JournalWriteTask - follower-271: completed 1 commands in 12.73 μs 12:00:50,228 AM [follower-271-writer-123] [DEBUG] JournalWriteTask - follower-271: journal writer stopped 12:00:50,228 AM [main] [DEBUG] EntryJournalV1 - follower-271: journal closed 12:00:50,228 AM [main] [INFO] PekkoRaftStorage - follower-271: journal closed 12:00:50,228 AM [main] [DEBUG] RaftStorage - follower-271: stopped executor with 0 remaining tasks 12:00:50,228 AM [main] [DEBUG] RaftStorage - follower-271: stopped executor with 0 remaining tasks [WARN] [07/02/2025 00:00:50.231] [test-pekko.actor.default-dispatcher-11] [pekko://test/user/termination-monitor] received dead letter from TestActor[pekko://test/user/leader-273]: org.opendaylight.controller.cluster.common.actor.Monitor@1061cf9c 12:00:50,231 AM [main] [INFO] RaftActor - leader-273: Starting recovery with journal batch size 1000 12:00:50,231 AM [main] [DEBUG] RaftStorage - leader-273: started executor 12:00:50,231 AM [main] [DEBUG] RaftStorage - leader-273: started executor 12:00:50,232 AM [main] [DEBUG] EntryJournalV1 - leader-273: metadata journal open: replayFrom=1 applyTo=0 12:00:50,232 AM [main] [DEBUG] EntryJournalV1 - leader-273: journal open: firstIndex=1 lastIndex=0 replayFrom=1 fileEntries=0 12:00:50,232 AM [main] [INFO] PekkoRaftStorage - leader-273: journal open: applyTo=0 12:00:50,232 AM [leader-273-writer-124] [DEBUG] JournalWriteTask - leader-273: journal writer started 12:00:50,232 AM [leader-273-writer-124] [DEBUG] JournalWriteTask - leader-273: waiting to receive commands 12:00:50,233 AM [test-pekko.actor.default-dispatcher-11] [DEBUG] PropertiesTermInfoStore - /tmp/org.opendaylight.controller.cluster.raft.RaftActorTest5227996413212984776/leader-273/TermInfo.properties does not exist 12:00:50,233 AM [test-pekko.actor.default-dispatcher-11] [INFO] PekkoRecovery - leader-273: Recovery completed - Switching actor to Follower - last log index = -1, last log term = -1, snapshot index = -1, snapshot term = -1, journal size = 0 12:00:50,235 AM [test-pekko.actor.default-dispatcher-11] [DEBUG] PropertiesTermInfoStore - leader-273: Set currentTerm=0, votedFor=null 12:00:50,235 AM [test-pekko.actor.default-dispatcher-11] [INFO] PekkoRecovery - leader-273: Local TermInfo store seeded with TermInfo{term=0} 12:00:50,235 AM [test-pekko.actor.default-dispatcher-11] [DEBUG] RaftActor - leader-273: Pekko recovery completed with org.opendaylight.controller.cluster.raft.RecoveryLog@4be1bf0e 12:00:50,236 AM [main] [DEBUG] PropertiesTermInfoStore - leader-273: Set currentTerm=1, votedFor=leader-273 12:00:50,236 AM [main] [DEBUG] AbstractLeader - leader-273 (Leader): Election: Leader has following peers: [follower-274] 12:00:50,236 AM [main] [DEBUG] AbstractLeader - leader-273 (Leader): Checking sendAppendEntries for follower follower-274: active: false, followerNextIndex: -1, leaderLastIndex: -1, leaderSnapShotIndex: -1 12:00:50,236 AM [main] [DEBUG] RaftActor - leader-273: Persist data index=0 term=1 command=1 12:00:50,236 AM [main] [DEBUG] ReplicatedLogImpl - leader-273: Append log entry and persist JournaledLogEntry{index=0, term=1, command=1, pending=true} 12:00:50,236 AM [main] [DEBUG] AbstractLeader - leader-273 (Leader): Replicate message: identifier: MockIdentifier{value=1}, logIndex: 0, isSendImmediate: true 12:00:50,236 AM [main] [DEBUG] DefaultConfigParamsImpl - No custom RaftPolicy specified. Using DefaultRaftPolicy 12:00:50,236 AM [main] [DEBUG] AbstractLeader - leader-273 (Leader): Checking sendAppendEntries for follower follower-274: active: false, followerNextIndex: -1, leaderLastIndex: 0, leaderSnapShotIndex: -1 12:00:50,236 AM [main] [DEBUG] AbstractLeader - leader-273 (Leader): handleAppendEntriesReply - FollowerLogInformation for follower-274 updated: matchIndex: 0, nextIndex: 1 12:00:50,236 AM [main] [DEBUG] AbstractLeader - leader-273 (Leader): Checking sendAppendEntries for follower follower-274: active: true, followerNextIndex: 1, leaderLastIndex: 0, leaderSnapShotIndex: -1 12:00:50,236 AM [main] [DEBUG] ReplicatedLogImpl - leader-273: persist complete JournaledLogEntry{index=0, term=1, command=1, pending=true} 12:00:50,236 AM [main] [DEBUG] AbstractLeader - leader-273 (Leader): Applying to log - commitIndex: 0, lastAppliedIndex: -1 12:00:50,236 AM [main] [DEBUG] RaftActorBehavior - leader-273 (Leader): Setting last applied to 0 12:00:50,236 AM [main] [DEBUG] AbstractReplicatedLog - leader-273: Moving last applied index from -1 to 0 12:00:50,236 AM [main] [DEBUG] RaftActor - leader-273: Applying state for log index 0 data 1 12:00:50,236 AM [main] [INFO] MockRaftActor - leader-273: applyState called: 1 12:00:50,236 AM [main] [INFO] TestActorFactory - Killing actor Actor[pekko://test/user/$h#-1257859970] 12:00:50,237 AM [main] [INFO] TestActorFactory - Killing actor TestActor[pekko://test/user/leader-273] 12:00:50,237 AM [main] [DEBUG] PekkoRaftStorage - leader-273: terminating thread VirtualThread[#698,leader-273-writer-124]/waiting 12:00:50,237 AM [leader-273-writer-124] [DEBUG] JournalWriteTask - leader-273: received 1 commands after 5.221 ms 12:00:50,237 AM [leader-273-writer-124] [DEBUG] JournalWriteTask - leader-273: completed 1 commands in 11.27 μs 12:00:50,237 AM [leader-273-writer-124] [DEBUG] JournalWriteTask - leader-273: journal writer stopped 12:00:50,238 AM [main] [DEBUG] EntryJournalV1 - leader-273: journal closed 12:00:50,238 AM [main] [INFO] PekkoRaftStorage - leader-273: journal closed 12:00:50,238 AM [main] [DEBUG] RaftStorage - leader-273: stopped executor with 0 remaining tasks 12:00:50,238 AM [main] [DEBUG] RaftStorage - leader-273: stopped executor with 0 remaining tasks 12:00:50,239 AM [main] [INFO] RaftActorTest - testRestoreFromSnapshot starting [WARN] [07/02/2025 00:00:50.239] [test-pekko.actor.default-dispatcher-11] [pekko://test/user/termination-monitor] received dead letter from TestActor[pekko://test/user/test-actor-275]: org.opendaylight.controller.cluster.common.actor.Monitor@7cd0cdcf 12:00:50,240 AM [test-pekko.actor.default-dispatcher-12] [INFO] RaftActor - test-actor-275: Starting recovery with journal batch size 1000 12:00:50,240 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] RaftStorage - test-actor-275: started executor 12:00:50,240 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] RaftStorage - test-actor-275: started executor 12:00:50,241 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] EntryJournalV1 - test-actor-275: metadata journal open: replayFrom=1 applyTo=0 12:00:50,242 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] EntryJournalV1 - test-actor-275: journal open: firstIndex=1 lastIndex=0 replayFrom=1 fileEntries=0 12:00:50,242 AM [test-pekko.actor.default-dispatcher-12] [INFO] PekkoRaftStorage - test-actor-275: journal open: applyTo=0 12:00:50,242 AM [test-actor-275-writer-125] [DEBUG] JournalWriteTask - test-actor-275: journal writer started 12:00:50,242 AM [test-actor-275-writer-125] [DEBUG] JournalWriteTask - test-actor-275: waiting to receive commands 12:00:50,243 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] PropertiesTermInfoStore - /tmp/org.opendaylight.controller.cluster.raft.RaftActorTest11718684144241833397/test-actor-275/TermInfo.properties does not exist 12:00:50,243 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] RaftStorage - test-actor-275: skipping unrecognized file /tmp/org.opendaylight.controller.cluster.raft.RaftActorTest11718684144241833397/test-actor-275/journal-v1-1.log 12:00:50,243 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] RaftStorage - test-actor-275: skipping unrecognized file /tmp/org.opendaylight.controller.cluster.raft.RaftActorTest11718684144241833397/test-actor-275/metadata-v1-1.log 12:00:50,243 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] RaftStorage - test-actor-275: no eligible files found 12:00:50,243 AM [test-pekko.actor.default-dispatcher-12] [INFO] PekkoRecovery - test-actor-275: Recovery completed - Switching actor to Follower - last log index = -1, last log term = -1, snapshot index = -1, snapshot term = -1, journal size = 0 12:00:50,250 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] PropertiesTermInfoStore - test-actor-275: Set currentTerm=0, votedFor=null 12:00:50,250 AM [test-pekko.actor.default-dispatcher-12] [INFO] PekkoRecovery - test-actor-275: Local TermInfo store seeded with TermInfo{term=0} 12:00:50,250 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] PekkoRecovery - test-actor-275: Restoring snapshot: Snapshot [lastIndex=4, lastTerm=1, lastAppliedIndex=3, lastAppliedTerm=1, unAppliedEntries size=1, state=MockSnapshotState[state=[A, B, C, D]], electionTerm=1, electionVotedFor=member-1, ServerConfigPayload=null] 12:00:50,265 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] PekkoRecovery - test-actor-275: initializing from snapshot taken at 2025-07-02T00:00:50.265062186Z 12:00:50,266 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] PropertiesTermInfoStore - test-actor-275: Set currentTerm=1, votedFor=member-1 12:00:50,266 AM [test-pekko.actor.default-dispatcher-12] [INFO] PekkoRecovery - Recovery snapshot applied for test-actor-275 in 148.3 μs: snapshotIndex=3, snapshotTerm=1, journal-size=1 12:00:50,267 AM [test-pekko.actor.default-dispatcher-12] [INFO] MockRaftActor - test-actor-275: support() called 12:00:50,267 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] RaftStorage - test-actor-275: starting snapshot writeout to /tmp/org.opendaylight.controller.cluster.raft.RaftActorTest11718684144241833397/test-actor-275/snapshot-00000000686476B2-0FCC872A.tmp 12:00:50,270 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] RaftStorage - test-actor-275: finished snapshot writeout to /tmp/org.opendaylight.controller.cluster.raft.RaftActorTest11718684144241833397/test-actor-275/snapshot-00000000686476B2-0FCC872A.v1 12:00:50,270 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] RaftStorage - test-actor-275: selected SNAPSHOT_V1 to handle file /tmp/org.opendaylight.controller.cluster.raft.RaftActorTest11718684144241833397/test-actor-275/snapshot-00000000686476B2-0FCC872A.v1 12:00:50,270 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] RaftStorage - test-actor-275: skipping unrecognized file /tmp/org.opendaylight.controller.cluster.raft.RaftActorTest11718684144241833397/test-actor-275/TermInfo.properties 12:00:50,270 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] RaftStorage - test-actor-275: skipping unrecognized file /tmp/org.opendaylight.controller.cluster.raft.RaftActorTest11718684144241833397/test-actor-275/journal-v1-1.log 12:00:50,270 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] RaftStorage - test-actor-275: skipping unrecognized file /tmp/org.opendaylight.controller.cluster.raft.RaftActorTest11718684144241833397/test-actor-275/metadata-v1-1.log 12:00:50,270 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] RaftStorage - test-actor-275: retaining snapshot SnapshotFileV1{lastIncluded=EntryInfo[index=3, term=1], timestamp=2025-07-02T00:00:50.265062186Z, file=/tmp/org.opendaylight.controller.cluster.raft.RaftActorTest11718684144241833397/test-actor-275/snapshot-00000000686476B2-0FCC872A.v1, size=513, entryCompress=NONE, stateCompress=NONE} 12:00:50,270 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] RaftActor - test-actor-275: Pekko recovery completed with org.opendaylight.controller.cluster.raft.RecoveryLog@187c2080 12:00:50,270 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] AbstractReplicatedLog - test-actor-275: Moving last applied index from -1 to 3 12:00:50,270 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] JournalRecovery - test-actor-275: empty journal: appending 1 entries 12:00:50,270 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] EntryJournalV1 - test-actor-275: updated meta to JournalMeta[replayFrom=1, applyTo=0] 12:00:50,273 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] JournalRecovery - test-actor-275: journal recovery completedin 2.718 ms with journalIndex=1 12:00:50,273 AM [main] [DEBUG] RaftStorage - test-actor-275: selected SNAPSHOT_V1 to handle file /tmp/org.opendaylight.controller.cluster.raft.RaftActorTest11718684144241833397/test-actor-275/snapshot-00000000686476B2-0FCC872A.v1 12:00:50,274 AM [main] [DEBUG] RaftStorage - test-actor-275: skipping unrecognized file /tmp/org.opendaylight.controller.cluster.raft.RaftActorTest11718684144241833397/test-actor-275/TermInfo.properties 12:00:50,274 AM [main] [DEBUG] RaftStorage - test-actor-275: skipping unrecognized file /tmp/org.opendaylight.controller.cluster.raft.RaftActorTest11718684144241833397/test-actor-275/journal-v1-1.log 12:00:50,274 AM [main] [DEBUG] RaftStorage - test-actor-275: skipping unrecognized file /tmp/org.opendaylight.controller.cluster.raft.RaftActorTest11718684144241833397/test-actor-275/metadata-v1-1.log 12:00:50,274 AM [test-pekko.actor.default-dispatcher-12] [INFO] DefaultConfigParamsImpl - Trying to use custom RaftPolicy org.opendaylight.controller.cluster.raft.policy.DisableElectionsRaftPolicy 12:00:50,274 AM [main] [DEBUG] RaftStorage - test-actor-275: picked SnapshotFileV1{lastIncluded=EntryInfo[index=3, term=1], timestamp=2025-07-02T00:00:50.265062186Z, file=/tmp/org.opendaylight.controller.cluster.raft.RaftActorTest11718684144241833397/test-actor-275/snapshot-00000000686476B2-0FCC872A.v1, size=513, entryCompress=NONE, stateCompress=NONE} as the latest file [WARN] [07/02/2025 00:00:50.275] [test-pekko.actor.default-dispatcher-11] [pekko://test/user/termination-monitor] received dead letter from TestActor[pekko://test/user/test-actor-276]: org.opendaylight.controller.cluster.common.actor.Monitor@5a1a3d16 12:00:50,276 AM [test-pekko.actor.default-dispatcher-7] [INFO] RaftActor - test-actor-276: Starting recovery with journal batch size 1000 12:00:50,276 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] RaftStorage - test-actor-276: started executor 12:00:50,276 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] RaftStorage - test-actor-276: started executor 12:00:50,277 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] EntryJournalV1 - test-actor-276: metadata journal open: replayFrom=1 applyTo=0 12:00:50,277 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] EntryJournalV1 - test-actor-276: journal open: firstIndex=1 lastIndex=0 replayFrom=1 fileEntries=0 12:00:50,277 AM [test-pekko.actor.default-dispatcher-7] [INFO] PekkoRaftStorage - test-actor-276: journal open: applyTo=0 12:00:50,277 AM [test-actor-276-writer-126] [DEBUG] JournalWriteTask - test-actor-276: journal writer started 12:00:50,277 AM [test-actor-276-writer-126] [DEBUG] JournalWriteTask - test-actor-276: waiting to receive commands 12:00:50,280 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] PropertiesTermInfoStore - /tmp/org.opendaylight.controller.cluster.raft.RaftActorTest11718684144241833397/test-actor-276/TermInfo.properties does not exist 12:00:50,281 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] RaftStorage - test-actor-276: skipping unrecognized file /tmp/org.opendaylight.controller.cluster.raft.RaftActorTest11718684144241833397/test-actor-276/journal-v1-1.log 12:00:50,281 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] RaftStorage - test-actor-276: skipping unrecognized file /tmp/org.opendaylight.controller.cluster.raft.RaftActorTest11718684144241833397/test-actor-276/metadata-v1-1.log 12:00:50,281 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] RaftStorage - test-actor-276: no eligible files found 12:00:50,281 AM [test-pekko.actor.default-dispatcher-7] [INFO] PekkoRecovery - test-actor-276: Recovery completed - Switching actor to Follower - last log index = -1, last log term = -1, snapshot index = -1, snapshot term = -1, journal size = 0 12:00:50,282 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] PropertiesTermInfoStore - test-actor-276: Set currentTerm=0, votedFor=null 12:00:50,282 AM [test-pekko.actor.default-dispatcher-7] [INFO] PekkoRecovery - test-actor-276: Local TermInfo store seeded with TermInfo{term=0} 12:00:50,282 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] PekkoRecovery - test-actor-276: Restoring snapshot: Snapshot [lastIndex=-1, lastTerm=-1, lastAppliedIndex=-1, lastAppliedTerm=-1, unAppliedEntries size=0, state=null, electionTerm=5, electionVotedFor=member-1, ServerConfigPayload=null] 12:00:50,282 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] PekkoRecovery - test-actor-276: initializing from snapshot taken at 2025-07-02T00:00:50.282715936Z 12:00:50,282 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] PropertiesTermInfoStore - test-actor-276: Set currentTerm=5, votedFor=member-1 12:00:50,282 AM [test-pekko.actor.default-dispatcher-7] [INFO] PekkoRecovery - Recovery snapshot applied for test-actor-276 in 2.260 μs: snapshotIndex=-1, snapshotTerm=-1, journal-size=0 12:00:50,282 AM [test-pekko.actor.default-dispatcher-7] [INFO] MockRaftActor - test-actor-276: support() called 12:00:50,283 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] RaftStorage - test-actor-276: starting snapshot writeout to /tmp/org.opendaylight.controller.cluster.raft.RaftActorTest11718684144241833397/test-actor-276/snapshot-00000000686476B2-10D9E720.tmp 12:00:50,284 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] RaftStorage - test-actor-276: finished snapshot writeout to /tmp/org.opendaylight.controller.cluster.raft.RaftActorTest11718684144241833397/test-actor-276/snapshot-00000000686476B2-10D9E720.v1 12:00:50,284 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] RaftStorage - test-actor-276: selected SNAPSHOT_V1 to handle file /tmp/org.opendaylight.controller.cluster.raft.RaftActorTest11718684144241833397/test-actor-276/snapshot-00000000686476B2-10D9E720.v1 12:00:50,284 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] RaftStorage - test-actor-276: skipping unrecognized file /tmp/org.opendaylight.controller.cluster.raft.RaftActorTest11718684144241833397/test-actor-276/TermInfo.properties 12:00:50,284 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] RaftStorage - test-actor-276: skipping unrecognized file /tmp/org.opendaylight.controller.cluster.raft.RaftActorTest11718684144241833397/test-actor-276/journal-v1-1.log 12:00:50,284 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] RaftStorage - test-actor-276: skipping unrecognized file /tmp/org.opendaylight.controller.cluster.raft.RaftActorTest11718684144241833397/test-actor-276/metadata-v1-1.log 12:00:50,284 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] RaftStorage - test-actor-276: retaining snapshot SnapshotFileV1{lastIncluded=EntryInfo[index=-1, term=-1], timestamp=2025-07-02T00:00:50.282715936Z, file=/tmp/org.opendaylight.controller.cluster.raft.RaftActorTest11718684144241833397/test-actor-276/snapshot-00000000686476B2-10D9E720.v1, size=64, entryCompress=NONE, stateCompress=NONE} 12:00:50,284 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] RaftActor - test-actor-276: Pekko recovery completed with org.opendaylight.controller.cluster.raft.RecoveryLog@708a0759 12:00:50,477 AM [main] [INFO] RaftActorTest - testRestoreFromSnapshot ending 12:00:50,477 AM [main] [INFO] TestActorFactory - Killing actor TestActor[pekko://test/user/test-actor-275] 12:00:50,488 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] PekkoRaftStorage - test-actor-275: terminating thread VirtualThread[#699,test-actor-275-writer-125]/waiting 12:00:50,488 AM [test-actor-275-writer-125] [DEBUG] JournalWriteTask - test-actor-275: received 1 commands after 246.3 ms 12:00:50,489 AM [test-actor-275-writer-125] [DEBUG] JournalWriteTask - test-actor-275: completed 1 commands in 12.68 μs 12:00:50,489 AM [test-actor-275-writer-125] [DEBUG] JournalWriteTask - test-actor-275: journal writer stopped 12:00:50,489 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] EntryJournalV1 - test-actor-275: journal closed 12:00:50,489 AM [test-pekko.actor.default-dispatcher-7] [INFO] PekkoRaftStorage - test-actor-275: journal closed 12:00:50,489 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] RaftStorage - test-actor-275: stopped executor with 0 remaining tasks 12:00:50,489 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] RaftStorage - test-actor-275: stopped executor with 0 remaining tasks 12:00:50,489 AM [main] [INFO] TestActorFactory - Killing actor TestActor[pekko://test/user/test-actor-276] 12:00:50,489 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] PekkoRaftStorage - test-actor-276: terminating thread VirtualThread[#700,test-actor-276-writer-126]/waiting 12:00:50,489 AM [test-actor-276-writer-126] [DEBUG] JournalWriteTask - test-actor-276: received 1 commands after 212.0 ms 12:00:50,489 AM [test-actor-276-writer-126] [DEBUG] JournalWriteTask - test-actor-276: completed 1 commands in 7.450 μs 12:00:50,489 AM [test-actor-276-writer-126] [DEBUG] JournalWriteTask - test-actor-276: journal writer stopped 12:00:50,490 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] EntryJournalV1 - test-actor-276: journal closed 12:00:50,490 AM [test-pekko.actor.default-dispatcher-7] [INFO] PekkoRaftStorage - test-actor-276: journal closed 12:00:50,490 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] RaftStorage - test-actor-276: stopped executor with 0 remaining tasks 12:00:50,490 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] RaftStorage - test-actor-276: stopped executor with 0 remaining tasks 12:00:50,491 AM [main] [INFO] RaftActorTest - testGetSnapshot starting [WARN] [07/02/2025 00:00:50.493] [test-pekko.actor.default-dispatcher-12] [pekko://test/user/termination-monitor] received dead letter from TestActor[pekko://test/user/test-actor-277]: org.opendaylight.controller.cluster.common.actor.Monitor@13f697cb 12:00:50,493 AM [test-pekko.actor.default-dispatcher-7] [INFO] RaftActor - test-actor-277: Starting recovery with journal batch size 1000 12:00:50,493 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] RaftStorage - test-actor-277: started executor 12:00:50,494 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] RaftStorage - test-actor-277: started executor 12:00:50,494 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] EntryJournalV1 - test-actor-277: metadata journal open: replayFrom=1 applyTo=0 12:00:50,494 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] EntryJournalV1 - test-actor-277: journal open: firstIndex=1 lastIndex=0 replayFrom=1 fileEntries=0 12:00:50,494 AM [test-pekko.actor.default-dispatcher-7] [INFO] PekkoRaftStorage - test-actor-277: journal open: applyTo=0 12:00:50,494 AM [test-actor-277-writer-127] [DEBUG] JournalWriteTask - test-actor-277: journal writer started 12:00:50,494 AM [test-actor-277-writer-127] [DEBUG] JournalWriteTask - test-actor-277: waiting to receive commands 12:00:50,497 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] PropertiesTermInfoStore - /tmp/org.opendaylight.controller.cluster.raft.RaftActorTest14691591230008946966/test-actor-277/TermInfo.properties does not exist 12:00:50,497 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] RaftStorage - test-actor-277: skipping unrecognized file /tmp/org.opendaylight.controller.cluster.raft.RaftActorTest14691591230008946966/test-actor-277/journal-v1-1.log 12:00:50,497 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] RaftStorage - test-actor-277: skipping unrecognized file /tmp/org.opendaylight.controller.cluster.raft.RaftActorTest14691591230008946966/test-actor-277/metadata-v1-1.log 12:00:50,497 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] RaftStorage - test-actor-277: no eligible files found 12:00:50,498 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] PropertiesTermInfoStore - test-actor-277: Set currentTerm=3, votedFor=member-1 12:00:50,498 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] PekkoRecovery - test-actor-277: Received ReplicatedLogEntry for recovery: index: 0, size: 1 12:00:50,498 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] PekkoRecovery - test-actor-277: Received ReplicatedLogEntry for recovery: index: 1, size: 1 12:00:50,498 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] PekkoRecovery - test-actor-277: Received apply journal entries for recovery, applying to state: 0 to 1 12:00:50,498 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] AbstractReplicatedLog - test-actor-277: Moving last applied index from -1 to 1 12:00:50,498 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] PekkoRecovery - test-actor-277: Received ReplicatedLogEntry for recovery: index: 2, size: 1 12:00:50,498 AM [test-pekko.actor.default-dispatcher-12] [INFO] PekkoRecovery - test-actor-277: Recovery completed in 113.3 μs - Switching actor to Follower - last log index = 2, last log term = 3, snapshot index = -1, snapshot term = -1, journal size = 3 12:00:50,577 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] PropertiesTermInfoStore - test-actor-277: Set currentTerm=3, votedFor=member-1 12:00:50,577 AM [test-pekko.actor.default-dispatcher-12] [INFO] PekkoRecovery - test-actor-277: Local TermInfo store seeded with TermInfo{term=3, votedFor=member-1} 12:00:50,577 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] RaftActor - test-actor-277: Pekko recovery completed with org.opendaylight.controller.cluster.raft.RecoveryLog@7b14b405 12:00:50,577 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] AbstractReplicatedLog - test-actor-277: Moving last applied index from -1 to 1 12:00:50,577 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] JournalRecovery - test-actor-277: empty journal: appending 3 entries 12:00:50,577 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] EntryJournalV1 - test-actor-277: updated meta to JournalMeta[replayFrom=1, applyTo=0] 12:00:50,584 AM [test-pekko.actor.default-dispatcher-12] [DEBUG] JournalRecovery - test-actor-277: journal recovery completedin 7.196 ms with journalIndex=1 12:00:50,597 AM [test-pekko.actor.default-dispatcher-11] [DEBUG] RaftActor - test-actor-277: onGetSnapshot 12:00:50,600 AM [test-pekko.actor.default-dispatcher-11] [DEBUG] RaftActor - test-actor-277: onGetSnapshot 12:00:50,600 AM [main] [INFO] RaftActorTest - testGetSnapshot ending 12:00:50,600 AM [main] [INFO] TestActorFactory - Killing actor TestActor[pekko://test/user/test-actor-277] 12:00:50,611 AM [test-pekko.actor.default-dispatcher-11] [DEBUG] PekkoRaftStorage - test-actor-277: terminating thread VirtualThread[#702,test-actor-277-writer-127]/waiting 12:00:50,611 AM [test-actor-277-writer-127] [DEBUG] JournalWriteTask - test-actor-277: received 1 commands after 116.2 ms 12:00:50,611 AM [test-actor-277-writer-127] [DEBUG] JournalWriteTask - test-actor-277: completed 1 commands in 12.42 μs 12:00:50,611 AM [test-actor-277-writer-127] [DEBUG] JournalWriteTask - test-actor-277: journal writer stopped 12:00:50,611 AM [test-pekko.actor.default-dispatcher-11] [DEBUG] EntryJournalV1 - test-actor-277: journal closed 12:00:50,611 AM [test-pekko.actor.default-dispatcher-11] [INFO] PekkoRaftStorage - test-actor-277: journal closed 12:00:50,611 AM [test-pekko.actor.default-dispatcher-11] [DEBUG] RaftStorage - test-actor-277: stopped executor with 0 remaining tasks 12:00:50,611 AM [test-pekko.actor.default-dispatcher-11] [DEBUG] RaftStorage - test-actor-277: stopped executor with 0 remaining tasks [INFO] [07/02/2025 00:00:50.612] [main] [CoordinatedShutdown(pekko://test)] Running CoordinatedShutdown with reason [ActorSystemTerminateReason] 12:00:50,612 AM [test-pekko.actor.default-dispatcher-11] [INFO] CoordinatedShutdown - Running CoordinatedShutdown with reason [ActorSystemTerminateReason] [WARN] [07/02/2025 00:00:50.613] [test-pekko.actor.default-dispatcher-12] [pekko://test/system/cluster/core/daemon] unhandled message from Actor[pekko://test/deadLetters]: Leave(pekko://test@10.30.171.227:17355) 12:00:50,614 AM [test-pekko.actor.default-dispatcher-11] [INFO] Cluster - Cluster Node [pekko://test@10.30.171.227:17355] - Exiting completed 12:00:50,614 AM [test-pekko.actor.default-dispatcher-11] [INFO] Cluster - Cluster Node [pekko://test@10.30.171.227:17355] - Shutting down... [INFO] [07/02/2025 00:00:50.614] [test-pekko.actor.internal-dispatcher-3] [Cluster(pekko://test)] Cluster Node [pekko://test@10.30.171.227:17355] - Exiting completed [INFO] [07/02/2025 00:00:50.614] [test-pekko.actor.internal-dispatcher-3] [Cluster(pekko://test)] Cluster Node [pekko://test@10.30.171.227:17355] - Shutting down... 12:00:50,615 AM [test-pekko.actor.default-dispatcher-11] [INFO] Cluster - Cluster Node [pekko://test@10.30.171.227:17355] - Successfully shut down 12:00:50,615 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] PekkoRaftStorage - testConstruction: terminating thread VirtualThread[#680,testConstruction-writer-106]/waiting 12:00:50,615 AM [test-pekko.actor.default-dispatcher-6] [DEBUG] PekkoRaftStorage - testFindLeader: terminating thread VirtualThread[#676,testFindLeader-writer-102]/waiting [INFO] [07/02/2025 00:00:50.614] [test-pekko.actor.internal-dispatcher-3] [Cluster(pekko://test)] Cluster Node [pekko://test@10.30.171.227:17355] - Successfully shut down 12:00:50,616 AM [testConstruction-writer-106] [DEBUG] JournalWriteTask - testConstruction: received 1 commands after 3.007 s 12:00:50,616 AM [testFindLeader-writer-102] [DEBUG] JournalWriteTask - testFindLeader: received 1 commands after 8.256 s 12:00:50,616 AM [testConstruction-writer-106] [DEBUG] JournalWriteTask - testConstruction: completed 1 commands in 27.79 μs 12:00:50,616 AM [testConstruction-writer-106] [DEBUG] JournalWriteTask - testConstruction: journal writer stopped 12:00:50,616 AM [testFindLeader-writer-102] [DEBUG] JournalWriteTask - testFindLeader: completed 1 commands in 16.37 μs 12:00:50,616 AM [testFindLeader-writer-102] [DEBUG] JournalWriteTask - testFindLeader: journal writer stopped 12:00:50,616 AM [test-pekko.actor.default-dispatcher-6] [DEBUG] EntryJournalV1 - testFindLeader: journal closed 12:00:50,616 AM [test-pekko.actor.default-dispatcher-6] [INFO] PekkoRaftStorage - testFindLeader: journal closed 12:00:50,616 AM [test-pekko.actor.default-dispatcher-6] [DEBUG] RaftStorage - testFindLeader: stopped executor with 0 remaining tasks 12:00:50,616 AM [test-pekko.actor.default-dispatcher-6] [DEBUG] RaftStorage - testFindLeader: stopped executor with 0 remaining tasks 12:00:50,616 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] EntryJournalV1 - testConstruction: journal closed 12:00:50,616 AM [test-pekko.actor.default-dispatcher-7] [INFO] PekkoRaftStorage - testConstruction: journal closed 12:00:50,616 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] RaftStorage - testConstruction: stopped executor with 0 remaining tasks 12:00:50,617 AM [test-pekko.actor.default-dispatcher-7] [DEBUG] RaftStorage - testConstruction: stopped executor with 0 remaining tasks [INFO] [07/02/2025 00:00:50.617] [test-pekko.remote.default-remote-dispatcher-8] [pekko://test@10.30.171.227:17355/system/remoting-terminator] Shutting down remote daemon. [INFO] [07/02/2025 00:00:50.617] [test-pekko.remote.default-remote-dispatcher-8] [pekko://test@10.30.171.227:17355/system/remoting-terminator] Remote daemon shut down; proceeding with flushing remote transports. 12:00:50,618 AM [test-pekko.actor.default-dispatcher-6] [INFO] RemoteActorRefProvider$RemotingTerminator - Shutting down remote daemon. 12:00:50,618 AM [test-pekko.actor.default-dispatcher-6] [INFO] RemoteActorRefProvider$RemotingTerminator - Remote daemon shut down; proceeding with flushing remote transports. [INFO] [07/02/2025 00:00:50.619] [test-pekko.remote.default-remote-dispatcher-8] [pekko://test@10.30.171.227:17355/system/remoting-terminator] Remoting shut down. 12:00:50,619 AM [test-pekko.actor.default-dispatcher-6] [INFO] RemoteActorRefProvider$RemotingTerminator - Remoting shut down. [DEBUG] [07/02/2025 00:00:50.619] [test-pekko.actor.internal-dispatcher-4] [EventStream] shutting down: StandardOutLogger