[hotfix] Remove the wrong @Nullable annotation of FailureHandlingRe…

…sult due to the constructor checks `verticesToRestart` is not null
yhjhoo · Jan 23, 2024 · ad3f13f · ad3f13f
1 parent d031f60
commit ad3f13f
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/...src/main/java/org/apache/flink/runtime/executiongraph/failover/FailureHandlingResult.java b/...src/main/java/org/apache/flink/runtime/executiongraph/failover/FailureHandlingResult.java
@@ -87,7 +87,7 @@ private FailureHandlingResult(
             @Nullable Throwable cause,
             long timestamp,
             CompletableFuture<Map<String, String>> failureLabels,
-            @Nullable Set<ExecutionVertexID> verticesToRestart,
+            Set<ExecutionVertexID> verticesToRestart,
             long restartDelayMS,
             boolean globalFailure,
             boolean isRootCause) {
@@ -247,7 +247,7 @@ public static FailureHandlingResult restartable(
             @Nullable Throwable cause,
             long timestamp,
             CompletableFuture<Map<String, String>> failureLabels,
-            @Nullable Set<ExecutionVertexID> verticesToRestart,
+            Set<ExecutionVertexID> verticesToRestart,
             long restartDelayMS,
             boolean globalFailure,
             boolean isRootCause) {