This is an automated email from the ASF dual-hosted git repository. nkruber pushed a commit to branch release-1.6 in repository https://gitbox.apache.org/repos/asf/flink.git
commit 4432dc243d4c6e08404b04770463fc6ca5ef4b46 Author: Nico Kruber <[email protected]> AuthorDate: Tue Jul 31 14:49:16 2018 +0200 [hotfix][network] add task name to SingleInputGate logs --- .../runtime/io/network/partition/consumer/SingleInputGate.java | 10 ++++++---- 1 file changed, 6 insertions(+), 4 deletions(-) diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/SingleInputGate.java b/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/SingleInputGate.java index 06e80ff..b6380af 100644 --- a/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/SingleInputGate.java +++ b/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/SingleInputGate.java @@ -364,7 +364,7 @@ public class SingleInputGate implements InputGate { throw new IllegalStateException("Tried to update unknown channel with unknown channel."); } - LOG.debug("Updated unknown input channel to {}.", newChannel); + LOG.debug("{}: Updated unknown input channel to {}.", owningTaskName, newChannel); inputChannels.put(partitionId, newChannel); @@ -393,7 +393,7 @@ public class SingleInputGate implements InputGate { checkNotNull(ch, "Unknown input channel with ID " + partitionId); - LOG.debug("Retriggering partition request {}:{}.", ch.partitionId, consumedSubpartitionIndex); + LOG.debug("{}: Retriggering partition request {}:{}.", owningTaskName, ch.partitionId, consumedSubpartitionIndex); if (ch.getClass() == RemoteInputChannel.class) { final RemoteInputChannel rch = (RemoteInputChannel) ch; @@ -432,7 +432,8 @@ public class SingleInputGate implements InputGate { inputChannel.releaseAllResources(); } catch (IOException e) { - LOG.warn("Error during release of channel resources: " + e.getMessage(), e); + LOG.warn("{}: Error during release of channel resources: {}.", + owningTaskName, e.getMessage(), e); } } @@ -725,7 +726,8 @@ public class SingleInputGate implements InputGate { inputGate.setInputChannel(partitionId.getPartitionId(), inputChannels[i]); } - LOG.debug("Created {} input channels (local: {}, remote: {}, unknown: {}).", + LOG.debug("{}: Created {} input channels (local: {}, remote: {}, unknown: {}).", + owningTaskName, inputChannels.length, numLocalChannels, numRemoteChannels,
