@@ -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 {
@@ -3782,6 +3783,16 @@ static void MtmProcessUtility(Node *parsetree, const char *queryString,
37823783MTM_LOG3 ("%d: Process utility statement %s" ,MyProcPid ,queryString );
37833784switch (nodeTag (parsetree ))
37843785{
3786+ case T_IndexStmt :
3787+ {
3788+ IndexStmt * stmt = (IndexStmt * )parsetree ;
3789+ if (stmt -> concurrent ) {
3790+ stmt -> concurrent = false;
3791+ elog (WARNING ,"Disable concurrent option for index creation" );
3792+ }
3793+ break ;
3794+ }
3795+
37853796case T_TransactionStmt :
37863797{
37873798TransactionStmt * stmt = (TransactionStmt * )parsetree ;
@@ -3797,7 +3808,7 @@ static void MtmProcessUtility(Node *parsetree, const char *queryString,
37973808}
37983809break ;
37993810case TRANS_STMT_PREPARE :
3800- elog (ERROR ,"Two phase commit is not supported by multimaster" );
3811+ // elog(ERROR, "Two phase commit is not supported by multimaster");
38013812break ;
38023813case TRANS_STMT_COMMIT_PREPARED :
38033814case TRANS_STMT_ROLLBACK_PREPARED :
@@ -3957,7 +3968,11 @@ static void MtmProcessUtility(Node *parsetree, const char *queryString,
39573968standard_ProcessUtility (parsetree ,queryString ,context ,
39583969params ,dest ,completionTag );
39593970}
3960-
3971+
3972+ if (MtmTx .isDistributed && XactIsoLevel != XACT_REPEATABLE_READ ) {
3973+ elog (ERROR ,"Isolation level %s is not supported by multimaster" ,isoLevelStr [XactIsoLevel ]);
3974+ }
3975+
39613976if (MyXactAccessedTempRel )
39623977{
39633978MTM_LOG1 ("Xact accessed temp table, stopping replication" );