external
/
citus
mirror of https://github.com/citusdata/citus.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

sync objects without coordinated tx

metadata_sync_final
Onder Kalaci 2022-12-02 08:35:15 +01:00
parent ccf955fb52
commit b5f39898a0
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
src/backend/distributed/metadata/node_metadata.c
View File

@ -1221,6 +1221,7 @@ ActivateNodeList(List *nodeList)
List *existingMetadataNodeList = List *existingMetadataNodeList =
TargetWorkerSetNodeList(NON_COORDINATOR_METADATA_NODES, TargetWorkerSetNodeList(NON_COORDINATOR_METADATA_NODES,
RowShareLock); RowShareLock);
/*ErrorIfAnyMetadataNodeOutOfSync(existingMetadataNodeList); */ /*ErrorIfAnyMetadataNodeOutOfSync(existingMetadataNodeList); */
node = NULL; node = NULL;
@ -2274,7 +2275,7 @@ AddNodeMetadata(char *nodeName, int32 nodePort,
{ {
/* send the delete command to all primary nodes with metadata */ /* send the delete command to all primary nodes with metadata */
char *nodeDeleteCommand = NodeDeleteCommand(workerNode->nodeId); char *nodeDeleteCommand = NodeDeleteCommand(workerNode->nodeId);
SendCommandToWorkersWithMetadata(nodeDeleteCommand); SendBareCommandListToMetadataWorkers(list_make1(nodeDeleteCommand));
/* finally prepare the insert command and send it to all primary nodes */ /* finally prepare the insert command and send it to all primary nodes */
uint32 primariesWithMetadata = CountPrimariesWithMetadata(); uint32 primariesWithMetadata = CountPrimariesWithMetadata();
@ -2283,7 +2284,7 @@ AddNodeMetadata(char *nodeName, int32 nodePort,
List *workerNodeList = list_make1(workerNode); List *workerNodeList = list_make1(workerNode);
char *nodeInsertCommand = NodeListInsertCommand(workerNodeList); char *nodeInsertCommand = NodeListInsertCommand(workerNodeList);
SendCommandToWorkersWithMetadata(nodeInsertCommand); SendBareCommandListToMetadataWorkers(list_make1(nodeInsertCommand));
} }
} }