mirror of https://github.com/citusdata/citus.git
onder_tmo
parent
577d651778
commit
8bd4b11b2b
|
@ -863,6 +863,7 @@ RecursivelyPlanDistributedJoinNode(Node *distributedNode, Query *query,
|
||||||
Node *larg = ((JoinExpr *) distributedNode)->larg;
|
Node *larg = ((JoinExpr *) distributedNode)->larg;
|
||||||
if (!IsJoinNodeRecurring(larg, query))
|
if (!IsJoinNodeRecurring(larg, query))
|
||||||
{
|
{
|
||||||
|
elog(WARNING, "larg");
|
||||||
RecursivelyPlanDistributedJoinNode(larg, query,
|
RecursivelyPlanDistributedJoinNode(larg, query,
|
||||||
recursivePlanningContext);
|
recursivePlanningContext);
|
||||||
}
|
}
|
||||||
|
@ -870,6 +871,8 @@ RecursivelyPlanDistributedJoinNode(Node *distributedNode, Query *query,
|
||||||
Node *rarg = ((JoinExpr *) distributedNode)->rarg;
|
Node *rarg = ((JoinExpr *) distributedNode)->rarg;
|
||||||
if (!IsJoinNodeRecurring(rarg, query))
|
if (!IsJoinNodeRecurring(rarg, query))
|
||||||
{
|
{
|
||||||
|
elog(WARNING, "rarg");
|
||||||
|
|
||||||
RecursivelyPlanDistributedJoinNode(rarg, query,
|
RecursivelyPlanDistributedJoinNode(rarg, query,
|
||||||
recursivePlanningContext);
|
recursivePlanningContext);
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue