From 2db4ee7a503c089d88babab7af605608a0ccf7f4 Mon Sep 17 00:00:00 2001 From: Onder Kalaci Date: Tue, 29 Nov 2022 07:56:04 +0100 Subject: [PATCH] Partition drop first --- src/backend/distributed/worker/worker_drop_protocol.c | 2 ++ src/include/distributed/metadata_sync.h | 2 +- 2 files changed, 3 insertions(+), 1 deletion(-) diff --git a/src/backend/distributed/worker/worker_drop_protocol.c b/src/backend/distributed/worker/worker_drop_protocol.c index 53edac74a..f4ed73ce8 100644 --- a/src/backend/distributed/worker/worker_drop_protocol.c +++ b/src/backend/distributed/worker/worker_drop_protocol.c @@ -256,6 +256,8 @@ worker_drop_shell_table(PG_FUNCTION_ARGS) performDeletion(distributedTableObject, DROP_CASCADE, PERFORM_DELETION_INTERNAL); + CommandCounterInrement(); + PG_RETURN_VOID(); } diff --git a/src/include/distributed/metadata_sync.h b/src/include/distributed/metadata_sync.h index db63c46d6..b01e82762 100644 --- a/src/include/distributed/metadata_sync.h +++ b/src/include/distributed/metadata_sync.h @@ -118,7 +118,7 @@ extern void SyncDeleteColocationGroupToNodes(uint32 colocationId); #define DELETE_ALL_PARTITIONS "DELETE FROM pg_dist_partition" #define DELETE_ALL_COLOCATION "DELETE FROM pg_catalog.pg_dist_colocation" #define REMOVE_PARTITIONED_SHELL_TABLES_COMMAND \ - "SELECT worker_drop_shell_table(logicalrelid::regclass::text) FROM pg_dist_partition JOIN pg_class ON (logicalrelid = oid) WHERE relkind = 'p'" + "SELECT worker_drop_shell_table(logicalrelid::regclass::text) FROM pg_dist_partition JOIN pg_class ON (logicalrelid = oid) WHERE relkind != 'p'" #define REMOVE_ALL_SHELL_TABLES_COMMAND \ "SELECT worker_drop_shell_table(logicalrelid::regclass::text) FROM pg_dist_partition" #define REMOVE_ALL_CITUS_TABLES_COMMAND \