Github user ilooner commented on a diff in the pull request: https://github.com/apache/drill/pull/1045#discussion_r162513475 --- Diff: exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/WriterRecordBatch.java --- @@ -118,7 +118,7 @@ public IterOutcome innerNext() { } catch(IOException ex) { logger.error("Failure during query", ex); kill(false); - context.fail(ex); + context.getExecutorState().fail(ex); --- End diff -- Sounds fun. Created https://issues.apache.org/jira/browse/DRILL-6098
---