[jira] [Created] (TAJO-1794) row_number() function does not work with UNION ALL inline view

["Youngkyong Ko (JIRA)" <ji...@apache.org>]

Youngkyong Ko created TAJO-1794:
-----------------------------------

             Summary: row_number() function does not work with UNION ALL inline view
                 Key: TAJO-1794
                 URL: https://issues.apache.org/jira/browse/TAJO-1794
             Project: Tajo
          Issue Type: Bug
    Affects Versions: 0.11.0
         Environment: single node Tajo on Macbook
            Reporter: Youngkyong Ko


Q1 works. Q2 meet "No error message". 
When I changed "UNION ALL" to "UNION" in Q2, it works. 
Therefore I suspect it's related to UNION ALL. 

Q1. 
SELECT i1, rownum, i2, support, confidence, lift  FROM (
  SELECT row_number() over ( partition by i1 order by lift desc ) as rownum, r.*
  FROM (
    SELECT item1 as i1, item2 as i2, support, confidence1 as confidence, lift
    FROM rules
    WHERE support > 0.005
    ORDER BY i1, lift desc
  ) r 
)x
WHERE  rownum <= 5;

Q2. Same as Q1 except UNION ALL in inline view : NullPointerException 

SELECT i1, rownum, i2, support, confidence, lift  FROM (
  SELECT row_number() over ( partition by i1 order by lift desc ) as rownum, r.*
  FROM (
    SELECT item1 as i1, item2 as i2, support, confidence1 as confidence, lift
    FROM rules
    WHERE support > 0.005
    ORDER BY i1, lift desc
    UNION 
    SELECT item2 as i1, item1 as i2, support, confidence2 as confidence, lift
    FROM rules
    WHERE support > 0.005
    ORDER BY i1, lift desc
  ) r 
)x
WHERE  rownum <= 5;

2015-08-21 16:33:22,129 ERROR org.apache.tajo.querymaster.QueryMasterTask:
java.lang.NullPointerException
        at org.apache.tajo.engine.planner.global.DataChannel.<init>(DataChannel.java:56)
        at org.apache.tajo.engine.planner.global.GlobalPlanner$DistributedPlannerVisitor.buildWindowAgg(GlobalPlanner.java:1100)
        at org.apache.tajo.engine.planner.global.GlobalPlanner$DistributedPlannerVisitor.visitWindowAgg(GlobalPlanner.java:1086)
        at org.apache.tajo.engine.planner.global.GlobalPlanner$DistributedPlannerVisitor.visitWindowAgg(GlobalPlanner.java:973)
        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:984)
        at org.apache.tajo.engine.planner.global.GlobalPlanner$DistributedPlannerVisitor.visitProjection(GlobalPlanner.java:973)
        at org.apache.tajo.plan.visitor.BasicLogicalPlanVisitor.visit(BasicLogicalPlanVisitor.java:71)
        at org.apache.tajo.plan.visitor.BasicLogicalPlanVisitor.visitTableSubQuery(BasicLogicalPlanVisitor.java:308)
        at org.apache.tajo.engine.planner.global.GlobalPlanner$DistributedPlannerVisitor.visitTableSubQuery(GlobalPlanner.java:1275)
        at org.apache.tajo.engine.planner.global.GlobalPlanner$DistributedPlannerVisitor.visitTableSubQuery(GlobalPlanner.java:973)
        at org.apache.tajo.plan.visitor.BasicLogicalPlanVisitor.visit(BasicLogicalPlanVisitor.java:107)
        at org.apache.tajo.plan.visitor.BasicLogicalPlanVisitor.visitRoot(BasicLogicalPlanVisitor.java:163)
        at org.apache.tajo.engine.planner.global.GlobalPlanner$DistributedPlannerVisitor.visitRoot(GlobalPlanner.java:978)
        at org.apache.tajo.engine.planner.global.GlobalPlanner$DistributedPlannerVisitor.visitRoot(GlobalPlanner.java:973)
        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:358)
        at org.apache.tajo.querymaster.QueryMasterTask.serviceStart(QueryMasterTask.java:159)
        at org.apache.hadoop.service.AbstractService.start(AbstractService.java:193)
        at org.apache.tajo.querymaster.QueryMaster$QueryStartEventHandler.handle(QueryMaster.java:363)
        at org.apache.tajo.querymaster.QueryMaster$QueryStartEventHandler.handle(QueryMaster.java:350)
        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)




--
This message was sent by Atlassian JIRA
(v6.3.4#6332)