|
@@ -1071,6 +1071,7 @@ public class TestAppManager extends AppManagerTestBase{
|
|
|
when(app.getApplicationType()).thenReturn("MAPREDUCE");
|
|
|
when(app.getSubmitTime()).thenReturn(1000L);
|
|
|
when(app.getLaunchTime()).thenReturn(2000L);
|
|
|
+ when(app.getApplicationTags()).thenReturn(Sets.newHashSet("tag2", "tag1"));
|
|
|
Map<String, Long> resourceSecondsMap = new HashMap<>();
|
|
|
resourceSecondsMap.put(ResourceInformation.MEMORY_MB.getName(), 16384L);
|
|
|
resourceSecondsMap.put(ResourceInformation.VCORES.getName(), 64L);
|
|
@@ -1098,7 +1099,8 @@ public class TestAppManager extends AppManagerTestBase{
|
|
|
assertTrue(msg.contains("preemptedNonAMContainers=10"));
|
|
|
assertTrue(msg.contains("preemptedResources=<memory:1234\\, vCores:56>"));
|
|
|
assertTrue(msg.contains("applicationType=MAPREDUCE"));
|
|
|
- }
|
|
|
+ assertTrue(msg.contains("applicationTags=tag1\\,tag2"));
|
|
|
+ }
|
|
|
|
|
|
@Test
|
|
|
public void testRMAppSubmitWithQueueChanged() throws Exception {
|