[TAJO-2083] Window aggregation query on union throws NPE

• Type: Bug
• Status: Open
• Priority: Major
• Resolution: Unresolved
• Fix Version/s: 0.13.0
• Component/s: distributed query plan
• Assignee: Unassigned
• Reporter: Jihoon Son
• Created: 29/Feb/16 07:42
• Updated: 02/Dec/17 17:33

Description

You can reproduce using the below query.

tpch> SELECT l_linenumber, sum(l_quantity) OVER (PARTITION BY l_partkey ORDER BY l_linenumber DESC) , rank() OVER (PARTITION BY l_partkey ORDER BY l_linenumber DESC) FROM (select l_linenumber, l_partkey, l_quantity from lineitem union all select o_orderkey, o_custkey, o_totalprice from orders) a;
[                                          ] 0%  0.842 sec
ERROR: internal error: %s

Here is the stack trace.

2016-02-29 16:40:20,273 ERROR org.apache.tajo.querymaster.QueryMasterTask:
java.lang.NullPointerException
        at org.apache.tajo.engine.planner.global.DataChannel.<init>(DataChannel.java:57)
        at org.apache.tajo.engine.planner.global.GlobalPlanner$DistributedPlannerVisitor.buildWindowAgg(GlobalPlanner.java:1094)
        at org.apache.tajo.engine.planner.global.GlobalPlanner$DistributedPlannerVisitor.visitWindowAgg(GlobalPlanner.java:1080)
        at org.apache.tajo.engine.planner.global.GlobalPlanner$DistributedPlannerVisitor.visitWindowAgg(GlobalPlanner.java:968)
        at org.apache.tajo.plan.visitor.BasicLogicalPlanVisitor.visit(BasicLogicalPlanVisitor.java:86)
        at org.apache.tajo.plan.visitor.BasicLogicalPlanVisitor.visitRoot(BasicLogicalPlanVisitor.java:163)
        at org.apache.tajo.engine.planner.global.GlobalPlanner$DistributedPlannerVisitor.visitRoot(GlobalPlanner.java:973)
        at org.apache.tajo.engine.planner.global.GlobalPlanner$DistributedPlannerVisitor.visitRoot(GlobalPlanner.java:968)
        at org.apache.tajo.plan.visitor.BasicLogicalPlanVisitor.visit(BasicLogicalPlanVisitor.java:62)
        at org.apache.tajo.engine.planner.global.GlobalPlanner.build(GlobalPlanner.java:138)
        at org.apache.tajo.querymaster.QueryMasterTask.startQuery(QueryMasterTask.java:361)
        at org.apache.tajo.querymaster.QueryMasterTask.serviceStart(QueryMasterTask.java:161)
        at org.apache.hadoop.service.AbstractService.start(AbstractService.java:193)
        at org.apache.tajo.querymaster.QueryMaster$QueryStartEventHandler.handle(QueryMaster.java:378)
        at org.apache.tajo.querymaster.QueryMaster$QueryStartEventHandler.handle(QueryMaster.java:365)
        at org.apache.hadoop.yarn.event.AsyncDispatcher.dispatch(AsyncDispatcher.java:175)
        at org.apache.hadoop.yarn.event.AsyncDispatcher$1.run(AsyncDispatcher.java:108)
        at java.lang.Thread.run(Thread.java:745)