Github user vrozov commented on a diff in the pull request: https://github.com/apache/drill/pull/1110#discussion_r167954543 --- Diff: exec/java-exec/src/main/java/org/apache/drill/exec/physical/config/UnorderedMuxExchange.java --- @@ -37,14 +37,8 @@ public UnorderedMuxExchange(@JsonProperty("child") PhysicalOperator child) { } @Override - public Receiver getReceiver(int minorFragmentId) { - createSenderReceiverMapping(); - - List<MinorFragmentEndpoint> senders = receiverToSenderMapping.get(minorFragmentId); - if (senders == null || senders.size() <= 0) { - throw new IllegalStateException(String.format("Failed to find senders for receiver [%d]", minorFragmentId)); - } - + protected Receiver getReceiverInternal(int oppositeMajorFragmentId, + List<MinorFragmentEndpoint> senders, boolean spooling) { return new UnorderedReceiver(senderMajorFragmentId, senders, false); --- End diff -- `spooling` parameter is ignored, is this expected?
---