File tree Expand file tree Collapse file tree
pulsar-broker/src/test/java/org/apache/pulsar/broker/service Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -1687,7 +1687,7 @@ public void testReplicatorWithFailedAck() throws Exception {
16871687 Mockito .any ());
16881688
16891689 // Mock the readEntriesFailed scenario:
1690- // Use AtomicBoolean to control whether to trigger read failure, manually set true/false by test code.
1690+ // Use AtomicBoolean to control whether to trigger read failure
16911691 // Initialized to true to ensure the first readMoreEntries after replicator startup is intercepted.
16921692 AtomicBoolean isMakeReadFail = new AtomicBoolean (true );
16931693 doAnswer (invocation -> {
@@ -1719,7 +1719,6 @@ public void testReplicatorWithFailedAck() throws Exception {
17191719
17201720 // --- Test readEntriesFailed scenario ---
17211721 // isMakeReadFail is already true, replicator's readMoreEntries keeps failing
1722-
17231722 // Record current mark delete position
17241723 Position posBeforeReadFail = cursor .getMarkDeletedPosition ();
17251724
You can’t perform that action at this time.
0 commit comments