From 446b582ed701e8c6f9f2c98aaacab1ea7ee0b64e Mon Sep 17 00:00:00 2001 From: Matthias Pohl Date: Fri, 31 May 2024 16:16:39 +0200 Subject: [PATCH] [hotfix][runtime] Adds missing @Nullable annotation --- .../runtime/scheduler/adaptive/CreatingExecutionGraph.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) 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(