[FLINK-3434] Prevent NPE in ClientFrontend#getClient()

This closes apache#1695
kumarvee · Feb 26, 2016 · 0fb6e0d · 0fb6e0d
1 parent 9692c83
commit 0fb6e0d
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/flink-yarn/src/main/java/org/apache/flink/yarn/FlinkYarnClientBase.java b/flink-yarn/src/main/java/org/apache/flink/yarn/FlinkYarnClientBase.java
@@ -367,9 +367,8 @@ protected AbstractFlinkYarnCluster deployInternal() throws Exception {
 		try {
 			org.apache.flink.core.fs.FileSystem.setDefaultScheme(flinkConfiguration);
 		} catch (IOException e) {
-			LOG.error("Error while setting the default " +
+			throw new IOException("Error while setting the default " +
 				"filesystem scheme from configuration.", e);
-			return null;
 		}
 		// ------------------ Check if the specified queue exists --------------