This is an automated email from the ASF dual-hosted git repository. trohrmann pushed a commit to branch release-1.13 in repository https://gitbox.apache.org/repos/asf/flink.git
commit 9252ee2a92a0d71502c57783ced32c4b5a27a6ab Author: Matthias Pohl <[email protected]> AuthorDate: Mon Apr 19 09:27:28 2021 +0200 [hotfix][runtime] Wrong annotation was used The Throwable can be null in that case due to FLINK-21376. We're not enforcing that behavior for now. FLINK-22060 covers the resolution on the ExecutionGraph side. FLINK-21376 covers the issue on the Task side. --- .../runtime/executiongraph/failover/flip1/FailureHandlingResult.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/failover/flip1/FailureHandlingResult.java b/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/failover/flip1/FailureHandlingResult.java index 957fb92..b23f732 100644 --- a/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/failover/flip1/FailureHandlingResult.java +++ b/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/failover/flip1/FailureHandlingResult.java @@ -156,6 +156,7 @@ public class FailureHandlingResult { * * @return reason why the restarting cannot be conducted */ + @Nullable public Throwable getError() { return error; } @@ -204,7 +205,7 @@ public class FailureHandlingResult { */ public static FailureHandlingResult restartable( @Nullable ExecutionVertexID failingExecutionVertexId, - @Nonnull Throwable cause, + @Nullable Throwable cause, long timestamp, @Nullable Set<ExecutionVertexID> verticesToRestart, long restartDelayMS,
