mirror of https://github.com/citusdata/citus.git
Fix rebase conflicts
parent
0c57ea7587
commit
4c22ed9ec2
|
@ -389,9 +389,9 @@ RouterModifyTaskForShardInterval(Query *originalQuery, ShardInterval *shardInter
|
||||||
{
|
{
|
||||||
RelationRestriction *restriction = lfirst(restrictionCell);
|
RelationRestriction *restriction = lfirst(restrictionCell);
|
||||||
List *originalBaserestrictInfo = restriction->relOptInfo->baserestrictinfo;
|
List *originalBaserestrictInfo = restriction->relOptInfo->baserestrictinfo;
|
||||||
|
List *originalJoinInfo = restriction->relOptInfo->joininfo;
|
||||||
InstantiateQualContext instantiateQualWalker;
|
InstantiateQualContext instantiateQualWalker;
|
||||||
Var *relationPartitionKey = PartitionKey(restriction->relationId);
|
Var *relationPartitionKey = PartitionKey(restriction->relationId);
|
||||||
Var *relationPartitionKey = PartitionKey(restriction->relationId);
|
|
||||||
|
|
||||||
/*
|
/*
|
||||||
* We haven't added the quals if all participating tables are reference
|
* 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,
|
(List *) InstantiatePartitionQualWalker((Node *) originalBaserestrictInfo,
|
||||||
&instantiateQualWalker);
|
&instantiateQualWalker);
|
||||||
originalJoinInfo =
|
originalJoinInfo =
|
||||||
(List *) InstantiatePartitionQual((Node *) originalJoinInfo,
|
(List *) InstantiatePartitionQualWalker((Node *) originalJoinInfo,
|
||||||
instantiateQualWalker);
|
&instantiateQualWalker);
|
||||||
}
|
}
|
||||||
|
|
||||||
/*
|
/*
|
||||||
|
|
Loading…
Reference in New Issue