You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by se...@apache.org on 2017/05/02 21:47:27 UTC
[5/8] flink git commit: [hotfix] [runtime] Minor improvement to
logging in CheckpointCoordinator
[hotfix] [runtime] Minor improvement to logging in CheckpointCoordinator
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/91b2d6f3
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/91b2d6f3
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/91b2d6f3
Branch: refs/heads/master
Commit: 91b2d6f39edb22787c2b763e28c6545ed951425a
Parents: 03721cf
Author: Stephan Ewen <se...@apache.org>
Authored: Tue May 2 21:24:10 2017 +0200
Committer: Stephan Ewen <se...@apache.org>
Committed: Tue May 2 22:49:46 2017 +0200
----------------------------------------------------------------------
.../apache/flink/runtime/checkpoint/CheckpointCoordinator.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/91b2d6f3/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java
----------------------------------------------------------------------
diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java b/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java
index 96add06..0bbf6b5 100644
--- a/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java
+++ b/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java
@@ -646,7 +646,8 @@ public class CheckpointCoordinator {
}
int numUnsuccessful = numUnsuccessfulCheckpointsTriggers.incrementAndGet();
- LOG.warn("Failed to trigger checkpoint (" + numUnsuccessful + " consecutive failed attempts so far)", t);
+ LOG.warn("Failed to trigger checkpoint {}. ({} consecutive failed attempts so far)",
+ checkpointID, numUnsuccessful, t);
if (!checkpoint.isDiscarded()) {
checkpoint.abortError(new Exception("Failed to trigger checkpoint", t));