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/11/03 10:14:14 UTC
flink git commit: [yarn] fix debug string displayed for failed
applications
Repository: flink
Updated Branches:
refs/heads/master 7d61e1f2f -> bb26c9e1b
[yarn] fix debug string displayed for failed applications
This closes #2745.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/bb26c9e1
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/bb26c9e1
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/bb26c9e1
Branch: refs/heads/master
Commit: bb26c9e1b7ed16c78cf4c3b3ae2d4483c526e5c3
Parents: 7d61e1f
Author: Maximilian Michels <mx...@apache.org>
Authored: Tue Nov 1 11:02:39 2016 +0100
Committer: Maximilian Michels <mx...@apache.org>
Committed: Thu Nov 3 11:10:13 2016 +0100
----------------------------------------------------------------------
.../src/main/java/org/apache/flink/yarn/YarnClusterClient.java | 6 ++++--
1 file changed, 4 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/bb26c9e1/flink-yarn/src/main/java/org/apache/flink/yarn/YarnClusterClient.java
----------------------------------------------------------------------
diff --git a/flink-yarn/src/main/java/org/apache/flink/yarn/YarnClusterClient.java b/flink-yarn/src/main/java/org/apache/flink/yarn/YarnClusterClient.java
index e620f21..cd447d7 100644
--- a/flink-yarn/src/main/java/org/apache/flink/yarn/YarnClusterClient.java
+++ b/flink-yarn/src/main/java/org/apache/flink/yarn/YarnClusterClient.java
@@ -419,8 +419,10 @@ public class YarnClusterClient extends ClusterClient {
== YarnApplicationState.KILLED) {
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:\n"
- + "\tyarn logs -appReport " + appReport.getApplicationId() + "\n"
+ + "the full application log using this command:"
+ + System.lineSeparator()
+ + "\tyarn logs -applicationId " + appReport.getApplicationId()
+ + System.lineSeparator()
+ "(It sometimes takes a few seconds until the logs are aggregated)");
}
} catch (Exception e) {