@@ -2080,6 +2080,7 @@ static void MtmInitialize()
20802080Mtm -> nodes [i ].originId = InvalidRepOriginId ;
20812081Mtm -> nodes [i ].timeline = 0 ;
20822082}
2083+ Mtm -> nodes [MtmNodeId - 1 ].originId = DoNotReplicateId ;
20832084PGSemaphoreCreate (& Mtm -> sendSemaphore );
20842085PGSemaphoreReset (& Mtm -> sendSemaphore );
20852086SpinLockInit (& Mtm -> spinlock );
@@ -2806,10 +2807,12 @@ void MtmFinishPreparedTransaction(MtmTransState* ts, bool commit)
28062807Assert (!IsTransactionState ());
28072808MtmResetTransaction ();
28082809StartTransactionCommand ();
2810+ #if 0
28092811if (Mtm -> nodes [MtmNodeId - 1 ].originId == InvalidRepOriginId ) {
28102812/* This dummy origin is used for local commits/aborts which should not be replicated */
28112813Mtm -> nodes [MtmNodeId - 1 ].originId = replorigin_create (psprintf (MULTIMASTER_SLOT_PATTERN ,MtmNodeId ));
28122814}
2815+ #endif
28132816MtmBeginSession (MtmNodeId );
28142817MtmSetCurrentTransactionCSN (ts -> csn );
28152818MtmSetCurrentTransactionGID (ts -> gid );