ascherbakoff commented on code in PR #7052:
URL: https://github.com/apache/ignite-3/pull/7052#discussion_r2580567119
##########
modules/transactions/src/main/java/org/apache/ignite/internal/tx/impl/TxManagerImpl.java:
##########
@@ -1209,6 +1210,19 @@ public void onReceived(NetworkMessage message,
InternalClusterNode sender, @Null
// Ignore error responses here. A transaction will be rolled back in
other place.
if (message instanceof ErrorReplicaResponse) {
+ ErrorReplicaResponse response = (ErrorReplicaResponse) message;
+
+ Throwable err = response.throwable();
+
+ Throwable cause = ExceptionUtils.unwrapCause(err);
+
+ if (cause instanceof DelayedAckException) {
Review Comment:
I don't think so. MismatchingTransactionOutcomeInternalException indicates
impossibility to set tx state to desired, because it's already in incompatble
state.
DelayedAckException reports impossibility to commit a transaction due to
partial replication.
--
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]
