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

style

rebalance_move_notice
eaydingol 2024-03-10 06:53:26 +00:00
parent 5377aed757
commit 2ec570bb88
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
src/backend/distributed/utils/resource_lock.c
View File

@ -712,7 +712,8 @@ SerializeNonCommutativeWrites(List *shardIntervalList, LOCKMODE lockMode)
/* /*
* Acquire locks on the modified table. * Acquire locks on the modified table.
* If the table is replicated, the locks are first acquired on the first worker node then locally. * If the table is replicated, the locks are first acquired on the first worker node then locally.
* But if we're already on the first worker, acquiring on the first worker node and locally are the same operation. So we only acquire locally in that case. * But if we're already on the first worker, acquiring on the first worker node and locally are the same operation.
* So we only acquire locally in that case.
*/ */
if (anyTableReplicated && ClusterHasKnownMetadataWorkers() && !IsFirstWorkerNode()) if (anyTableReplicated && ClusterHasKnownMetadataWorkers() && !IsFirstWorkerNode())
{ {