diff --git a/src/backend/distributed/planner/distributed_planner.c b/src/backend/distributed/planner/distributed_planner.c index 9d45d2008..b74117278 100644 --- a/src/backend/distributed/planner/distributed_planner.c +++ b/src/backend/distributed/planner/distributed_planner.c @@ -268,6 +268,13 @@ distributed_planner(Query *parse, int cursorOptions, ParamListInfo boundParams) * restriction information per table and parse tree transformations made by * postgres' planner. */ + + RangeTblEntry *subqueryRte = ExtractSelectRangeTableEntry(planContext.originalQuery); + subqueryRte = linitial(subqueryRte->subquery->rtable); + RangeTblEntry *valuesRte = linitial(subqueryRte->subquery->rtable); + elog(INFO, "valuesRte: %d len: %d",valuesRte->rtekind, list_length(valuesRte->values_lists)); + + planContext.plan = standard_planner(planContext.query, planContext.cursorOptions, planContext.boundParams); diff --git a/src/backend/distributed/planner/insert_select_planner.c b/src/backend/distributed/planner/insert_select_planner.c index 153e0cba3..19310ec77 100644 --- a/src/backend/distributed/planner/insert_select_planner.c +++ b/src/backend/distributed/planner/insert_select_planner.c @@ -322,6 +322,8 @@ DistributedInsertSelectSupported(Query *queryTree, RangeTblEntry *insertRte, char targetPartitionMethod = PartitionMethod(targetRelationId); ListCell *rangeTableCell = NULL; + return false; + /* we only do this check for INSERT ... SELECT queries */ AssertArg(InsertSelectIntoCitusTable(queryTree));