[
https://issues.apache.org/jira/browse/DRILL-6882?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aman Sinha updated DRILL-6882:
------------------------------
Labels: ready-to-commit (was: )
> Handle the cases where RowKeyJoin's left pipeline being called multiple times.
> ------------------------------------------------------------------------------
>
> Key: DRILL-6882
> URL: https://issues.apache.org/jira/browse/DRILL-6882
> Project: Apache Drill
> Issue Type: Bug
> Affects Versions: 1.15.0
> Reporter: Gautam Parai
> Assignee: Gautam Parai
> Priority: Blocker
> Labels: ready-to-commit
> Fix For: 1.15.0
>
>
> RowKeyJoin operator's leftStream pipeline uses IterOutcome.NONE state to
> repeat the pipeline multiple times. This should be avoided as
> IterOutcome.NONE will assertion checks in validator. We ran into this issue
> when trying to fix DRILL-6878.
> Sample unit test failure from DRILL-6878
> select t1.id.ssn as ssn from hbase.`index_test_primary` t1,
> hbase.`index_test_primary` t2 where t1._id = t2.rowid and
> cast(t2.activity.irs.firstlogin as timestamp) = to_timestamp('2013-02-04
> 22:34:38.0', 'YYYY-MM-dd HH:mm:ss.S')
> at
> org.apache.drill.test.DrillTestWrapper.compareMergedOnHeapVectors(DrillTestWrapper.java:630)
> ~[drill-java-exec-1.15.0-SNAPSHOT-tests.jar:1.15.0-SNAPSHOT]
> at
> org.apache.drill.test.DrillTestWrapper.compareOrderedResults(DrillTestWrapper.java:584)
> ~[drill-java-exec-1.15.0-SNAPSHOT-tests.jar:1.15.0-SNAPSHOT]
> at org.apache.drill.test.DrillTestWrapper.run(DrillTestWrapper.java:157)
> ~[drill-java-exec-1.15.0-SNAPSHOT-tests.jar:1.15.0-SNAPSHOT]
> at org.apache.drill.test.TestBuilder.go(TestBuilder.java:139)
> ~[drill-java-exec-1.15.0-SNAPSHOT-tests.jar:1.15.0-SNAPSHOT]
> at
> com.mapr.drill.maprdb.tests.index.IndexPlanTest.testRowkeyJoinPushdown_7(IndexPlanTest.java:1828)
> ~[test-classes/:na]
> at java.lang.Thread.run(Thread.java:748) ~[na:1.8.0_141]
> Caused by: org.apache.drill.exec.rpc.RpcException:
> org.apache.drill.common.exceptions.UserRemoteException: SYSTEM ERROR:
> IllegalStateException: next() [on #851, ScanBatch] called again after it
> returned NONE. Caller should not have called next() again.
>
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
