Jaehwa Jung created TAJO-2121:
---------------------------------
Summary: Window function with UNION ALL throws InternalError
Key: TAJO-2121
URL: https://issues.apache.org/jira/browse/TAJO-2121
Project: Tajo
Issue Type: Bug
Components: distributed query plan
Affects Versions: 0.12.0, 0.11.2
Reporter: Jaehwa Jung
When using window function with {{UNION ALL}} clause Tajo throws InternalError
as following:
{code:xml}
default> SELECT
> lead(l_shipmode, 1) over (PARTITION BY L_ORDERKEY order by l_shipmode ) as
> shipmode_lead,
> l_orderkey
> FROM
> (
> SELECT
> l_orderkey,l_partkey,l_suppkey::INT8 as
> l_suppkey_t,l_linenumber,l_quantity,
> l_extendedprice,l_discount::FLOAT4 as
> l_discount_t,l_tax,l_returnflag,l_linestatus,
> l_shipdate::DATE as l_shipdate_t,l_commitdate::TIMESTAMP as
> l_commitdate_t,l_receiptdate,l_shipinstruct,l_shipmode,l_comment
> FROM
> LINEITEM
> where l_shipdate >= '1996-01-01'
> and l_shipdate <= '1996-01-31'
> union all
> SELECT
> l_orderkey,l_partkey,l_suppkey::INT8 as
> l_suppkey_t,l_linenumber,l_quantity,
> l_extendedprice,l_discount::FLOAT4 as
> l_discount_t,l_tax,l_returnflag,l_linestatus,
> l_shipdate::DATE as l_shipdate_t,l_commitdate::TIMESTAMP as
> l_commitdate_t,l_receiptdate,l_shipinstruct,l_shipmode,l_comment
> FROM
> LINEITEM
> where l_shipdate >= '1996-02-01'
> and l_shipdate <= '1996-02-28'
> ) xx;
[ ] 0% 1.014 sec
ERROR: internal error: NullPointerException:
{code}
Here is the log of TajoWorker as follows.
{code:xml}
2016-04-19 11:13:13,997 ERROR org.apache.tajo.querymaster.QueryMasterTask:
java.lang.NullPointerException
at
org.apache.tajo.engine.planner.global.DataChannel.<init>(DataChannel.java:58)
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.visitProjection(BasicLogicalPlanVisitor.java:185)
at
org.apache.tajo.engine.planner.global.GlobalPlanner$DistributedPlannerVisitor.visitProjection(GlobalPlanner.java:979)
at
org.apache.tajo.engine.planner.global.GlobalPlanner$DistributedPlannerVisitor.visitProjection(GlobalPlanner.java:968)
at
org.apache.tajo.plan.visitor.BasicLogicalPlanVisitor.visit(BasicLogicalPlanVisitor.java:71)
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:173)
at
org.apache.hadoop.yarn.event.AsyncDispatcher$1.run(AsyncDispatcher.java:106)
at java.lang.Thread.run(Thread.java:745)
{code}
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
