You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by mx...@apache.org on 2016/06/20 15:11:05 UTC
flink git commit: [FLINK-4089][yarn] fix null check in Yarn client
Repository: flink
Updated Branches:
refs/heads/release-1.0 14525ae18 -> e30bee839
[FLINK-4089][yarn] fix null check in Yarn client
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/e30bee83
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/e30bee83
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/e30bee83
Branch: refs/heads/release-1.0
Commit: e30bee839aadf9c3ac7d46bb35a87c0f130f4789
Parents: 14525ae
Author: Maximilian Michels <mx...@apache.org>
Authored: Mon Jun 20 17:07:50 2016 +0200
Committer: Maximilian Michels <mx...@apache.org>
Committed: Mon Jun 20 17:10:53 2016 +0200
----------------------------------------------------------------------
.../src/main/java/org/apache/flink/yarn/FlinkYarnCluster.java | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/e30bee83/flink-yarn/src/main/java/org/apache/flink/yarn/FlinkYarnCluster.java
----------------------------------------------------------------------
diff --git a/flink-yarn/src/main/java/org/apache/flink/yarn/FlinkYarnCluster.java b/flink-yarn/src/main/java/org/apache/flink/yarn/FlinkYarnCluster.java
index 2d7e213..418b684 100644
--- a/flink-yarn/src/main/java/org/apache/flink/yarn/FlinkYarnCluster.java
+++ b/flink-yarn/src/main/java/org/apache/flink/yarn/FlinkYarnCluster.java
@@ -320,11 +320,13 @@ public class FlinkYarnCluster extends AbstractFlinkYarnCluster {
if(!isConnected) {
throw new IllegalStateException("The cluster has been connected to the ApplicationMaster.");
}
+ ApplicationReport lastReport = null;
if(pollingRunner == null) {
LOG.warn("FlinkYarnCluster.hasFailed() has been called on an uninitialized cluster." +
"The system might be in an erroneous state");
+ } else {
+ lastReport = pollingRunner.getLastReport();
}
- ApplicationReport lastReport = pollingRunner.getLastReport();
if(lastReport == null) {
LOG.warn("FlinkYarnCluster.hasFailed() has been called on a cluster that didn't receive a status so far." +
"The system might be in an erroneous state");