diff --git a/src/backend/distributed/planner/insert_select_planner.c b/src/backend/distributed/planner/insert_select_planner.c index 2eecb6e9f..bfe6faa0e 100644 --- a/src/backend/distributed/planner/insert_select_planner.c +++ b/src/backend/distributed/planner/insert_select_planner.c @@ -423,7 +423,7 @@ CreateInsertSelectIntoLocalTablePlan(uint64 planId, Query *insertSelectQuery, * distributed select instead of returning it. */ selectRte->subquery = distPlan->combineQuery; - distPlan->combineQuery = insertSelectQuery; + distPlan->combineQuery = selectQuery; return distPlan; }