diff --git a/pulsar-transaction/coordinator/src/main/java/org/apache/pulsar/transaction/coordinator/impl/MLTransactionMetadataStore.java b/pulsar-transaction/coordinator/src/main/java/org/apache/pulsar/transaction/coordinator/impl/MLTransactionMetadataStore.java index fbb14fa86f3de..53a515ff99164 100644 --- a/pulsar-transaction/coordinator/src/main/java/org/apache/pulsar/transaction/coordinator/impl/MLTransactionMetadataStore.java +++ b/pulsar-transaction/coordinator/src/main/java/org/apache/pulsar/transaction/coordinator/impl/MLTransactionMetadataStore.java @@ -127,9 +127,9 @@ public void replayComplete() { + tcID.toString() + " change state to Ready error when init it")); } else { + completableFuture.complete(MLTransactionMetadataStore.this); recoverTracker.handleCommittingAndAbortingTransaction(); timeoutTracker.start(); - completableFuture.complete(MLTransactionMetadataStore.this); recoverTime.setRecoverEndTime(System.currentTimeMillis()); } }