[ 
https://issues.apache.org/jira/browse/FLINK-33186?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18120061#comment-18120061
 ] 

Martijn Visser commented on FLINK-33186:
----------------------------------------

release-2.3 hits the hang as well now, same line 138 and the same dump shape 
(the source subtask parked in StreamTask.afterInvoke, four passB -> sinkB 
subtasks in the mailbox loop):

https://github.com/apache/flink/actions/runs/36287526040/job/108536631175 
(nightly 2026-09-27, Java 21)
https://github.com/apache/flink/actions/runs/36084551382/job/107928974605 
(nightly 2026-09-25, Java 11)

{code}
Process produced no output for 900 seconds.
...
"ForkJoinPool-1-worker-1" #28 [26355] daemon prio=5 os_prio=0 cpu=4047.16ms 
elapsed=4971.74s
   java.lang.Thread.State: WAITING (parking)
        at 
java.util.concurrent.CompletableFuture.get([email protected]/CompletableFuture.java:2072)
        at 
org.apache.flink.test.checkpointing.CheckpointAfterAllTasksFinishedITCase.testRestoreAfterSomeTasksFinished(CheckpointAfterAllTasksFinishedITCase.java:138)
{code}

>  CheckpointAfterAllTasksFinishedITCase.testRestoreAfterSomeTasksFinished 
> fails on AZP
> -------------------------------------------------------------------------------------
>
>                 Key: FLINK-33186
>                 URL: https://issues.apache.org/jira/browse/FLINK-33186
>             Project: Flink
>          Issue Type: Bug
>          Components: Runtime / Checkpointing
>    Affects Versions: 1.19.0, 1.18.1, 2.3.1, 2.4.0
>            Reporter: Sergey Nuyanzin
>            Assignee: Efrat Levitan
>            Priority: Critical
>              Labels: pull-request-available, test-stability
>             Fix For: 2.4.0
>
>
> This build 
> https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=53509&view=logs&j=baf26b34-3c6a-54e8-f93f-cf269b32f802&t=8c9d126d-57d2-5a9e-a8c8-ff53f7b35cd9&l=8762
> fails as
> {noformat}
> Sep 28 01:23:43 Caused by: 
> org.apache.flink.runtime.checkpoint.CheckpointException: Task local 
> checkpoint failure.
> Sep 28 01:23:43       at 
> org.apache.flink.runtime.checkpoint.PendingCheckpoint.abort(PendingCheckpoint.java:550)
> Sep 28 01:23:43       at 
> org.apache.flink.runtime.checkpoint.CheckpointCoordinator.abortPendingCheckpoint(CheckpointCoordinator.java:2248)
> Sep 28 01:23:43       at 
> org.apache.flink.runtime.checkpoint.CheckpointCoordinator.abortPendingCheckpoint(CheckpointCoordinator.java:2235)
> Sep 28 01:23:43       at 
> org.apache.flink.runtime.checkpoint.CheckpointCoordinator.lambda$null$9(CheckpointCoordinator.java:817)
> Sep 28 01:23:43       at 
> java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
> Sep 28 01:23:43       at 
> java.util.concurrent.FutureTask.run(FutureTask.java:266)
> Sep 28 01:23:43       at 
> java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)
> Sep 28 01:23:43       at 
> java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
> Sep 28 01:23:43       at 
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
> Sep 28 01:23:43       at 
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
> Sep 28 01:23:43       at java.lang.Thread.run(Thread.java:748)
> {noformat}



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

Reply via email to