@@ -922,7 +922,7 @@ MtmEndTransaction(MtmCurrentTrans* x, bool commit)
922922Assert (Mtm -> status != MTM_RECOVERY );
923923/*
924924 * Send notification only if ABORT happens during transaction processing at replicas,
925- * do not send notification if ABORT isreceiver from master
925+ * do not send notification if ABORT isreceived from master
926926 */
927927MTM_LOG2 ("%d: send ABORT notification abort transaction %d to coordinator %d" ,MyProcPid ,x -> gtid .xid ,x -> gtid .node );
928928if (ts == NULL ) {
@@ -1377,7 +1377,7 @@ bool MtmRefreshClusterStatus(bool nowait)
13771377MtmCheckQuorum ();
13781378/* Interrupt voting for active transaction and abort them */
13791379for (ts = Mtm -> transListHead ;ts != NULL ;ts = ts -> next ) {
1380- if (!ts -> votingCompleted ) {
1380+ if (!ts -> votingCompleted && MtmIsCoordinator ( ts ) ) {
13811381if (ts -> status != TRANSACTION_STATUS_ABORTED ) {
13821382MTM_LOG1 ("Rollback active transaction %d:%d" ,ts -> gtid .node ,ts -> gtid .xid );
13831383MtmAbortTransaction (ts );
@@ -1443,7 +1443,7 @@ void MtmOnNodeDisconnect(int nodeId)
14431443MtmCheckQuorum ();
14441444/* Interrupt voting for active transaction and abort them */
14451445for (ts = Mtm -> transListHead ;ts != NULL ;ts = ts -> next ) {
1446- if (!ts -> votingCompleted ) {
1446+ if (!ts -> votingCompleted && MtmIsCoordinator ( ts ) ) {
14471447if (ts -> status != TRANSACTION_STATUS_ABORTED ) {
14481448MTM_LOG1 ("Rollback active transaction %d:%d" ,ts -> gtid .node ,ts -> gtid .xid );
14491449MtmAbortTransaction (ts );