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.


---

Reply via email to