Details
-
Bug
-
Status: Closed
-
Major
-
Resolution: Duplicate
-
1.11.4
-
None
Description
2021-02-09T23:15:44.6563035Z 2021-02-09 23:15:42,855 INFO org.apache.flink.runtime.taskmanager.Task [] - Freeing task resources for Source: Sequence Source -> Map -> Sink: Unnamed (1/1) (99fb2a8c8084ff2d87fa8bc5a91f2a82). 2021-02-09T23:15:44.6564613Z 2021-02-09 23:15:42,855 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor [] - Un-registering task and sending final execution state FINISHED to JobManager for task Source: Sequence Source -> Map -> Sink: Unnamed (1/1) 99fb2a8c8084ff2d87fa8bc5a91f2a82. 2021-02-09T23:15:44.6565773Z 2021-02-09 23:15:42,862 WARN org.apache.flink.streaming.runtime.tasks.AsyncCheckpointRunnable [] - As task is already not running, no longer decline checkpoint 1. 2021-02-09T23:15:44.6566892Z java.lang.Exception: Could not materialize checkpoint 1 for operator Source: Sequence Source -> Map -> Sink: Unnamed (1/1). 2021-02-09T23:15:44.6568059Z at org.apache.flink.streaming.runtime.tasks.AsyncCheckpointRunnable.handleExecutionException(AsyncCheckpointRunnable.java:215) [flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT] 2021-02-09T23:15:44.6569266Z at org.apache.flink.streaming.runtime.tasks.AsyncCheckpointRunnable.run(AsyncCheckpointRunnable.java:150) [flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT] 2021-02-09T23:15:44.6570111Z at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [?:1.8.0_282] 2021-02-09T23:15:44.6570749Z at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [?:1.8.0_282] 2021-02-09T23:15:44.6571299Z at java.lang.Thread.run(Thread.java:748) [?:1.8.0_282] 2021-02-09T23:15:44.6571749Z Caused by: java.util.concurrent.CancellationException 2021-02-09T23:15:44.6572242Z at java.util.concurrent.FutureTask.report(FutureTask.java:121) ~[?:1.8.0_282] 2021-02-09T23:15:44.6572800Z at java.util.concurrent.FutureTask.get(FutureTask.java:192) ~[?:1.8.0_282] 2021-02-09T23:15:44.6573827Z at org.apache.flink.runtime.concurrent.FutureUtils.runIfNotDoneAndGet(FutureUtils.java:501) ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT] 2021-02-09T23:15:44.6574980Z at org.apache.flink.streaming.api.operators.OperatorSnapshotFinalizer.<init>(OperatorSnapshotFinalizer.java:57) ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT] 2021-02-09T23:15:44.6576164Z at org.apache.flink.streaming.runtime.tasks.AsyncCheckpointRunnable.run(AsyncCheckpointRunnable.java:113) ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT] 2021-02-09T23:15:44.6576754Z ... 3 more .... 2021-02-09T23:15:44.6841230Z [FAIL] 'Quickstarts Scala nightly end-to-end test' failed after 0 minutes and 39 seconds! Test exited with exit code 0 but the logs contained errors, exceptions or non-empty .out files
Attachments
Issue Links
- duplicates
-
FLINK-21213 e2e test fail with 'As task is already not running, no longer decline checkpoint'
- Resolved