Throw an error if placements cannot be found in router executor

pull/2157/head
Marco Slot 2018-05-06 17:36:40 +02:00 committed by Hadi Moshayedi
parent b4cfa2f283
commit 5f5f7b4fe0
1 changed files with 7 additions and 0 deletions

View File

@ -628,6 +628,13 @@ ExecuteSingleSelectTask(CitusScanState *scanState, Task *task)
placementAccessList = list_make1(placementAccess); placementAccessList = list_make1(placementAccess);
} }
if (placementAccessList == NIL)
{
ereport(ERROR, (errcode(ERRCODE_T_R_SERIALIZATION_FAILURE),
errmsg("a placement was moved after the SELECT was "
"planned")));
}
connection = GetPlacementListConnection(connectionFlags, placementAccessList, connection = GetPlacementListConnection(connectionFlags, placementAccessList,
NULL); NULL);