From 06bc0b47db63be3aaa6443ebcbff22e87aeac04b Mon Sep 17 00:00:00 2001 From: paragjain Date: Tue, 16 Jul 2024 03:34:18 +0000 Subject: [PATCH] some more --- src/backend/distributed/planner/merge_planner.c | 4 ++-- src/backend/distributed/planner/query_colocation_checker.c | 2 +- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/src/backend/distributed/planner/merge_planner.c b/src/backend/distributed/planner/merge_planner.c index fc6e4fd06..1f9d17c43 100644 --- a/src/backend/distributed/planner/merge_planner.c +++ b/src/backend/distributed/planner/merge_planner.c @@ -857,8 +857,8 @@ ConvertRelationRTEIntoSubquery(Query *mergeQuery, RangeTblEntry *sourceRte, /* set the FROM expression to the subquery */ newRangeTableRef->rtindex = SINGLE_RTE_INDEX; sourceResultsQuery->jointree = makeFromExpr(list_make1(newRangeTableRef), NULL); - sourceResultsQuery->targetList = CreateAllTargetListForRelation(sourceRte->relid, - requiredAttributes); + sourceResultsQuery->targetList = + CreateAllTargetListForRelation(sourceRte->relid, requiredAttributes); List *restrictionList = GetRestrictInfoListForRelation(sourceRte, plannerRestrictionContext); List *copyRestrictionList = copyObject(restrictionList); diff --git a/src/backend/distributed/planner/query_colocation_checker.c b/src/backend/distributed/planner/query_colocation_checker.c index d7fb8e868..bef91618e 100644 --- a/src/backend/distributed/planner/query_colocation_checker.c +++ b/src/backend/distributed/planner/query_colocation_checker.c @@ -362,7 +362,7 @@ CreateAllTargetListForRelation(Oid relationId, List *requiredAttributes) else { TargetEntry *targetEntry = - CreateTargetEntryForColumn(attributeTuple, SINGLE_RTE_INDEX, varAttrNo, + CreateTargetEntryForColumn(attributeTuple, SINGLE_RTE_INDEX, varAttrNo++, resNo); targetList = lappend(targetList, targetEntry); }