diff --git a/src/backend/distributed/transaction/worker_transaction.c b/src/backend/distributed/transaction/worker_transaction.c index 5812f79cd..8387f003d 100644 --- a/src/backend/distributed/transaction/worker_transaction.c +++ b/src/backend/distributed/transaction/worker_transaction.c @@ -97,7 +97,7 @@ TargetWorkerSetNodeList(TargetWorkerSet targetWorkerSet, LOCKMODE lockMode) { WorkerNode *workerNode = (WorkerNode *) lfirst(workerNodeCell); if (targetWorkerSet == WORKERS_WITH_METADATA && - !workerNode->hasMetadata) + (!workerNode->hasMetadata || !workerNode->metadataSynced)) { continue; }