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

DROP TABLE becomes idempotent for metadata sync - t2

metadata_sync_partially_non_tx
Onder Kalaci 2022-12-02 13:15:40 +01:00
parent a41953d5bb
commit 5c0a647661
1 changed files with 16 additions and 16 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -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);
// }
//}
/*