fix topic compaction is failed after compactedLedger being recover

TakaHiR07 · Nov 10, 2023 · c6403ce · c6403ce
1 parent 51202a6
commit c6403ce
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/compaction/CompactedTopicImpl.java b/pulsar-broker/src/main/java/org/apache/pulsar/compaction/CompactedTopicImpl.java
@@ -238,7 +238,7 @@ private static CompletableFuture<MessageIdData> readOneMessageId(LedgerHandle lh
 
     private static CompletableFuture<CompactedTopicContext> openCompactedLedger(BookKeeper bk, long id) {
         CompletableFuture<LedgerHandle> promise = new CompletableFuture<>();
-        bk.asyncOpenLedger(id,
+        bk.asyncOpenLedgerNoRecovery(id,
                            Compactor.COMPACTED_TOPIC_LEDGER_DIGEST_TYPE,
                            Compactor.COMPACTED_TOPIC_LEDGER_PASSWORD,
                            (rc, ledger, ctx) -> {

diff --git a/pulsar-broker/src/test/java/org/apache/pulsar/compaction/CompactedTopicTest.java b/pulsar-broker/src/test/java/org/apache/pulsar/compaction/CompactedTopicTest.java
@@ -855,7 +855,7 @@ public void testCompactWithConcurrentGetCompactionHorizonAndCompactedTopicContex
             Thread.sleep(1500);
             invocation.callRealMethod();
             return null;
-        }).when(bk).asyncOpenLedger(Mockito.anyLong(), Mockito.any(), Mockito.any(), Mockito.any(), Mockito.any());
+        }).when(bk).asyncOpenLedgerNoRecovery(Mockito.anyLong(), Mockito.any(), Mockito.any(), Mockito.any(), Mockito.any());
 
         LedgerHandle oldCompactedLedger = bk.createLedger(1, 1,
                 Compactor.COMPACTED_TOPIC_LEDGER_DIGEST_TYPE,