From 032167c553b53af1b1fa775fa581f6efbe8272c3 Mon Sep 17 00:00:00 2001 From: Hadi Moshayedi Date: Fri, 5 Jul 2019 13:54:01 -0700 Subject: [PATCH] Fix Assert() in ProcessVariableSetStmt() --- src/backend/distributed/commands/variableset.c | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/src/backend/distributed/commands/variableset.c b/src/backend/distributed/commands/variableset.c index cdef64fe9..87e3116ed 100644 --- a/src/backend/distributed/commands/variableset.c +++ b/src/backend/distributed/commands/variableset.c @@ -83,9 +83,9 @@ ShouldPropagateSetCommand(VariableSetStmt *setStmt) /* * 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 - * ban propagating the SET command propagation setting (not for correctness, more to - * avoid confusion). + * We exclude settings that are highly specific to the client or session and also + * ban propagating the citus.propagate_set_commands setting (not for correctness, + * more to avoid confusion). */ static bool IsSettingSafeToPropagate(char *name) @@ -124,7 +124,7 @@ ProcessVariableSetStmt(VariableSetStmt *setStmt, const char *setStmtString) List *connectionList = NIL; /* 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 */ if (activeSetStmts == NULL)