[
https://issues.apache.org/jira/browse/FLINK-27637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lijie Wang updated FLINK-27637:
-------------------------------
Affects Version/s: 1.15.0
(was: 1.16.0)
> Optimize the log information when the asynchronous part of checkpoint is
> canceled
> ---------------------------------------------------------------------------------
>
> Key: FLINK-27637
> URL: https://issues.apache.org/jira/browse/FLINK-27637
> Project: Flink
> Issue Type: Improvement
> Components: Runtime / Checkpointing
> Affects Versions: 1.15.0
> Reporter: Lijie Wang
> Priority: Major
>
> When the checkpoint is aborted due to expiration, the tasks whose
> asynchronous part of checkpoint is not completed will print following logs:
> {code:java}
> 60477 [AsyncOperations-thread-1] INFO
> org.apache.flink.streaming.runtime.tasks.AsyncCheckpointRunnable [] -
> DeclineSink (1/1)#0 - asynchronous part of checkpoint 2 could not be
> completed.
> java.util.concurrent.CancellationException: null
> at java.util.concurrent.FutureTask.report(FutureTask.java:121)
> ~[?:1.8.0_241]
> at java.util.concurrent.FutureTask.get(FutureTask.java:192) ~[?:1.8.0_241]
> at
> org.apache.flink.util.concurrent.FutureUtils.runIfNotDoneAndGet(FutureUtils.java:645)
> ~[classes/:?]
> at
> org.apache.flink.streaming.api.operators.OperatorSnapshotFinalizer.<init>(OperatorSnapshotFinalizer.java:60)
> ~[classes/:?]
> at
> org.apache.flink.streaming.runtime.tasks.AsyncCheckpointRunnable.finalizeNonFinishedSnapshots(AsyncCheckpointRunnable.java:191)
> ~[classes/:?]
> at
> org.apache.flink.streaming.runtime.tasks.AsyncCheckpointRunnable.run(AsyncCheckpointRunnable.java:124)
> [classes/:?]
> at
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
> [?:1.8.0_241]
> at
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
> [?:1.8.0_241]
> at java.lang.Thread.run(Thread.java:748) [?:1.8.0_241] {code}
>
> Maybe we can optimize the logs to make it more friendly.
--
This message was sent by Atlassian Jira
(v8.20.7#820007)
