diff --git a/src/backend/distributed/executor/multi_router_executor.c b/src/backend/distributed/executor/multi_router_executor.c index d82526f46..8038feb18 100644 --- a/src/backend/distributed/executor/multi_router_executor.c +++ b/src/backend/distributed/executor/multi_router_executor.c @@ -294,7 +294,10 @@ AcquireExecutorShardLock(Task *task, LOCKMODE lockMode) { int64 shardId = task->anchorShardId; - LockShardResource(shardId, lockMode); + if (shardId != INVALID_SHARD_ID) + { + LockShardResource(shardId, lockMode); + } }