File tree Expand file tree Collapse file tree 1 file changed +4
-4
lines changed
flink-runtime/src/test/java/org/apache/flink/runtime/jobmaster Expand file tree Collapse file tree 1 file changed +4
-4
lines changed Original file line number Diff line number Diff line change @@ -1736,18 +1736,18 @@ private static void assertJobStatusTransitions(
17361736 .map (x -> (String ) x .get ("newJobStatus" ))
17371737 .collect (Collectors .toList ());
17381738
1739- if (schedulerType == SchedulerType .Default ) {
1740- // Default scheduler does not emit CREATED: RUNNING → FAILING → FAILED
1739+ if (schedulerType == SchedulerType .Adaptive ) {
1740+ // Adaptive schedulers emit CREATED: CREATED → RUNNING → FAILING → FAILED
17411741 assertThat (jobStatusTransitions )
17421742 .containsExactly (
1743+ JobStatus .CREATED .toString (),
17431744 JobStatus .RUNNING .toString (),
17441745 JobStatus .FAILING .toString (),
17451746 JobStatus .FAILED .toString ());
17461747 } else {
1747- // Adaptive schedulers emit CREATED: CREATED → RUNNING → FAILING → FAILED
1748+ // Default scheduler does not emit CREATED: RUNNING → FAILING → FAILED
17481749 assertThat (jobStatusTransitions )
17491750 .containsExactly (
1750- JobStatus .CREATED .toString (),
17511751 JobStatus .RUNNING .toString (),
17521752 JobStatus .FAILING .toString (),
17531753 JobStatus .FAILED .toString ());
You can’t perform that action at this time.
0 commit comments