Github user ilooner commented on a diff in the pull request: https://github.com/apache/drill/pull/1105#discussion_r173367313 --- Diff: exec/java-exec/src/main/java/org/apache/drill/exec/work/fragment/FragmentExecutor.java --- @@ -475,6 +483,8 @@ public void drillbitUnregistered(final Set<CoordinationProtos.DrillbitEndpoint> * This is especially important as fragments can take longer to start */ private class FragmentEventProcessor extends EventProcessor<FragmentEvent> { + private boolean terminate = false; --- End diff -- Done
---