denis-chudov commented on code in PR #2918:
URL: https://github.com/apache/ignite-3/pull/2918#discussion_r1422745366
##########
modules/table/src/main/java/org/apache/ignite/internal/table/distributed/replicator/PartitionReplicaListener.java:
##########
@@ -521,8 +524,35 @@ private CompletableFuture<Void>
processTxRecoveryAction(TxRecoveryMessage reques
LOG.info("Orphan transaction has to be aborted [tx={}].", txId);
- // TODO: IGNITE-20735 Implement initiate recovery handling logic.
- return nullCompletedFuture();
+ return triggerTxRecovery(txId)
+ .thenApply(v -> null);
+ }
+
+ /**
+ * Starts tx recovery process. Returns the future containing transaction
meta with its final state that completes
+ * when the recovery is completed.
+ *
+ * @param txId Transaction id.
+ * @return Tx recovery future, or failed future if the tx recovery is not
possible.
+ */
+ private CompletableFuture<TransactionMeta> triggerTxRecovery(UUID txId) {
Review Comment:
It will be done under IGNITE-20735
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
