Commit80daa6b

committed

Fix infinite loop of non-tx ddl statements

1 parentbf78c9e commit80daa6bCopy full SHA for 80daa6b

File tree

-2

lines changed

-2

lines changed

Lines changed: 2 additions & 2 deletions

Original file line number	Diff line number	Diff line change
`@@ -3897,7 +3897,7 @@ static void MtmProcessUtility(Node parsetree, const char queryString,`
`3897`	`3897`	`caseT_IndexStmt:`
`3898`	`3898`	`{`
`3899`	`3899`	`IndexStmtindexStmt= (IndexStmt)parsetree;`
`3900`		`-if (indexStmt->concurrent&& !IsTransactionBlock())`
	`3900`	`+if (indexStmt->concurrent&& !IsTransactionBlock()&& !MtmTx.isReplicated)`
`3901`	`3901`	`{`
`3902`	`3902`	`skipCommand= true;`
`3903`	`3903`	`MtmProcessDDLCommand(queryString, false);`
`@@ -3909,7 +3909,7 @@ static void MtmProcessUtility(Node parsetree, const char queryString,`
`3909`	`3909`	`caseT_DropStmt:`
`3910`	`3910`	`{`
`3911`	`3911`	`DropStmtstmt= (DropStmt)parsetree;`
`3912`		`-if (stmt->removeType==OBJECT_INDEX&&stmt->concurrent&& !IsTransactionBlock())`
	`3912`	`+if (stmt->removeType==OBJECT_INDEX&&stmt->concurrent&& !IsTransactionBlock()&& !MtmTx.isReplicated)`
`3913`	`3913`	`{`
`3914`	`3914`	`skipCommand= true;`
`3915`	`3915`	`MtmProcessDDLCommand(queryString, false);`

Comments

(0)