This is an automated email from the ASF dual-hosted git repository. zhijiang pushed a commit to branch release-1.11 in repository https://gitbox.apache.org/repos/asf/flink.git
commit 4030b1b30a2208e494d639af8767c3a944d87d58 Author: Roman Khachatryan <[email protected]> AuthorDate: Wed Jun 3 14:34:30 2020 +0200 [FLINK-17869][hotfix] Add taskName to ChannelStateWriter log messages --- .../flink/runtime/checkpoint/channel/ChannelStateWriterImpl.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/channel/ChannelStateWriterImpl.java b/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/channel/ChannelStateWriterImpl.java index e6aa9dc..fc8655c 100644 --- a/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/channel/ChannelStateWriterImpl.java +++ b/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/channel/ChannelStateWriterImpl.java @@ -102,11 +102,11 @@ public class ChannelStateWriterImpl implements ChannelStateWriter { LOG.debug("{} starting checkpoint {} ({})", taskName, checkpointId, checkpointOptions); ChannelStateWriteResult result = new ChannelStateWriteResult(); ChannelStateWriteResult put = results.computeIfAbsent(checkpointId, id -> { - Preconditions.checkState(results.size() < maxCheckpoints, "results.size() > maxCheckpoints", results.size(), maxCheckpoints); + Preconditions.checkState(results.size() < maxCheckpoints, String.format("%s can't start %d, results.size() > maxCheckpoints: %d > %d", taskName, checkpointId, results.size(), maxCheckpoints)); enqueue(new CheckpointStartRequest(checkpointId, result, checkpointOptions.getTargetLocation()), false); return result; }); - Preconditions.checkArgument(put == result, "result future already present for checkpoint " + checkpointId); + Preconditions.checkArgument(put == result, taskName + " result future already present for checkpoint " + checkpointId); } @Override @@ -156,7 +156,7 @@ public class ChannelStateWriterImpl implements ChannelStateWriter { public ChannelStateWriteResult getWriteResult(long checkpointId) { LOG.debug("{} requested write result, checkpoint {}", taskName, checkpointId); ChannelStateWriteResult result = results.get(checkpointId); - Preconditions.checkArgument(result != null, "channel state write result not found for checkpoint " + checkpointId); + Preconditions.checkArgument(result != null, taskName + " channel state write result not found for checkpoint " + checkpointId); return result; }
