[
https://issues.apache.org/jira/browse/DRILL-6137?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16373982#comment-16373982
]
Pritesh Maker commented on DRILL-6137:
--------------------------------------
[~timothyfarkas] since this chance is included with DRILL-5993, should we close
this issue?
> Join Failure When Some Json File Partitions Empty
> -------------------------------------------------
>
> Key: DRILL-6137
> URL: https://issues.apache.org/jira/browse/DRILL-6137
> Project: Apache Drill
> Issue Type: Bug
> Affects Versions: 1.13.0
> Reporter: Timothy Farkas
> Assignee: Timothy Farkas
> Priority: Major
> Fix For: 1.13.0
>
>
> The following exception can occurr when the following query is executed:
> {code}
> select t.p_partkey, t1.ps_suppkey from dfs.`join/empty_part/part` as t RIGHT
> JOIN dfs.`join/empty_part/partsupp` as t1 ON t.p_partkey = t1.ps_partkey
> where t1.ps_partkey > 1
> {code}
> * part has one nonempty file 0_0_0.json
> * partsupp has one nonempty file 0_0_0.json and one empty file 0_0_1.json
> {code}
> (java.lang.IllegalStateException) next() [on #10, RemovingRecordBatch]
> called again after it returned NONE. Caller should not have called next()
> again.
>
> org.apache.drill.exec.physical.impl.validate.IteratorValidatorBatchIterator.next():220
> org.apache.drill.exec.record.AbstractRecordBatch.next():119
>
> org.apache.drill.exec.test.generated.HashJoinProbeGen2.executeProbePhase():119
>
> org.apache.drill.exec.test.generated.HashJoinProbeGen2.probeAndProject():227
> org.apache.drill.exec.physical.impl.join.HashJoinBatch.innerNext():222
> org.apache.drill.exec.record.AbstractRecordBatch.next():164
>
> org.apache.drill.exec.physical.impl.validate.IteratorValidatorBatchIterator.next():228
> org.apache.drill.exec.record.AbstractRecordBatch.next():119
> org.apache.drill.exec.record.AbstractRecordBatch.next():109
> org.apache.drill.exec.record.AbstractSingleRecordBatch.innerNext():51
>
> org.apache.drill.exec.physical.impl.project.ProjectRecordBatch.innerNext():134
> org.apache.drill.exec.record.AbstractRecordBatch.next():164
>
> org.apache.drill.exec.physical.impl.validate.IteratorValidatorBatchIterator.next():228
> org.apache.drill.exec.record.AbstractRecordBatch.next():119
> org.apache.drill.exec.record.AbstractRecordBatch.next():109
> org.apache.drill.exec.record.AbstractSingleRecordBatch.innerNext():51
>
> org.apache.drill.exec.physical.impl.project.ProjectRecordBatch.innerNext():134
> org.apache.drill.exec.record.AbstractRecordBatch.next():164
>
> org.apache.drill.exec.physical.impl.validate.IteratorValidatorBatchIterator.next():228
> org.apache.drill.exec.physical.impl.BaseRootExec.next():105
>
> org.apache.drill.exec.physical.impl.SingleSenderCreator$SingleSenderRootExec.innerNext():93
> org.apache.drill.exec.physical.impl.BaseRootExec.next():95
> org.apache.drill.exec.work.fragment.FragmentExecutor$1.run():233
> org.apache.drill.exec.work.fragment.FragmentExecutor$1.run():226
> java.security.AccessController.doPrivileged():-2
> javax.security.auth.Subject.doAs():415
> org.apache.hadoop.security.UserGroupInformation.doAs():1657
> org.apache.drill.exec.work.fragment.FragmentExecutor.run():226
> org.apache.drill.common.SelfCleaningRunnable.run():38
> java.util.concurrent.ThreadPoolExecutor.runWorker():1145
> java.util.concurrent.ThreadPoolExecutor$Worker.run():615
> java.lang.Thread.run():745
> {code}
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
