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

Fail task in real-time executor if no placements found. (#2133)

pull/2052/head
Hadi Moshayedi 2018-04-26 12:05:24 -04:00 committed by GitHub
parent 9610fe70f8
commit 24659a97dc
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 14 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
src/backend/distributed/executor/multi_real_time_executor.c
View File

@ -311,8 +311,20 @@ ManageTaskExecution(Task *task, TaskExecution *taskExecution,
placementAccessList = BuildPlacementSelectList(taskPlacement->groupId,
relationShardList);
/* should at least have an entry for the anchor shard */
Assert(list_length(placementAccessList) > 0);
/*
* Should at least have an entry for the anchor shard. If this is not the
* case, we should have errored out in the physical planner. We are
* rechecking here until we find the root cause of
* https://github.com/citusdata/citus/issues/2092.
*/
if (placementAccessList == NIL)
{
ereport(WARNING, (errmsg("could not find any placements for task %d",
task->taskId)));
taskStatusArray[currentIndex] = EXEC_TASK_FAILED;
break;
}
connectionId = MultiClientPlacementConnectStart(placementAccessList,
NULL);