You are viewing a plain text version of this content. The canonical link for it is here.
Posted to common-commits@hadoop.apache.org by jh...@apache.org on 2019/09/09 02:25:11 UTC
[hadoop] branch branch-3.1 updated: YARN-9764. Print application
submission context label in application summary. Contributed by Manoj Kumar
This is an automated email from the ASF dual-hosted git repository.
jhung pushed a commit to branch branch-3.1
in repository https://gitbox.apache.org/repos/asf/hadoop.git
The following commit(s) were added to refs/heads/branch-3.1 by this push:
new 080fc6d YARN-9764. Print application submission context label in application summary. Contributed by Manoj Kumar
080fc6d is described below
commit 080fc6d9432aca12a57c839fe6624b65eb5c3362
Author: Jonathan Hung <jh...@linkedin.com>
AuthorDate: Sun Sep 8 19:07:05 2019 -0700
YARN-9764. Print application submission context label in application summary. Contributed by Manoj Kumar
(cherry picked from commit 43e389b9801e09741fdf78fef067b8ac60f691c8)
(cherry picked from commit 45220d115797663b8749980b78a61bafcb2344f1)
---
.../apache/hadoop/yarn/server/resourcemanager/RMAppManager.java | 9 ++++++++-
.../hadoop/yarn/server/resourcemanager/TestAppManager.java | 4 ++++
2 files changed, 12 insertions(+), 1 deletion(-)
diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/RMAppManager.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/RMAppManager.java
index 8bc9dc7..def565c 100644
--- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/RMAppManager.java
+++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/RMAppManager.java
@@ -207,7 +207,14 @@ public class RMAppManager implements EventHandler<RMAppManagerEvent>,
metrics.getPreemptedResourceSecondsMap()))
.add("applicationTags", StringHelper.CSV_JOINER.join(
app.getApplicationTags() != null ? new TreeSet<>(
- app.getApplicationTags()) : Collections.<String>emptySet()));
+ app.getApplicationTags()) : Collections.<String>emptySet()))
+ .add("applicationNodeLabel",
+ app.getApplicationSubmissionContext().getNodeLabelExpression()
+ == null
+ ? ""
+ : app.getApplicationSubmissionContext()
+ .getNodeLabelExpression());
+
return summary;
}
diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/TestAppManager.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/TestAppManager.java
index d7317af..fcc865a 100644
--- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/TestAppManager.java
+++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/TestAppManager.java
@@ -990,6 +990,9 @@ public class TestAppManager{
@Test (timeout = 30000)
public void testEscapeApplicationSummary() {
RMApp app = mock(RMAppImpl.class);
+ ApplicationSubmissionContext asc = mock(ApplicationSubmissionContext.class);
+ when(asc.getNodeLabelExpression()).thenReturn("test");
+ when(app.getApplicationSubmissionContext()).thenReturn(asc);
when(app.getApplicationId()).thenReturn(
ApplicationId.newInstance(100L, 1));
when(app.getName()).thenReturn("Multiline\n\n\r\rAppName");
@@ -1028,6 +1031,7 @@ public class TestAppManager{
assertTrue(msg.contains("preemptedResources=<memory:1234\\, vCores:56>"));
assertTrue(msg.contains("applicationType=MAPREDUCE"));
assertTrue(msg.contains("applicationTags=tag1\\,tag2"));
+ assertTrue(msg.contains("applicationNodeLabel=test"));
}
@Test
---------------------------------------------------------------------
To unsubscribe, e-mail: common-commits-unsubscribe@hadoop.apache.org
For additional commands, e-mail: common-commits-help@hadoop.apache.org