@@ -755,9 +755,6 @@ MtmBeginTransaction(MtmCurrentTrans* x)
755755MtmUnlock ();
756756elog (ERROR ,"Multimaster node is not online: current status %s" ,MtmNodeStatusMnem [Mtm -> status ]);
757757}
758- if (x -> isDistributed && XactIsoLevel != XACT_REPEATABLE_READ ) {
759- elog (LOG ,"Isolation level %s is not supported by multimaster" ,isoLevelStr [XactIsoLevel ]);
760- }
761758x -> containsDML = false;
762759x -> snapshot = MtmAssignCSN ();
763760x -> gtid .xid = InvalidTransactionId ;
@@ -984,9 +981,13 @@ MtmAbortPreparedTransaction(MtmCurrentTrans* x)
984981if (x -> status != TRANSACTION_STATUS_ABORTED ) {
985982MtmLock (LW_EXCLUSIVE );
986983tm = (MtmTransMap * )hash_search (MtmGid2State ,x -> gid ,HASH_REMOVE ,NULL );
987- Assert (tm != NULL && tm -> state != NULL );
988- MTM_LOG1 ("Abort prepared transaction %d with gid='%s'" ,x -> xid ,x -> gid );
989- MtmAbortTransaction (tm -> state );
984+ if (tm == NULL ) {
985+ elog (WARNING ,"Global transaciton ID %s is not found" ,x -> gid );
986+ }else {
987+ Assert (tm -> state != NULL );
988+ MTM_LOG1 ("Abort prepared transaction %d with gid='%s'" ,x -> xid ,x -> gid );
989+ MtmAbortTransaction (tm -> state );
990+ }
990991MtmUnlock ();
991992x -> status = TRANSACTION_STATUS_ABORTED ;
992993}else {
@@ -3938,7 +3939,11 @@ static void MtmProcessUtility(Node *parsetree, const char *queryString,
39383939standard_ProcessUtility (parsetree ,queryString ,context ,
39393940params ,dest ,completionTag );
39403941}
3941-
3942+
3943+ if (MtmTx .isDistributed && XactIsoLevel != XACT_REPEATABLE_READ ) {
3944+ elog (ERROR ,"Isolation level %s is not supported by multimaster" ,isoLevelStr [XactIsoLevel ]);
3945+ }
3946+
39423947if (MyXactAccessedTempRel )
39433948{
39443949MTM_LOG1 ("Xact accessed temp table, stopping replication" );