[flink] 08/10: [hotfix][coordination] Remove unnecessary null check

[sewen]

This is an automated email from the ASF dual-hosted git repository.

sewen pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git

commit 7f01aeca04329aeb19b1ede659a33eedaf0eca29
Author: Stephan Ewen <se...@apache.org>
AuthorDate: Wed Apr 14 11:54:20 2021 +0200

    [hotfix][coordination] Remove unnecessary null check
---
 .../runtime/operators/coordination/OperatorCoordinatorHolder.java    | 5 +----
 1 file changed, 1 insertion(+), 4 deletions(-)

diff --git 
a/flink-runtime/src/main/java/org/apache/flink/runtime/operators/coordination/OperatorCoordinatorHolder.java
 
b/flink-runtime/src/main/java/org/apache/flink/runtime/operators/coordination/OperatorCoordinatorHolder.java
index 1baa738..8d96e15 100644
--- 
a/flink-runtime/src/main/java/org/apache/flink/runtime/operators/coordination/OperatorCoordinatorHolder.java
+++ 
b/flink-runtime/src/main/java/org/apache/flink/runtime/operators/coordination/OperatorCoordinatorHolder.java
@@ -252,10 +252,7 @@ public class OperatorCoordinatorHolder
         }
 
         eventValve.openValveAndUnmarkCheckpoint();
-
-        if (context != null) {
-            context.resetFailed();
-        }
+        context.resetFailed();
 
         // when initial savepoints are restored, this call comes before the 
mainThreadExecutor
         // is available, which is needed to set up these gateways. So during 
the initial restore,