[hotfix] Fix restart strategy class loading by using not lower cased …

…class name
KobeFeng · Sep 26, 2016 · 28ff5a3 · 28ff5a3
1 parent 4a8e944
commit 28ff5a3
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/...src/main/java/org/apache/flink/runtime/executiongraph/restart/RestartStrategyFactory.java b/...src/main/java/org/apache/flink/runtime/executiongraph/restart/RestartStrategyFactory.java
@@ -79,9 +79,9 @@ public static RestartStrategy createRestartStrategy(RestartStrategies.RestartStr
 	 * @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,