[
https://issues.apache.org/jira/browse/FLINK-27637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-27637:
-----------------------------------
Labels: pull-request-available stale-assigned (was: pull-request-available)
I am the [Flink Jira Bot|https://github.com/apache/flink-jira-bot/] and I help
the community manage its development. I see this issue is assigned but has not
received an update in 30 days, so it has been labeled "stale-assigned".
If you are still working on the issue, please remove the label and add a
comment updating the community on your progress. If this issue is waiting on
feedback, please consider this a reminder to the committer/reviewer. Flink is a
very active project, and so we appreciate your patience.
If you are no longer working on the issue, please unassign yourself so someone
else may work on it.
> 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
> Assignee: Wencong Liu
> Priority: Major
> Labels: pull-request-available, stale-assigned
>
> 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.10#820010)
