Repository: flink Updated Branches: refs/heads/release-1.1 6e57e7f46 -> d3d6907b5
[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/d3d6907b Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/d3d6907b Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/d3d6907b Branch: refs/heads/release-1.1 Commit: d3d6907b57a49a2c52e2b6997bfa1792a02ccd05 Parents: 6e57e7f Author: Maximilian Michels <[email protected]> Authored: Tue Nov 1 11:02:39 2016 +0100 Committer: Maximilian Michels <[email protected]> Committed: Thu Nov 3 11:14:32 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/d3d6907b/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) {
