Myasuka commented on a change in pull request #14835:
URL: https://github.com/apache/flink/pull/14835#discussion_r578180251
##########
File path:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/AsyncCheckpointRunnable.java
##########
@@ -287,10 +287,9 @@ private void handleExecutionException(Exception e) {
} 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());
Review comment:
If we still leave `checkpointException` in messages, some e2e tests
would fail immediately during exception check, which is not what we expected.
Thus, we should remove the checkpoint exception message.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
