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

Don't schedule tasks on inactive nodes.

pull/2664/head
Hadi Moshayedi 2019-04-11 17:14:05 -07:00
parent 116c255d3d
commit 7b1d03772d
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/backend/distributed/planner/multi_physical_planner.c
View File

@ -5271,7 +5271,7 @@ ActivePlacementList(List *placementList)
/* check if the worker node for this shard placement is active */ /* check if the worker node for this shard placement is active */
workerNode = FindWorkerNode(placement->nodeName, placement->nodePort); workerNode = FindWorkerNode(placement->nodeName, placement->nodePort);
if (workerNode != NULL) if (workerNode != NULL && workerNode->isActive)
{ {
activePlacementList = lappend(activePlacementList, placement); activePlacementList = lappend(activePlacementList, placement);
} }