From 11d5d21fd88c3ab7d056a154f14e766929793bd3 Mon Sep 17 00:00:00 2001 From: Sait Talha Nisanci Date: Mon, 12 Jul 2021 13:28:36 +0300 Subject: [PATCH] Call LockPlacementCleanup in RemoveOldShardPlacementForNodeGroup --- src/backend/distributed/metadata/node_metadata.c | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/src/backend/distributed/metadata/node_metadata.c b/src/backend/distributed/metadata/node_metadata.c index 3ca27426d..0b4f03f93 100644 --- a/src/backend/distributed/metadata/node_metadata.c +++ b/src/backend/distributed/metadata/node_metadata.c @@ -1336,6 +1336,10 @@ RemoveNodeFromCluster(char *nodeName, int32 nodePort) static void RemoveOldShardPlacementForNodeGroup(int groupId) { + /* + * Prevent concurrent deferred drop + */ + LockPlacementCleanup(); List *shardPlacementsOnNode = AllShardPlacementsOnNodeGroup(groupId); GroupShardPlacement *placement = NULL; foreach_ptr(placement, shardPlacementsOnNode)