From 11aeeb59c8992bba0e4a3e6682bb1ec572deba79 Mon Sep 17 00:00:00 2001 From: Onder Kalaci Date: Tue, 21 Dec 2021 13:59:55 +0100 Subject: [PATCH] creation version --- src/backend/distributed/metadata/metadata_cache.c | 2 +- src/backend/distributed/metadata/metadata_sync.c | 2 +- src/backend/distributed/sql/citus--10.2-4--11.0-1.sql | 8 ++++++++ 3 files changed, 10 insertions(+), 2 deletions(-) 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;