From 6346f64f7a236db91bd9666ba6f6b6f0eaf8a53b Mon Sep 17 00:00:00 2001 From: fanjianye Date: Wed, 14 Dec 2022 16:54:44 +0800 Subject: [PATCH] finish tc recover future when replayComplete --- .../coordinator/impl/MLTransactionMetadataStore.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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()); } }