From 2a6c867cb023d183fe9a27700081a71ce7e99bde Mon Sep 17 00:00:00 2001 From: Simon Kelly Date: Thu, 8 Oct 2020 09:43:43 +0200 Subject: [PATCH] Make citus_prepare_pg_upgrade idempotent https://github.com/citusdata/citus/issues/3527 --- .../sql/udfs/citus_prepare_pg_upgrade/latest.sql | 15 +++++++++++++++ 1 file changed, 15 insertions(+) diff --git a/src/backend/distributed/sql/udfs/citus_prepare_pg_upgrade/latest.sql b/src/backend/distributed/sql/udfs/citus_prepare_pg_upgrade/latest.sql index 7f0d2affd..241974d75 100644 --- a/src/backend/distributed/sql/udfs/citus_prepare_pg_upgrade/latest.sql +++ b/src/backend/distributed/sql/udfs/citus_prepare_pg_upgrade/latest.sql @@ -4,6 +4,21 @@ CREATE OR REPLACE FUNCTION pg_catalog.citus_prepare_pg_upgrade() SET search_path = pg_catalog AS $cppu$ BEGIN + -- + -- Drop existing backup tables + -- + DROP TABLE IF EXISTS public.pg_dist_partition; + DROP TABLE IF EXISTS public.pg_dist_shard; + DROP TABLE IF EXISTS public.pg_dist_placement; + DROP TABLE IF EXISTS public.pg_dist_node_metadata; + DROP TABLE IF EXISTS public.pg_dist_node; + DROP TABLE IF EXISTS public.pg_dist_local_group; + DROP TABLE IF EXISTS public.pg_dist_transaction; + DROP TABLE IF EXISTS public.pg_dist_colocation; + DROP TABLE IF EXISTS public.pg_dist_authinfo; + DROP TABLE IF EXISTS public.pg_dist_poolinfo; + DROP TABLE IF EXISTS public.pg_dist_rebalance_strategy; + -- -- backup citus catalog tables --