diff --git a/src/backend/distributed/sql/citus--10.1-1--10.2-1.sql b/src/backend/distributed/sql/citus--10.1-1--10.2-1.sql index 507a141c5..1a6400c47 100644 --- a/src/backend/distributed/sql/citus--10.1-1--10.2-1.sql +++ b/src/backend/distributed/sql/citus--10.1-1--10.2-1.sql @@ -31,6 +31,7 @@ CREATE FUNCTION pg_catalog.citus_drop_all_shards(logicalrelid regclass, AS 'MODULE_PATHNAME', $$citus_drop_all_shards$$; COMMENT ON FUNCTION pg_catalog.citus_drop_all_shards(regclass, text, text, boolean) IS 'drop all shards in a relation and update metadata'; +ALTER TABLE pg_dist_partition ADD COLUMN autoconverted boolean; #include "udfs/citus_drop_trigger/10.2-1.sql"; #include "udfs/citus_prepare_pg_upgrade/10.2-1.sql" #include "udfs/citus_finish_pg_upgrade/10.2-1.sql" diff --git a/src/backend/distributed/sql/downgrades/citus--10.2-1--10.1-1.sql b/src/backend/distributed/sql/downgrades/citus--10.2-1--10.1-1.sql index 1e47b42c4..fad472442 100644 --- a/src/backend/distributed/sql/downgrades/citus--10.2-1--10.1-1.sql +++ b/src/backend/distributed/sql/downgrades/citus--10.2-1--10.1-1.sql @@ -25,6 +25,7 @@ DROP PROCEDURE pg_catalog.drop_old_time_partitions(regclass, timestamptz); REVOKE ALL ON FUNCTION pg_catalog.worker_record_sequence_dependency(regclass,regclass,name) FROM PUBLIC; ALTER TABLE pg_catalog.pg_dist_placement DROP CONSTRAINT placement_shardid_groupid_unique_index; +ALTER TABLE pg_catalog.pg_dist_partition DROP COLUMN autoconverted; DROP FUNCTION pg_catalog.citus_drop_all_shards(regclass, text, text, boolean); CREATE FUNCTION pg_catalog.citus_drop_all_shards(logicalrelid regclass, diff --git a/src/backend/distributed/utils/foreign_key_relationship.c b/src/backend/distributed/utils/foreign_key_relationship.c index ac0cbb059..ff823415c 100644 --- a/src/backend/distributed/utils/foreign_key_relationship.c +++ b/src/backend/distributed/utils/foreign_key_relationship.c @@ -158,9 +158,9 @@ ShouldUndistributeCitusLocalTable(Oid relationId) { if (IsCitusTableType(relationOid, REFERENCE_TABLE)) { - /* + /* * The relation is connected to a reference table via foreign keys, - * we shouldn't undistribute it. + * we shouldn't undistribute it. */ return false; }