EgorKuts commented on code in PR #6807:
URL: https://github.com/apache/ignite-3/pull/6807#discussion_r2447802832
##########
modules/table/src/main/java/org/apache/ignite/internal/table/distributed/replicator/TransactionStateResolver.java:
##########
@@ -213,18 +215,20 @@ private void resolveTxStateFromTxCoordinator(
updateLocalTxMapAfterDistributedStateResolved(txId, txMetaFuture);
InternalClusterNode coordinator = coordinatorId == null ? null :
clusterNodeResolver.getById(coordinatorId);
-
if (coordinator == null) {
// This means the coordinator node have either left the cluster or
restarted.
markAbandoned(txId);
resolveTxStateFromCommitPartition(txId, commitGrpId, txMetaFuture);
} else {
- txMessageSender.resolveTxStateFromCoordinator(coordinator.name(),
txId, timestamp)
+ txMessageSender.resolveTxStateFromCoordinator(coordinator, txId,
timestamp)
.whenComplete((response, e) -> {
- if (e == null) {
-
txMetaFuture.complete(asTransactionMeta(response.txStateMeta()));
+ if (e == null && response.txStateMeta() != null) {
+
txMetaFuture.complete(asTransactionMeta(Objects.requireNonNull(response.txStateMeta())));
} else {
+ if (e != null && e.getCause() instanceof
RecipientLeftException) {
Review Comment:
RecipientLeftException is the specific exception we can get here that
signifies the recipient node was restarted, which is when we need to trigger
abandon
--
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]
