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

!!!!! DO NOT MERGE THIS COMMIT

talha_pg14_support
Halil Ozan Akgul 2021-08-17 13:18:46 +03:00 committed by Sait Talha Nisanci
parent d3e084c9de
commit 5d16914a1b
3 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/backend/distributed/operations/delete_protocol.c
View File

@ -672,8 +672,8 @@ ShardsMatchingDeleteCriteria(Oid relationId, List *shardIntervalList,
Expr *lessThanExpr = (Expr *) linitial(andExpr->args); Expr *lessThanExpr = (Expr *) linitial(andExpr->args);
Expr *greaterThanExpr = (Expr *) lsecond(andExpr->args); Expr *greaterThanExpr = (Expr *) lsecond(andExpr->args);
RestrictInfo *lessThanRestrictInfo = make_simple_restrictinfo(lessThanExpr); RestrictInfo *lessThanRestrictInfo = make_simple_restrictinfo(NULL, lessThanExpr);
RestrictInfo *greaterThanRestrictInfo = make_simple_restrictinfo( RestrictInfo *greaterThanRestrictInfo = make_simple_restrictinfo(NULL,
greaterThanExpr); greaterThanExpr);
restrictInfoList = lappend(restrictInfoList, lessThanRestrictInfo); restrictInfoList = lappend(restrictInfoList, lessThanRestrictInfo);

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

@ -747,7 +747,7 @@ RouterModifyTaskForShardInterval(Query *originalQuery,
continue; continue;
} }
shardRestrictionList = make_simple_restrictinfo((Expr *) shardOpExpressions); shardRestrictionList = make_simple_restrictinfo(NULL, (Expr *) shardOpExpressions);
extendedBaseRestrictInfo = lappend(extendedBaseRestrictInfo, extendedBaseRestrictInfo = lappend(extendedBaseRestrictInfo,
shardRestrictionList); shardRestrictionList);

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

@ -2054,7 +2054,7 @@ GetRestrictInfoListForRelation(RangeTblEntry *rangeTblEntry,
* If the restriction involves multiple tables, we cannot add it to * If the restriction involves multiple tables, we cannot add it to
* input relation's expression list. * input relation's expression list.
*/ */
Relids varnos = pull_varnos((Node *) restrictionClause); Relids varnos = pull_varnos(NULL, (Node *) restrictionClause);
if (bms_num_members(varnos) != 1) if (bms_num_members(varnos) != 1)
{ {
continue; continue;