diff --git a/src/backend/distributed/commands/database.c b/src/backend/distributed/commands/database.c index d9bbc663a..7e90cbc9e 100644 --- a/src/backend/distributed/commands/database.c +++ b/src/backend/distributed/commands/database.c @@ -159,7 +159,9 @@ PreprocessGrantOnDatabaseStmt(Node *node, const char *queryString, return NodeDDLTaskList(NON_COORDINATOR_NODES, commands); } -static bool isSetTablespaceStatement(AlterDatabaseStmt *stmt) + +static bool +isSetTablespaceStatement(AlterDatabaseStmt *stmt) { ListCell *lc = NULL; foreach(lc, stmt->options) @@ -190,11 +192,10 @@ PreprocessAlterDatabaseStmt(Node *node, const char *queryString, return NIL; } + EnsureCoordinator(); + AlterDatabaseStmt *stmt = castNode(AlterDatabaseStmt, node); - - - char *sql = DeparseTreeNode((Node *) stmt); List *commands = NULL;