From b5f39898a0bc4b1ff7dd490ff02ccca92b9fc1de Mon Sep 17 00:00:00 2001 From: Onder Kalaci Date: Fri, 2 Dec 2022 08:35:15 +0100 Subject: [PATCH] sync objects without coordinated tx --- src/backend/distributed/metadata/node_metadata.c | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/src/backend/distributed/metadata/node_metadata.c b/src/backend/distributed/metadata/node_metadata.c index 57ba208a2..4b8179d4a 100644 --- a/src/backend/distributed/metadata/node_metadata.c +++ b/src/backend/distributed/metadata/node_metadata.c @@ -1221,6 +1221,7 @@ ActivateNodeList(List *nodeList) List *existingMetadataNodeList = TargetWorkerSetNodeList(NON_COORDINATOR_METADATA_NODES, RowShareLock); + /*ErrorIfAnyMetadataNodeOutOfSync(existingMetadataNodeList); */ node = NULL; @@ -2274,7 +2275,7 @@ AddNodeMetadata(char *nodeName, int32 nodePort, { /* send the delete command to all primary nodes with metadata */ char *nodeDeleteCommand = NodeDeleteCommand(workerNode->nodeId); - SendCommandToWorkersWithMetadata(nodeDeleteCommand); + SendBareCommandListToMetadataWorkers(list_make1(nodeDeleteCommand)); /* finally prepare the insert command and send it to all primary nodes */ uint32 primariesWithMetadata = CountPrimariesWithMetadata(); @@ -2283,7 +2284,7 @@ AddNodeMetadata(char *nodeName, int32 nodePort, List *workerNodeList = list_make1(workerNode); char *nodeInsertCommand = NodeListInsertCommand(workerNodeList); - SendCommandToWorkersWithMetadata(nodeInsertCommand); + SendBareCommandListToMetadataWorkers(list_make1(nodeInsertCommand)); } }