You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tr...@apache.org on 2018/01/12 22:25:32 UTC
[11/14] flink git commit: [hotfix] Log failure message only if Yarn
application truly failed
[hotfix] Log failure message only if Yarn application truly failed
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/ed0716ac
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/ed0716ac
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/ed0716ac
Branch: refs/heads/master
Commit: ed0716ac710387979735140d18a598240b43085d
Parents: dbe0e82
Author: Till Rohrmann <tr...@apache.org>
Authored: Fri Dec 29 17:08:45 2017 +0100
Committer: Till Rohrmann <tr...@apache.org>
Committed: Fri Jan 12 16:14:06 2018 +0100
----------------------------------------------------------------------
.../main/java/org/apache/flink/yarn/cli/FlinkYarnSessionCli.java | 3 +--
1 file changed, 1 insertion(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/ed0716ac/flink-yarn/src/main/java/org/apache/flink/yarn/cli/FlinkYarnSessionCli.java
----------------------------------------------------------------------
diff --git a/flink-yarn/src/main/java/org/apache/flink/yarn/cli/FlinkYarnSessionCli.java b/flink-yarn/src/main/java/org/apache/flink/yarn/cli/FlinkYarnSessionCli.java
index d4cf9ad..cc7f4c1 100644
--- a/flink-yarn/src/main/java/org/apache/flink/yarn/cli/FlinkYarnSessionCli.java
+++ b/flink-yarn/src/main/java/org/apache/flink/yarn/cli/FlinkYarnSessionCli.java
@@ -686,8 +686,7 @@ public class FlinkYarnSessionCli extends AbstractCustomCommandLine<ApplicationId
.getYarnApplicationState() + " and final state " + appReport
.getFinalApplicationStatus() + " at " + appReport.getFinishTime());
- if (appReport.getYarnApplicationState() == YarnApplicationState.FAILED || appReport.getYarnApplicationState()
- == YarnApplicationState.KILLED) {
+ if (appReport.getYarnApplicationState() == YarnApplicationState.FAILED) {
LOG.warn("Application failed. Diagnostics " + appReport.getDiagnostics());
LOG.warn("If log aggregation is activated in the Hadoop cluster, we recommend to retrieve "
+ "the full application log using this command:"