[
https://issues.apache.org/jira/browse/DRILL-5854?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16197770#comment-16197770
]
ASF GitHub Bot commented on DRILL-5854:
---------------------------------------
GitHub user ppadma opened a pull request:
https://github.com/apache/drill/pull/981
DRILL-5854: IllegalStateException when empty batch with valid schema …
…is received
Problem is that merge receiver is reading from the wrong sender when first
batch is empty from one of the senders.
When first batch is empty, we are continuing without moving to the next
sender.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/ppadma/drill DRILL-5854
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/drill/pull/981.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #981
----
commit eb25c2f2ec879c369c7deb84a4273bec1fad42cc
Author: Padma Penumarthy <[email protected]>
Date: 2017-10-09T22:05:17Z
DRILL-5854: IllegalStateException when empty batch with valid schema is
received
----
> IllegalStateException when empty batch with valid schema is received.
> ---------------------------------------------------------------------
>
> Key: DRILL-5854
> URL: https://issues.apache.org/jira/browse/DRILL-5854
> Project: Apache Drill
> Issue Type: Bug
> Components: Execution - Flow
> Affects Versions: 1.11.0
> Reporter: Padma Penumarthy
> Assignee: Padma Penumarthy
> Fix For: 1.12.0
>
>
> When we get a batch with record count 0 and empty schema from one of the
> senders in the merge receiver,
> the following exception is thrown sometimes.
> Problem is that merge receiver is reading from the wrong sender when first
> batch is empty from one of the senders.
> When first batch is empty, we are continuing without moving to the next
> sender.
> Error: SYSTEM ERROR: IllegalStateException: Cleanup before finished. 0 out of
> 1 streams have finished
> Fragment 0:0
> [Error Id: 0dec4617-eb06-48fd-80c9-75e9c1e74ce2 on sidrill1:31010]
> (java.lang.IllegalStateException) Cleanup before finished. 0 out of 1
> streams have finished
> org.apache.drill.exec.work.batch.BaseRawBatchBuffer.close():107
> org.apache.drill.common.AutoCloseables.close():76
> org.apache.drill.common.AutoCloseables.close():64
> org.apache.drill.exec.work.batch.AbstractDataCollector.close():119
> org.apache.drill.common.AutoCloseables.close():76
> org.apache.drill.exec.work.batch.IncomingBuffers.close():140
> org.apache.drill.exec.ops.FragmentContext.suppressingClose():436
> org.apache.drill.exec.ops.FragmentContext.close():429
>
> org.apache.drill.exec.work.fragment.FragmentExecutor.closeOutResources():320
> org.apache.drill.exec.work.fragment.FragmentExecutor.cleanup():155
> org.apache.drill.exec.work.fragment.FragmentExecutor.run():264
> org.apache.drill.common.SelfCleaningRunnable.run():38
> java.util.concurrent.ThreadPoolExecutor.runWorker():1149
> java.util.concurrent.ThreadPoolExecutor$Worker.run():624
> java.lang.Thread.run():748 (state=,code=0)
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
