sepuri sai krishna created FLINK-40793:
------------------------------------------
Summary: 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.3.0, 2.2.0, 2.4.0
Reporter: sepuri sai krishna
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)
