From 5c0a6476611fedd8d766214c5a9c1c6c87ab179b Mon Sep 17 00:00:00 2001 From: Onder Kalaci Date: Fri, 2 Dec 2022 13:15:40 +0100 Subject: [PATCH] DROP TABLE becomes idempotent for metadata sync - t2 --- .../distributed/metadata/node_metadata.c | 32 +++++++++---------- 1 file changed, 16 insertions(+), 16 deletions(-) diff --git a/src/backend/distributed/metadata/node_metadata.c b/src/backend/distributed/metadata/node_metadata.c index b1fbc2599..6d7f5f32c 100644 --- a/src/backend/distributed/metadata/node_metadata.c +++ b/src/backend/distributed/metadata/node_metadata.c @@ -101,7 +101,7 @@ static void InsertNodeRow(int nodeid, char *nodename, int32 nodeport, NodeMetada *nodeMetadata); static void DeleteNodeRow(char *nodename, int32 nodeport); static void SyncDistributedObjectsToNodeList(List *workerNodeList); -static void UpdateLocalGroupIdOnNode(WorkerNode *workerNode); +//static void UpdateLocalGroupIdOnNode(WorkerNode *workerNode); static void SyncPgDistTableMetadataToNodeList(List *nodeList); static List * InterTableRelationshipCommandList(); static void BlockDistributedQueriesOnMetadataNodes(void); @@ -875,21 +875,21 @@ SyncDistributedObjectsToNodeList(List *workerNodeList) /* * UpdateLocalGroupIdOnNode updates local group id on node. */ -static void -UpdateLocalGroupIdOnNode(WorkerNode *workerNode) -{ - if (NodeIsPrimary(workerNode) && !NodeIsCoordinator(workerNode)) - { - List *commandList = list_make1(LocalGroupIdUpdateCommand(workerNode->groupId)); - - /* send commands to new workers, the current user should be a superuser */ - Assert(superuser()); - SendMetadataCommandListToWorkerListInCoordinatedTransaction( - list_make1(workerNode), - CurrentUserName(), - commandList); - } -} +//static void +//UpdateLocalGroupIdOnNode(WorkerNode *workerNode) +//{ +// if (NodeIsPrimary(workerNode) && !NodeIsCoordinator(workerNode)) +// { +// List *commandList = list_make1(LocalGroupIdUpdateCommand(workerNode->groupId)); +// +// /* send commands to new workers, the current user should be a superuser */ +// Assert(superuser()); +// SendMetadataCommandListToWorkerListInCoordinatedTransaction( +// list_make1(workerNode), +// CurrentUserName(), +// commandList); +// } +//} /*