Github user vrozov commented on a diff in the pull request:
https://github.com/apache/drill/pull/1105#discussion_r173300352
--- Diff:
exec/java-exec/src/main/java/org/apache/drill/exec/work/fragment/FragmentExecutor.java
---
@@ -67,6 +88,11 @@
private volatile RootExec root;
private final AtomicReference<FragmentState> fragmentState = new
AtomicReference<>(FragmentState.AWAITING_ALLOCATION);
+ /**
+ * Holds all of the messages sent by downstream recievers that have
finished. The {@link FragmentExecutor#run()} thread reads from this queue and
passes the
+ * finished messages to the fragment's {@link RootExec} via the {@link
RootExec#receivingFragmentFinished(FragmentHandle)} method.
+ */
+ private final Queue<FragmentHandle> recieverFinishedQueue = new
ConcurrentLinkedQueue<>();
--- End diff --
please fix typo (receiver)
---
