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

Martijn Visser commented on FLINK-40793:
----------------------------------------

One more on master, nightly 2026-10-07 (Hadoop 3.4.3, module core, JDK 17), 
testJobStatusHookWithJobFinished:
https://github.com/apache/flink/actions/runs/37560828844/job/112601113284

{code}
[ERROR] 
org.apache.flink.runtime.scheduler.DefaultSchedulerTest.testJobStatusHookWithJobFinished
 -- Time elapsed: 0.011 s <<< FAILURE!
org.opentest4j.AssertionFailedError:
expected: FINISHED
 but was: FAILED
        at 
org.apache.flink.runtime.scheduler.DefaultSchedulerTest.commonJobStatusHookTest(DefaultSchedulerTest.java:1933)
        at 
org.apache.flink.runtime.scheduler.DefaultSchedulerTest.testJobStatusHookWithJobFinished(DefaultSchedulerTest.java:1823)
{code}

The fork log has the same main thread violation as the release-2.3 run in my 
09-30 comment, so the deployment failed before the test reported FINISHED:

{code}
02:34:39,733 [  pool-1175-thread-1] WARN  
org.apache.flink.runtime.rpc.MainThreadValidatorUtil [] - Violation of main 
thread constraint detected: expected 
<Thread[ComponentMainThread-ForkJoinPool-468-worker-1,5,main]> but running in 
<Thread[pool-1175-thread-1,5,main]>.
02:34:39,734 [ComponentMainThread-ForkJoinPool-468-worker-1] INFO  
org.apache.flink.runtime.executiongraph.ExecutionGraph [] - source (1/1) 
(474650421f35ca831d43a3bf117737f7_db202123a969e8c1d3f478fe0e19637d_0_0) 
switched from DEPLOYING to FAILED on 60700e442fbf7d217f263d784e29db7e @ 
localhost (dataPort=42).
java.lang.AssertionError
        at 
org.apache.flink.runtime.concurrent.ComponentMainThreadExecutorServiceAdapter$1.execute(ComponentMainThreadExecutorServiceAdapter.java:66)
{code}

> DefaultSchedulerTest is unstable across many test methods
> ---------------------------------------------------------
>
>                 Key: FLINK-40793
>                 URL: https://issues.apache.org/jira/browse/FLINK-40793
>             Project: Flink
>          Issue Type: Bug
>          Components: Runtime / Coordination
>    Affects Versions: 2.2.2, 2.3.1, 2.4.0
>            Reporter: sepuri sai krishna
>            Assignee: sepuri sai krishna
>            Priority: Major
>              Labels: pull-request-available, test-stability
>
> DefaultSchedulerTest failed 17 times in the 90 days to 2026-09-15, in 11 
> different test methods, on all core CI profiles (Java 11, 17, 21, Hadoop, 
> AdaptiveScheduler). It is not limited to master: the most recent two are 
> 2026-09-14 on master and 2026-09-10 on release-2.3.
> Recent runs:
> * https://github.com/apache/flink/actions/runs/34798011374/job/103837976051 
> master, testExceptionHistoryWithRestartableFailure
> * https://github.com/apache/flink/actions/runs/34427845031/job/102726173515 
> release-2.3, testExceptionHistoryWithRestartableFailure
> * https://github.com/apache/flink/actions/runs/33866786819/job/101007980019 
> testExceptionHistoryConcurrentRestart
> * https://github.com/apache/flink/actions/runs/33349433782/job/99360730245 
> testJobStatusHookWithJobCanceled
> * https://github.com/apache/flink/actions/runs/32136151763/job/95710148170 
> testExceptionHistoryWithGlobalFailOver
> * https://github.com/apache/flink/actions/runs/31662007213/job/94339220821 
> testJobStatusHookWithJobFinished
> * https://github.com/apache/flink/actions/runs/30418270959/job/90470994165 
> testStartCheckpointOnlyAfterVertexWithBlockingEdgeFinished
> Other failing methods: skipDeploymentIfVertexVersionOutdated, 
> testDeploymentWaitForProducedPartitionRegistration, 
> failGlobalWhenRestoringStateFails, 
> jobStatusIsRestartingIfOneVertexIsWaitingForRestart, 
> abortPendingCheckpointsWhenRestartingTasks.
> {code}
> [ERROR] 
> org.apache.flink.runtime.scheduler.DefaultSchedulerTest.testJobStatusHookWithJobCanceled
>  -- Time elapsed: 0.014 s <<< FAILURE!
> org.opentest4j.AssertionFailedError:
> expected: CANCELED
>  but was: FAILED
>       at 
> org.apache.flink.runtime.scheduler.DefaultSchedulerTest.commonJobStatusHookTest(DefaultSchedulerTest.java:1933)
>       at 
> org.apache.flink.runtime.scheduler.DefaultSchedulerTest.testJobStatusHookWithJobCanceled(DefaultSchedulerTest.java:1818)
> {code}
> {code}
> [ERROR] 
> org.apache.flink.runtime.scheduler.DefaultSchedulerTest.testStartCheckpointOnlyAfterVertexWithBlockingEdgeFinished
>  -- Time elapsed: 0.026 s <<< ERROR!
> java.lang.IllegalStateException
>       at 
> org.apache.flink.util.Preconditions.checkState(Preconditions.java:177)
>       at 
> org.apache.flink.runtime.scheduler.DefaultSchedulerTest.transitionToRunning(DefaultSchedulerTest.java:2362)
>       at 
> org.apache.flink.runtime.scheduler.DefaultSchedulerTest.testStartCheckpointOnlyAfterVertexWithBlockingEdgeFinished(DefaultSchedulerTest.java:1877)
> {code}



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

Reply via email to