Browse Source

YARN-3085. Application summary should include the application type. Contributed by Rohith

Jason Lowe 10 năm trước cách đây
mục cha
commit
a761bf8726

+ 3 - 0
hadoop-yarn-project/CHANGES.txt

@@ -225,6 +225,9 @@ Release 2.7.0 - UNRELEASED
     YARN-2808. Made YARN CLI list attempt’s finished containers of a running
     application. (Naganarasimha G R via zjshen)
 
+    YARN-3085. Application summary should include the application type (Rohith
+    via jlowe)
+
   OPTIMIZATIONS
 
   BUG FIXES

+ 2 - 1
hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/RMAppManager.java

@@ -172,7 +172,8 @@ public class RMAppManager implements EventHandler<RMAppManagerEvent>,
           .add("vcoreSeconds", metrics.getVcoreSeconds())
           .add("preemptedAMContainers", metrics.getNumAMContainersPreempted())
           .add("preemptedNonAMContainers", metrics.getNumNonAMContainersPreempted())
-          .add("preemptedResources", metrics.getResourcePreempted());
+          .add("preemptedResources", metrics.getResourcePreempted())
+          .add("applicationType", app.getApplicationType());
       return summary;
     }
 

+ 2 - 1
hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/TestAppManager.java

@@ -572,7 +572,7 @@ public class TestAppManager{
     when(app.getUser()).thenReturn("Multiline\n\n\r\rUserName");
     when(app.getQueue()).thenReturn("Multiline\n\n\r\rQueueName");
     when(app.getState()).thenReturn(RMAppState.RUNNING);
-
+    when(app.getApplicationType()).thenReturn("MAPREDUCE");
     RMAppMetrics metrics =
         new RMAppMetrics(Resource.newInstance(1234, 56), 10, 1, 16384, 64);
     when(app.getRMAppMetrics()).thenReturn(metrics);
@@ -593,6 +593,7 @@ public class TestAppManager{
     Assert.assertTrue(msg.contains("preemptedAMContainers=1"));
     Assert.assertTrue(msg.contains("preemptedNonAMContainers=10"));
     Assert.assertTrue(msg.contains("preemptedResources=<memory:1234\\, vCores:56>"));
+    Assert.assertTrue(msg.contains("applicationType=MAPREDUCE"));
  }
 
   private static ResourceScheduler mockResourceScheduler() {