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.
---
