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;
        }
 

Reply via email to