[improve][txn] fix error in recoverTracker.handleCommittingAndAbortingTransaction() (#18924)

TakaHiR07 · web-flow · commit a35670d83b0b · 2022-12-16T10:56:55.000+08:00
Fixes #18923 ### Motivation As described in #18923, recoverTracker.handleCommittingAndAbortingTransaction() fail when TC recover. ### Modifications when transactionLog.replayAsync() finish, complete TC future.
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
@@ -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());
                     }
                 }

Original file line number	Diff line number	Diff line change
`@@ -127,9 +127,9 @@ public void replayComplete() {`
`127`	`127`	`+ tcID.toString() + " change state to Ready error when init it"));`
`128`	`128`
`129`	`129`	`} else {`
	`130`	`+ completableFuture.complete(MLTransactionMetadataStore.this);`
`130`	`131`	`recoverTracker.handleCommittingAndAbortingTransaction();`
`131`	`132`	`timeoutTracker.start();`
`132`		`- completableFuture.complete(MLTransactionMetadataStore.this);`
`133`	`133`	`recoverTime.setRecoverEndTime(System.currentTimeMillis());`
`134`	`134`	`}`
`135`	`135`	`}`