Github user HanumathRao commented on a diff in the pull request:

    https://github.com/apache/drill/pull/1110#discussion_r168021043
  
    --- Diff: 
exec/java-exec/src/main/java/org/apache/drill/exec/physical/config/AbstractMuxExchange.java
 ---
    @@ -92,24 +92,19 @@ public Sender getSender(int minorFragmentId, 
PhysicalOperator child) {
         return new SingleSender(receiverMajorFragmentId, receiver.getId(), 
child, receiver.getEndpoint());
       }
     
    -
    -  @Override
    -  public final Receiver getReceiver(int minorFragmentId) {
    +  protected final List<MinorFragmentEndpoint> getSenders(int 
minorFragmentId) {
         createSenderReceiverMapping();
     
         List<MinorFragmentEndpoint> senders = 
receiverToSenderMapping.get(minorFragmentId);
     
    -    logger.debug(String.format("Minor fragment %d, receives data from 
following senders %s", minorFragmentId, senders));
    +    logger.debug("Minor fragment %d, receives data from following senders 
%s", minorFragmentId, senders);
    --- End diff --
    
    Done. 


---

Reply via email to