external
/
citus
mirror of https://github.com/citusdata/citus.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fix Assert() in ProcessVariableSetStmt()

pull/2825/head
Hadi Moshayedi 2019-07-05 13:54:01 -07:00
parent 07d2266e11
commit 032167c553
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/backend/distributed/commands/variableset.c
View File

@ -83,9 +83,9 @@ ShouldPropagateSetCommand(VariableSetStmt *setStmt)
/* /*
* IsSettingSafeToPropagate returns whether a SET LOCAL is safe to propagate. * IsSettingSafeToPropagate returns whether a SET LOCAL is safe to propagate.
* *
* We exclude settings that are highly specific to the client or session and also ban * We exclude settings that are highly specific to the client or session and also
* ban propagating the SET command propagation setting (not for correctness, more to * ban propagating the citus.propagate_set_commands setting (not for correctness,
* avoid confusion). * more to avoid confusion).
*/ */
static bool static bool
IsSettingSafeToPropagate(char *name) IsSettingSafeToPropagate(char *name)
@ -124,7 +124,7 @@ ProcessVariableSetStmt(VariableSetStmt *setStmt, const char *setStmtString)
List *connectionList = NIL; List *connectionList = NIL;
/* at present we only support SET LOCAL */ /* at present we only support SET LOCAL */
AssertArg(setStmt->is_local); AssertArg(ShouldPropagateSetCommand(setStmt));
/* haven't seen any SET stmts so far in this (sub-)xact: initialize StringInfo */ /* haven't seen any SET stmts so far in this (sub-)xact: initialize StringInfo */
if (activeSetStmts == NULL) if (activeSetStmts == NULL)