Check all placements aren't inactive

2019-04-17 16:57:33 -07:00 · 2019-04-17 16:57:33 -07:00 · c9b1d9c2d1
parent 7b1d03772d
commit c9b1d9c2d1
1 changed files with 6 additions and 0 deletions
--- a/src/backend/distributed/planner/multi_physical_planner.c
+++ b/src/backend/distributed/planner/multi_physical_planner.c
@ -5213,6 +5213,12 @@ ActiveShardPlacementLists(List *taskList)

 		/* filter out shard placements that reside in inactive nodes */
 		List *activeShardPlacementList = ActivePlacementList(shardPlacementList);
+		if (activeShardPlacementList == NIL)
+		{
+			ereport(ERROR,
+					(errmsg("no active placements were found for shard " UINT64_FORMAT,
+							anchorShardId)));
+		}

 		/* sort shard placements by their creation time */
 		activeShardPlacementList = SortList(activeShardPlacementList,