File tree Expand file tree Collapse file tree 1 file changed +5
-1
lines changed
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive Expand file tree Collapse file tree 1 file changed +5
-1
lines changed Original file line number Diff line number Diff line change @@ -283,6 +283,8 @@ public int getMinParallelismChangeForDesiredRescale() {
283
283
}
284
284
285
285
private final Settings settings ;
286
+ private final RescaleManager .Factory rescaleManagerFactory ;
287
+
286
288
private final JobGraph jobGraph ;
287
289
288
290
private final JobInfo jobInfo ;
@@ -360,6 +362,8 @@ public AdaptiveScheduler(
360
362
assertPreconditions (jobGraph );
361
363
362
364
this .settings = settings ;
365
+ this .rescaleManagerFactory = DefaultRescaleManager .Factory .fromSettings (settings );
366
+
363
367
this .jobGraph = jobGraph ;
364
368
this .jobInfo = new JobInfoImpl (jobGraph .getJobID (), jobGraph .getName ());
365
369
@@ -1044,7 +1048,7 @@ public void goToExecuting(
1044
1048
this ,
1045
1049
userCodeClassLoader ,
1046
1050
failureCollection ,
1047
- DefaultRescaleManager . Factory . fromSettings ( settings ) ,
1051
+ rescaleManagerFactory ,
1048
1052
settings .getMinParallelismChangeForDesiredRescale ()));
1049
1053
}
1050
1054
You can’t perform that action at this time.
0 commit comments