Repository: flink Updated Branches: refs/heads/master 4a8e94403 -> 28ff5a3c9
[hotfix] Fix restart strategy class loading by using not lower cased class name Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/28ff5a3c Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/28ff5a3c Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/28ff5a3c Branch: refs/heads/master Commit: 28ff5a3c9999e02b84f4e4aa568347ba5e13c3d2 Parents: 4a8e944 Author: Till Rohrmann <trohrm...@apache.org> Authored: Mon Sep 26 12:00:19 2016 +0200 Committer: Till Rohrmann <trohrm...@apache.org> Committed: Mon Sep 26 12:00:19 2016 +0200 ---------------------------------------------------------------------- .../runtime/executiongraph/restart/RestartStrategyFactory.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/28ff5a3c/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/restart/RestartStrategyFactory.java ---------------------------------------------------------------------- diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/restart/RestartStrategyFactory.java b/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/restart/RestartStrategyFactory.java index ae92b3a..870bf63 100644 --- a/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/restart/RestartStrategyFactory.java +++ b/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/restart/RestartStrategyFactory.java @@ -79,9 +79,9 @@ public abstract class RestartStrategyFactory implements Serializable { * @throws Exception which indicates that the RestartStrategy could not be instantiated. */ public static RestartStrategyFactory createRestartStrategyFactory(Configuration configuration) throws Exception { - String restartStrategyName = configuration.getString(ConfigConstants.RESTART_STRATEGY, "none").toLowerCase(); + String restartStrategyName = configuration.getString(ConfigConstants.RESTART_STRATEGY, "none"); - switch (restartStrategyName) { + switch (restartStrategyName.toLowerCase()) { case "none": // support deprecated ConfigConstants values final int numberExecutionRetries = configuration.getInteger(ConfigConstants.EXECUTION_RETRIES_KEY,
