flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From rmetz...@apache.org
Subject [7/8] flink git commit: [FLINK-3434] Prevent NPE in ClientFrontend#getClient()
Date Fri, 26 Feb 2016 12:31:38 GMT
[FLINK-3434] Prevent NPE in ClientFrontend#getClient()

This closes #1695


Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/0fb6e0dd
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/0fb6e0dd
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/0fb6e0dd

Branch: refs/heads/master
Commit: 0fb6e0dde3fbfea666c6bfe8d6f738bfd80d3af0
Parents: 9692c83
Author: zentol <s.motsu@web.de>
Authored: Thu Feb 18 13:35:39 2016 +0100
Committer: Robert Metzger <rmetzger@apache.org>
Committed: Fri Feb 26 11:35:08 2016 +0100

----------------------------------------------------------------------
 .../src/main/java/org/apache/flink/yarn/FlinkYarnClientBase.java  | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/flink/blob/0fb6e0dd/flink-yarn/src/main/java/org/apache/flink/yarn/FlinkYarnClientBase.java
----------------------------------------------------------------------
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
index afedb33..4e4a2f5 100644
--- 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 @@ public abstract class FlinkYarnClientBase extends AbstractFlinkYarnClient
{
 		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 --------------
 


Mime
View raw message