We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 582457c commit 79356ccCopy full SHA for 79356cc
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/WaitingForResources.java
@@ -237,7 +237,7 @@ public Factory(
237
Logger log,
238
Duration initialResourceAllocationTimeout,
239
Duration resourceStabilizationTimeout,
240
- ExecutionGraph previousExecutionGraph) {
+ @Nullable ExecutionGraph previousExecutionGraph) {
241
this.context = context;
242
this.log = log;
243
this.initialResourceAllocationTimeout = initialResourceAllocationTimeout;
@@ -259,9 +259,4 @@ public WaitingForResources getState() {
259
previousExecutionGraph);
260
}
261
262
-
263
- @Nullable
264
- public ExecutionGraph getPreviousExecutionGraph() {
265
- return previousExecutionGraph;
266
- }
267
0 commit comments