[flink] branch master updated: [FLINK-21213][task] Degrade log level to INFO when ignore to decline checkpoint as task not running

[ta...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

tangyun pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/master by this push:
     new 32ed582  [FLINK-21213][task] Degrade log level to INFO when ignore to decline checkpoint as task not running
32ed582 is described below

commit 32ed58254303aaec6290a1adb0402279ac5ee7d1
Author: Yun Tang <my...@live.com>
AuthorDate: Tue Feb 2 20:38:45 2021 +0800

    [FLINK-21213][task] Degrade log level to INFO when ignore to decline checkpoint as task not running
---
 .../flink/streaming/runtime/tasks/AsyncCheckpointRunnable.java     | 7 +++----
 1 file changed, 3 insertions(+), 4 deletions(-)

diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/AsyncCheckpointRunnable.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/AsyncCheckpointRunnable.java
index 7c2f759..b7d1cd7 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/AsyncCheckpointRunnable.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/AsyncCheckpointRunnable.java
@@ -288,10 +288,9 @@ final class AsyncCheckpointRunnable implements Runnable, Closeable {
                 } else {
                     // We never decline checkpoint after task is not running to avoid unexpected job
                     // failover, which caused by exceeding checkpoint tolerable failure threshold.
-                    LOG.warn(
-                            "As task is already not running, no longer decline checkpoint {}.",
-                            checkpointMetaData.getCheckpointId(),
-                            checkpointException);
+                    LOG.info(
+                            "Ignore decline of checkpoint {} as task is not running anymore.",
+                            checkpointMetaData.getCheckpointId());
                 }
 
                 currentState = AsyncCheckpointState.DISCARDED;