diff --git a/src/backend/distributed/metadata/metadata_cache.c b/src/backend/distributed/metadata/metadata_cache.c index 52c4d258e..42d2ba0dd 100644 --- a/src/backend/distributed/metadata/metadata_cache.c +++ b/src/backend/distributed/metadata/metadata_cache.c @@ -2282,7 +2282,7 @@ DistNodeNodeIdIndexId(void) Oid DistLocalGroupIdRelationId(void) { - CachedRelationLookup("pg_dist_local_group", + CachedRelationLookup("pg_dist_local_node_info", &MetadataCache.distLocalGroupRelationId); return MetadataCache.distLocalGroupRelationId; diff --git a/src/backend/distributed/metadata/metadata_sync.c b/src/backend/distributed/metadata/metadata_sync.c index ecd01a2ab..78bbf418b 100644 --- a/src/backend/distributed/metadata/metadata_sync.c +++ b/src/backend/distributed/metadata/metadata_sync.c @@ -1487,7 +1487,7 @@ LocalGroupIdUpdateCommand(int32 groupId) { StringInfo updateCommand = makeStringInfo(); - appendStringInfo(updateCommand, "UPDATE pg_dist_local_group SET groupid = %d", + appendStringInfo(updateCommand, "UPDATE pg_dist_local_node_info SET groupid = %d", groupId); return updateCommand->data; diff --git a/src/backend/distributed/sql/citus--10.2-4--11.0-1.sql b/src/backend/distributed/sql/citus--10.2-4--11.0-1.sql index f4ba74584..76b031b62 100644 --- a/src/backend/distributed/sql/citus--10.2-4--11.0-1.sql +++ b/src/backend/distributed/sql/citus--10.2-4--11.0-1.sql @@ -30,3 +30,11 @@ BEGIN END IF; END; $$; + + +ALTER TABLE pg_dist_local_group DISABLE TRIGGER dist_local_group_cache_invalidate; +ALTER TABLE pg_dist_local_group RENAME TO pg_dist_local_node_info; +ALTER TABLE pg_dist_local_node_info ADD COLUMN citus_creation_version TEXT DEFAULT NULL; +UPDATE pg_dist_local_node_info SET citus_creation_version = (SELECT default_version FROM pg_available_extensions WHERE name = 'citus'); +ALTER TRIGGER dist_local_group_cache_invalidate ON pg_dist_local_node_info RENAME TO dist_local_info_cache_invalidate; +ALTER TABLE pg_dist_local_node_info ENABLE TRIGGER dist_local_info_cache_invalidate;