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 <[email protected]> Authored: Tue Nov 1 11:02:39 2016 +0100 Committer: Maximilian Michels <[email protected]> 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) {
