@@ -923,7 +923,7 @@ MtmEndTransaction(MtmCurrentTrans* x, bool commit)
923923Assert (Mtm -> status != MTM_RECOVERY );
924924/*
925925 * Send notification only if ABORT happens during transaction processing at replicas,
926- * do not send notification if ABORT isreceiver from master
926+ * do not send notification if ABORT isreceived from master
927927 */
928928MTM_LOG1 ("%d: send ABORT notification abort transaction %d to coordinator %d" ,MyProcPid ,x -> gtid .xid ,x -> gtid .node );
929929if (ts == NULL ) {
@@ -1378,7 +1378,7 @@ bool MtmRefreshClusterStatus(bool nowait)
13781378MtmCheckQuorum ();
13791379/* Interrupt voting for active transaction and abort them */
13801380for (ts = Mtm -> transListHead ;ts != NULL ;ts = ts -> next ) {
1381- if (!ts -> votingCompleted ) {
1381+ if (!ts -> votingCompleted && MtmIsCoordinator ( ts ) ) {
13821382if (ts -> status != TRANSACTION_STATUS_ABORTED ) {
13831383MTM_LOG1 ("1) Rollback active transaction %d:%d:%d" ,ts -> gtid .node ,ts -> gtid .xid ,ts -> xid );
13841384MtmAbortTransaction (ts );
@@ -1444,7 +1444,7 @@ void MtmOnNodeDisconnect(int nodeId)
14441444MtmCheckQuorum ();
14451445/* Interrupt voting for active transaction and abort them */
14461446for (ts = Mtm -> transListHead ;ts != NULL ;ts = ts -> next ) {
1447- if (!ts -> votingCompleted ) {
1447+ if (!ts -> votingCompleted && MtmIsCoordinator ( ts ) ) {
14481448if (ts -> status != TRANSACTION_STATUS_ABORTED ) {
14491449MTM_LOG1 ("2) Rollback active transaction %d:%d" ,ts -> gtid .node ,ts -> gtid .xid );
14501450MtmAbortTransaction (ts );