Github user HanumathRao commented on a diff in the pull request:
https://github.com/apache/drill/pull/1110#discussion_r168025910
--- 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 --
Done.
---
