Github user vrozov commented on a diff in the pull request:
https://github.com/apache/drill/pull/1105#discussion_r173224242
--- 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;
+ private List<FragmentHandle> finishedHandles = Lists.newArrayList();
--- End diff --
Consider using Queue and possibly concurrent Queue and moving
`finishedHandles` to FragmentExecutor.
---
