diff --git a/src/backend/distributed/planner/multi_physical_planner.c b/src/backend/distributed/planner/multi_physical_planner.c index 7fdbfa829..a2590d48d 100644 --- a/src/backend/distributed/planner/multi_physical_planner.c +++ b/src/backend/distributed/planner/multi_physical_planner.c @@ -1654,8 +1654,8 @@ UpdateAllColumnAttributes(Node *columnContainer, List *rangeTableList, static void UpdateColumnAttributes(Var *column, List *rangeTableList, List *dependentJobList) { - Index originalTableId = column->varno; - AttrNumber originalColumnId = column->varattno; + Index originalTableId = column->varnosyn; + AttrNumber originalColumnId = column->varattnosyn; /* find the new table identifier */ Index newTableId = NewTableId(originalTableId, rangeTableList);