File tree Expand file tree Collapse file tree 1 file changed +2
-0
lines changed
flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adaptive Expand file tree Collapse file tree 1 file changed +2
-0
lines changed Original file line number Diff line number Diff line change 94
94
import org .apache .flink .runtime .scheduler .DefaultSchedulerTest ;
95
95
import org .apache .flink .runtime .scheduler .SchedulerBase ;
96
96
import org .apache .flink .runtime .scheduler .SchedulerNG ;
97
+ import org .apache .flink .runtime .scheduler .SchedulerTestingUtils ;
97
98
import org .apache .flink .runtime .scheduler .TestingPhysicalSlot ;
98
99
import org .apache .flink .runtime .scheduler .VertexParallelismInformation ;
99
100
import org .apache .flink .runtime .scheduler .VertexParallelismStore ;
@@ -2228,6 +2229,7 @@ private AdaptiveScheduler createSchedulerThatReachesExecutingState(
2228
2229
.build (),
2229
2230
null ))
2230
2231
.build ();
2232
+ SchedulerTestingUtils .enableCheckpointing (jobGraph );
2231
2233
2232
2234
// testing SlotPool instance that would allow for the scheduler to transition to Executing
2233
2235
// state
You can’t perform that action at this time.
0 commit comments