[fix][broker] Fix test

oneby-wang · oneby-wang · commit 8e5a1103e84b · 2025-12-24T16:58:27.000+08:00
diff --git a/managed-ledger/src/test/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerTest.java b/managed-ledger/src/test/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerTest.java
@@ -3826,12 +3826,12 @@ public void markDeleteComplete(Object ctx) {
 
                 }
             }, null);
-            taskFireLatch.wait();
+            taskFireLatch.await();
             CompletableFuture<Void> future = managedLedger.maybeUpdateCursorBeforeTrimmingConsumedLedger();
             updateCursorFutures.add(future);
         }
 
-        latch.countDown();
+        latch.await();
         assertEquals(cursor.getNumberOfEntries(), 0);
         // Will not throw exception
         FutureUtil.waitForAll(updateCursorFutures).get();

Original file line number	Diff line number	Diff line change
`@@ -3826,12 +3826,12 @@ public void markDeleteComplete(Object ctx) {`
`3826`	`3826`
`3827`	`3827`	`}`
`3828`	`3828`	`}, null);`
`3829`		`- taskFireLatch.wait();`
	`3829`	`+ taskFireLatch.await();`
`3830`	`3830`	`CompletableFuture<Void> future = managedLedger.maybeUpdateCursorBeforeTrimmingConsumedLedger();`
`3831`	`3831`	`updateCursorFutures.add(future);`
`3832`	`3832`	`}`
`3833`	`3833`
`3834`		`- latch.countDown();`
	`3834`	`+ latch.await();`
`3835`	`3835`	`assertEquals(cursor.getNumberOfEntries(), 0);`
`3836`	`3836`	`// Will not throw exception`
`3837`	`3837`	`FutureUtil.waitForAll(updateCursorFutures).get();`