[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/table-retraction 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));
