You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tr...@apache.org on 2016/09/26 10:01:18 UTC
flink git commit: [hotfix] Fix restart strategy class loading by
using not lower cased class name
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 <tr...@apache.org>
Authored: Mon Sep 26 12:00:19 2016 +0200
Committer: Till Rohrmann <tr...@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,