diff --git a/src/backend/distributed/planner/multi_router_planner.c b/src/backend/distributed/planner/multi_router_planner.c index a8a269e86..c38c00adf 100644 --- a/src/backend/distributed/planner/multi_router_planner.c +++ b/src/backend/distributed/planner/multi_router_planner.c @@ -389,9 +389,9 @@ RouterModifyTaskForShardInterval(Query *originalQuery, ShardInterval *shardInter { RelationRestriction *restriction = lfirst(restrictionCell); List *originalBaserestrictInfo = restriction->relOptInfo->baserestrictinfo; + List *originalJoinInfo = restriction->relOptInfo->joininfo; InstantiateQualContext instantiateQualWalker; Var *relationPartitionKey = PartitionKey(restriction->relationId); - Var *relationPartitionKey = PartitionKey(restriction->relationId); /* * We haven't added the quals if all participating tables are reference @@ -409,8 +409,8 @@ RouterModifyTaskForShardInterval(Query *originalQuery, ShardInterval *shardInter (List *) InstantiatePartitionQualWalker((Node *) originalBaserestrictInfo, &instantiateQualWalker); originalJoinInfo = - (List *) InstantiatePartitionQual((Node *) originalJoinInfo, - instantiateQualWalker); + (List *) InstantiatePartitionQualWalker((Node *) originalJoinInfo, + &instantiateQualWalker); } /*