Github user vrozov commented on a diff in the pull request:
https://github.com/apache/drill/pull/1110#discussion_r167953826
--- Diff:
exec/java-exec/src/main/java/org/apache/drill/exec/physical/config/AbstractMuxExchange.java
---
@@ -90,6 +92,24 @@ public Sender getSender(int minorFragmentId,
PhysicalOperator child) {
return new SingleSender(receiverMajorFragmentId, receiver.getId(),
child, receiver.getEndpoint());
}
+
+ @Override
+ public final Receiver getReceiver(int minorFragmentId) {
+ createSenderReceiverMapping();
+
+ List<MinorFragmentEndpoint> senders =
receiverToSenderMapping.get(minorFragmentId);
+
+ logger.debug(String.format("Minor fragment %d, receives data from
following senders %s", minorFragmentId, senders));
--- End diff --
Use SLF4J smart logging instead of `String.format`.
---
