diff --git a/src/backend/distributed/planner/multi_physical_planner.c b/src/backend/distributed/planner/multi_physical_planner.c index a12572ad5..db37985dc 100644 --- a/src/backend/distributed/planner/multi_physical_planner.c +++ b/src/backend/distributed/planner/multi_physical_planner.c @@ -5271,7 +5271,7 @@ ActivePlacementList(List *placementList) /* check if the worker node for this shard placement is active */ workerNode = FindWorkerNode(placement->nodeName, placement->nodePort); - if (workerNode != NULL) + if (workerNode != NULL && workerNode->isActive) { activePlacementList = lappend(activePlacementList, placement); }