diff --git a/managed-ledger/src/test/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerBkTest.java b/managed-ledger/src/test/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerBkTest.java index 03f51a2067720..e093385ced9bb 100644 --- a/managed-ledger/src/test/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerBkTest.java +++ b/managed-ledger/src/test/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerBkTest.java @@ -273,6 +273,9 @@ public void testConcurrentMarkDelete() throws Exception { future.get(); } + // Since in this test we roll-over the cursor ledger every 10 entries acknowledged, the background roll back + // might still be happening when the futures are completed. + Thread.sleep(1000); factory.shutdown(); }