mirror of https://github.com/citusdata/citus.git
Merge pull request #3666 from citusdata/size-functions-without-locks
Remove metadata locks from size functionspull/3719/head
commit
e31dcff178
|
@ -301,18 +301,6 @@ ShardIntervalsOnWorkerGroup(WorkerNode *workerNode, Oid relationId)
|
||||||
placementIndex++)
|
placementIndex++)
|
||||||
{
|
{
|
||||||
GroupShardPlacement *placement = &placementArray[placementIndex];
|
GroupShardPlacement *placement = &placementArray[placementIndex];
|
||||||
uint64 shardId = placement->shardId;
|
|
||||||
|
|
||||||
bool metadataLock = TryLockShardDistributionMetadata(shardId, ShareLock);
|
|
||||||
|
|
||||||
/* if the lock is not acquired warn the user */
|
|
||||||
if (metadataLock == false)
|
|
||||||
{
|
|
||||||
ereport(WARNING, (errcode(ERRCODE_LOCK_NOT_AVAILABLE),
|
|
||||||
errmsg("lock is not acquired, size of shard "
|
|
||||||
UINT64_FORMAT " will be ignored", shardId)));
|
|
||||||
continue;
|
|
||||||
}
|
|
||||||
|
|
||||||
if (placement->groupId == workerNode->groupId)
|
if (placement->groupId == workerNode->groupId)
|
||||||
{
|
{
|
||||||
|
|
Loading…
Reference in New Issue