From bf9b64fdc1c8b2a47570a2568c9977dc0e35c5e9 Mon Sep 17 00:00:00 2001 From: Onder Kalaci Date: Mon, 18 Jul 2022 10:07:35 +0200 Subject: [PATCH] wip --- .../distributed/operations/shard_rebalancer.c | 12 ------------ 1 file changed, 12 deletions(-) diff --git a/src/backend/distributed/operations/shard_rebalancer.c b/src/backend/distributed/operations/shard_rebalancer.c index 75d4cc6c9..cf91d7700 100644 --- a/src/backend/distributed/operations/shard_rebalancer.c +++ b/src/backend/distributed/operations/shard_rebalancer.c @@ -1553,18 +1553,6 @@ RebalanceTableShards(RebalanceOptions *options, Oid shardReplicationModeOid) return; } - Oid relationId = InvalidOid; - char *operationName = "rebalance"; - if (options->drainOnly) - { - operationName = "move"; - } - - foreach_oid(relationId, options->relationIdList) - { - AcquireColocationLock(relationId, ExclusiveLock, operationName); - } - List *placementUpdateList = GetRebalanceSteps(options); if (list_length(placementUpdateList) == 0)