Skip to content

Commit e8a8d30

Browse files
marcoslotvelioglu
authored andcommitted
Throw an error if placements cannot be found in router executor
1 parent a5e9b29 commit e8a8d30

File tree

1 file changed

+7
-0
lines changed

1 file changed

+7
-0
lines changed

src/backend/distributed/executor/multi_router_executor.c

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -616,6 +616,13 @@ ExecuteSingleSelectTask(CitusScanState *scanState, Task *task)
616616
placementAccessList = list_make1(placementAccess);
617617
}
618618

619+
if (placementAccessList == NIL)
620+
{
621+
ereport(ERROR, (errcode(ERRCODE_T_R_SERIALIZATION_FAILURE),
622+
errmsg("a placement was moved after the SELECT was "
623+
"planned")));
624+
}
625+
619626
connection = GetPlacementListConnection(connectionFlags, placementAccessList,
620627
NULL);
621628

0 commit comments

Comments
 (0)