mirror of https://github.com/citusdata/citus.git
wip
parent
aeb644be5a
commit
bf9b64fdc1
|
|
@ -1553,18 +1553,6 @@ RebalanceTableShards(RebalanceOptions *options, Oid shardReplicationModeOid)
|
||||||
return;
|
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);
|
List *placementUpdateList = GetRebalanceSteps(options);
|
||||||
|
|
||||||
if (list_length(placementUpdateList) == 0)
|
if (list_length(placementUpdateList) == 0)
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue