From a285002c8b651b50c54d3660daf4e2a3994e11c4 Mon Sep 17 00:00:00 2001 From: Maximilian Michels Date: Tue, 1 Nov 2016 11:02:39 +0100 Subject: [PATCH] [yarn] fix debug string displayed for failed applications --- .../src/main/java/org/apache/flink/yarn/YarnClusterClient.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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 e620f217c0779..25aca76d69e3d 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 @@ -420,7 +420,7 @@ public void shutdownCluster() { 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" + + "\tyarn logs -applicationId " + appReport.getApplicationId() + "\n" + "(It sometimes takes a few seconds until the logs are aggregated)"); } } catch (Exception e) {