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

Move sync node metadata to above

velioglu/wo_seq_test_1
Burak Velioglu 2022-01-20 14:30:28 +03:00
parent 0932ea9a46
commit 632d7b8038
No known key found for this signature in database
GPG Key ID: F6827E620F6549C6
1 changed files with 10 additions and 20 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -1124,32 +1124,22 @@ ActivateNode(char *nodeName, int nodePort)
if (syncMetadata)
{
/*
* We are going to sync the metadata anyway in this transaction, so do
* not fail just because the current metadata is not synced.
*/
SetWorkerColumn(workerNode, Anum_pg_dist_node_metadatasynced,
BoolGetDatum(true));
SyncNodeMetadataToNode(nodeName, nodePort);
}
SetUpDistributedTableWithDependencies(workerNode);
if (syncMetadata)
if (syncMetadata && !NodeIsCoordinator(workerNode))
{
SyncNodeMetadataToNode(nodeName, nodePort);
List *metadataUpdateCommandList = ResyncMetadataCommandList();
if (!NodeIsCoordinator(workerNode))
{
List *metadataUpdateCommandList = ResyncMetadataCommandList();
/* send commands to the new worker, the current user should be a superuser */
Assert(superuser());
SendMetadataCommandListToWorkerInCoordinatedTransaction(
workerNode->workerName,
workerNode->workerPort,
CurrentUserName(),
metadataUpdateCommandList);
}
/* send commands to the new worker, the current user should be a superuser */
Assert(superuser());
SendMetadataCommandListToWorkerInCoordinatedTransaction(
workerNode->workerName,
workerNode->workerPort,
CurrentUserName(),
metadataUpdateCommandList);
}
/* finally, let all other active metadata nodes to learn about this change */