You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ga...@apache.org on 2019/05/08 13:12:15 UTC
[flink] 01/03: [hotfix][runtime] Add null check to
RestartStrategyResolving
This is an automated email from the ASF dual-hosted git repository.
gary pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 1090967f8af22b1801986ee39e1392738e8d3eea
Author: Gary Yao <ga...@apache.org>
AuthorDate: Mon Apr 29 10:10:12 2019 +0200
[hotfix][runtime] Add null check to RestartStrategyResolving
---
.../runtime/executiongraph/restart/RestartStrategyResolving.java | 4 ++++
1 file changed, 4 insertions(+)
diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/restart/RestartStrategyResolving.java b/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/restart/RestartStrategyResolving.java
index ad7aa93..7d3733b 100644
--- a/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/restart/RestartStrategyResolving.java
+++ b/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/restart/RestartStrategyResolving.java
@@ -20,6 +20,8 @@ package org.apache.flink.runtime.executiongraph.restart;
import org.apache.flink.api.common.restartstrategy.RestartStrategies;
+import static org.apache.flink.util.Preconditions.checkNotNull;
+
/**
* Utility method for resolving {@link RestartStrategy}.
*/
@@ -46,6 +48,8 @@ public final class RestartStrategyResolving {
RestartStrategyFactory serverStrategyFactory,
boolean isCheckpointingEnabled) {
+ checkNotNull(serverStrategyFactory);
+
final RestartStrategy clientSideRestartStrategy =
RestartStrategyFactory.createRestartStrategy(clientConfiguration);