You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by rm...@apache.org on 2016/02/26 13:31:38 UTC
[7/8] flink git commit: [FLINK-3434] Prevent NPE in
ClientFrontend#getClient()
[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....@web.de>
Authored: Thu Feb 18 13:35:39 2016 +0100
Committer: Robert Metzger <rm...@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 --------------