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

Call LockPlacementCleanup in RemoveOldShardPlacementForNodeGroup

pull/5110/head
Sait Talha Nisanci 2021-07-12 13:28:36 +03:00 committed by Hanefi Onaldi
parent 4fbed90505
commit 11d5d21fd8
No known key found for this signature in database
GPG Key ID: F18CDB10BA0DFDC7
1 changed files with 4 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -1336,6 +1336,10 @@ RemoveNodeFromCluster(char *nodeName, int32 nodePort)
static void static void
RemoveOldShardPlacementForNodeGroup(int groupId) RemoveOldShardPlacementForNodeGroup(int groupId)
{ {
/*
* Prevent concurrent deferred drop
*/
LockPlacementCleanup();
List *shardPlacementsOnNode = AllShardPlacementsOnNodeGroup(groupId); List *shardPlacementsOnNode = AllShardPlacementsOnNodeGroup(groupId);
GroupShardPlacement *placement = NULL; GroupShardPlacement *placement = NULL;
foreach_ptr(placement, shardPlacementsOnNode) foreach_ptr(placement, shardPlacementsOnNode)