external
/
citus
mirror of https://github.com/citusdata/citus.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

some more

pull/7643/head
paragjain 2024-07-16 03:34:18 +00:00
parent d29e3ccbc5
commit 06bc0b47db
2 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/backend/distributed/planner/merge_planner.c
View File

@ -857,8 +857,8 @@ ConvertRelationRTEIntoSubquery(Query *mergeQuery, RangeTblEntry *sourceRte,
/* set the FROM expression to the subquery */ /* set the FROM expression to the subquery */
newRangeTableRef->rtindex = SINGLE_RTE_INDEX; newRangeTableRef->rtindex = SINGLE_RTE_INDEX;
sourceResultsQuery->jointree = makeFromExpr(list_make1(newRangeTableRef), NULL); sourceResultsQuery->jointree = makeFromExpr(list_make1(newRangeTableRef), NULL);
sourceResultsQuery->targetList = CreateAllTargetListForRelation(sourceRte->relid, sourceResultsQuery->targetList =
requiredAttributes); CreateAllTargetListForRelation(sourceRte->relid, requiredAttributes);
List *restrictionList = List *restrictionList =
GetRestrictInfoListForRelation(sourceRte, plannerRestrictionContext); GetRestrictInfoListForRelation(sourceRte, plannerRestrictionContext);
List *copyRestrictionList = copyObject(restrictionList); List *copyRestrictionList = copyObject(restrictionList);

2
src/backend/distributed/planner/query_colocation_checker.c
View File

@ -362,7 +362,7 @@ CreateAllTargetListForRelation(Oid relationId, List *requiredAttributes)
else else
{ {
TargetEntry *targetEntry = TargetEntry *targetEntry =
CreateTargetEntryForColumn(attributeTuple, SINGLE_RTE_INDEX, varAttrNo, CreateTargetEntryForColumn(attributeTuple, SINGLE_RTE_INDEX, varAttrNo++,
resNo); resNo);
targetList = lappend(targetList, targetEntry); targetList = lappend(targetList, targetEntry);
} }