Commit0ce22e9

committed

Fix infinite loop of non-tx ddl statements

1 parent0252391 commit0ce22e9Copy full SHA for 0ce22e9

File tree

-2

lines changed

-2

lines changed

Lines changed: 2 additions & 2 deletions

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

Comments

(0)