diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/CreatingExecutionGraph.java b/flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/CreatingExecutionGraph.java index e9b1317e46e62..44fa1a9b68b19 100644 --- a/flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/CreatingExecutionGraph.java +++ b/flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/CreatingExecutionGraph.java @@ -67,7 +67,7 @@ public CreatingExecutionGraph( executionGraphWithParallelismFuture, Logger logger, OperatorCoordinatorHandlerFactory operatorCoordinatorFactory, - ExecutionGraph previousExecutionGraph1) { + @Nullable ExecutionGraph previousExecutionGraph) { super(context, logger); this.context = context; this.operatorCoordinatorHandlerFactory = operatorCoordinatorFactory; @@ -83,7 +83,7 @@ public CreatingExecutionGraph( Duration.ZERO); return null; })); - previousExecutionGraph = previousExecutionGraph1; + this.previousExecutionGraph = previousExecutionGraph; } private void handleExecutionGraphCreation(