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

pg14_support_3
Halil Ozan Akgul 2021-08-17 13:18:46 +03:00
parent abe85798a8
commit 95674ad4e3
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 *greaterThanExpr = (Expr *) lsecond(andExpr->args);
RestrictInfo *lessThanRestrictInfo = make_simple_restrictinfo(lessThanExpr);
RestrictInfo *greaterThanRestrictInfo = make_simple_restrictinfo(
RestrictInfo *lessThanRestrictInfo = make_simple_restrictinfo(NULL, lessThanExpr);
RestrictInfo *greaterThanRestrictInfo = make_simple_restrictinfo(NULL,
greaterThanExpr);
restrictInfoList = lappend(restrictInfoList, lessThanRestrictInfo);

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

@ -747,7 +747,7 @@ RouterModifyTaskForShardInterval(Query *originalQuery,
continue;
}
shardRestrictionList = make_simple_restrictinfo((Expr *) shardOpExpressions);
shardRestrictionList = make_simple_restrictinfo(NULL, (Expr *) shardOpExpressions);
extendedBaseRestrictInfo = lappend(extendedBaseRestrictInfo,
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
* input relation's expression list.
*/
Relids varnos = pull_varnos((Node *) restrictionClause);
Relids varnos = pull_varnos(NULL, (Node *) restrictionClause);
if (bms_num_members(varnos) != 1)
{
continue;