diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/placement/TestAppNameMappingPlacementRule.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/placement/TestAppNameMappingPlacementRule.java
index 3665dd037ec044..4cdbf150cb9a95 100644
--- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/placement/TestAppNameMappingPlacementRule.java
+++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/placement/TestAppNameMappingPlacementRule.java
@@ -30,14 +30,14 @@
import org.apache.hadoop.yarn.server.resourcemanager.scheduler.capacity.CapacitySchedulerQueueManager;
import org.apache.hadoop.yarn.server.resourcemanager.scheduler.fair.SimpleGroupsMapping;
import org.apache.hadoop.yarn.util.Records;
-import org.junit.Assert;
-import org.junit.Before;
-import org.junit.Test;
+import org.junit.jupiter.api.BeforeEach;
+import org.junit.jupiter.api.Test;
import java.io.IOException;
import java.util.Collections;
import static org.apache.hadoop.yarn.server.resourcemanager.placement.FairQueuePlacementUtils.DOT;
+import static org.junit.jupiter.api.Assertions.assertEquals;
import static org.mockito.ArgumentMatchers.isNull;
import static org.mockito.Mockito.mock;
import static org.mockito.Mockito.when;
@@ -55,7 +55,7 @@ public class TestAppNameMappingPlacementRule {
private YarnConfiguration conf = new YarnConfiguration();
- @Before
+ @BeforeEach
public void setup() {
conf.setClass(CommonConfigurationKeys.HADOOP_SECURITY_GROUP_MAPPING,
SimpleGroupsMapping.class, GroupMappingServiceProvider.class);
@@ -108,7 +108,7 @@ private void verifyQueueMapping(QueueMapping queueMapping,
asc.setApplicationName(appName);
ApplicationPlacementContext ctx = engine.getPlacementForApp(asc,
user);
- Assert.assertEquals(expectedQueue,
+ assertEquals(expectedQueue,
ctx != null ? ctx.getQueue() : inputQueue);
}
diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/placement/TestFairQueuePlacementUtils.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/placement/TestFairQueuePlacementUtils.java
index 506746add80f38..8b94bd7a13356e 100644
--- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/placement/TestFairQueuePlacementUtils.java
+++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/placement/TestFairQueuePlacementUtils.java
@@ -18,7 +18,7 @@
package org.apache.hadoop.yarn.server.resourcemanager.placement;
-import org.junit.Test;
+import org.junit.jupiter.api.Test;
import static org.apache.hadoop.yarn.server.resourcemanager.placement.FairQueuePlacementUtils.DOT;
import static org.apache.hadoop.yarn.server.resourcemanager.placement.FairQueuePlacementUtils.DOT_REPLACEMENT;
@@ -26,11 +26,11 @@
import static org.apache.hadoop.yarn.server.resourcemanager.placement.FairQueuePlacementUtils.assureRoot;
import static org.apache.hadoop.yarn.server.resourcemanager.placement.FairQueuePlacementUtils.cleanName;
import static org.apache.hadoop.yarn.server.resourcemanager.placement.FairQueuePlacementUtils.isValidQueueName;
-import static org.junit.Assert.assertEquals;
-import static org.junit.Assert.assertFalse;
-import static org.junit.Assert.assertNotEquals;
-import static org.junit.Assert.assertNull;
-import static org.junit.Assert.assertTrue;
+import static org.junit.jupiter.api.Assertions.assertEquals;
+import static org.junit.jupiter.api.Assertions.assertFalse;
+import static org.junit.jupiter.api.Assertions.assertNotEquals;
+import static org.junit.jupiter.api.Assertions.assertNull;
+import static org.junit.jupiter.api.Assertions.assertTrue;
/**
* Tests of the utility methods from {@link FairQueuePlacementUtils}.
@@ -50,27 +50,27 @@ public void testCleanName() {
final String unTrimmed = " .invalid. "; // not really a valid queue
String cleaned = cleanName(clean);
- assertEquals("Name was changed and it should not", clean, cleaned);
+ assertEquals(clean, cleaned, "Name was changed and it should not");
cleaned = cleanName(dotted);
- assertFalse("Cleaned name contains dots and it should not",
- cleaned.contains(DOT));
+ assertFalse(cleaned.contains(DOT),
+ "Cleaned name contains dots and it should not");
cleaned = cleanName(multiDot);
- assertFalse("Cleaned name contains dots and it should not",
- cleaned.contains(DOT));
- assertNotEquals("Multi dot failed: wrong replacements found",
- cleaned.indexOf(DOT_REPLACEMENT),
- cleaned.lastIndexOf(DOT_REPLACEMENT));
+ assertFalse(cleaned.contains(DOT),
+ "Cleaned name contains dots and it should not");
+ assertNotEquals(cleaned.indexOf(DOT_REPLACEMENT),
+ cleaned.lastIndexOf(DOT_REPLACEMENT),
+ "Multi dot failed: wrong replacements found");
cleaned = cleanName(seqDot);
- assertFalse("Cleaned name contains dots and it should not",
- cleaned.contains(DOT));
- assertNotEquals("Sequential dot failed: wrong replacements found",
- cleaned.indexOf(DOT_REPLACEMENT),
- cleaned.lastIndexOf(DOT_REPLACEMENT));
+ assertFalse(cleaned.contains(DOT),
+ "Cleaned name contains dots and it should not");
+ assertNotEquals(cleaned.indexOf(DOT_REPLACEMENT),
+ cleaned.lastIndexOf(DOT_REPLACEMENT),
+ "Sequential dot failed: wrong replacements found");
cleaned = cleanName(unTrimmed);
- assertTrue("Trimming start failed: space not removed or dot not replaced",
- cleaned.startsWith(DOT_REPLACEMENT));
- assertTrue("Trimming end failed: space not removed or dot not replaced",
- cleaned.endsWith(DOT_REPLACEMENT));
+ assertTrue(cleaned.startsWith(DOT_REPLACEMENT),
+ "Trimming start failed: space not removed or dot not replaced");
+ assertTrue(cleaned.endsWith(DOT_REPLACEMENT),
+ "Trimming end failed: space not removed or dot not replaced");
}
@Test
@@ -82,23 +82,22 @@ public void testAssureRoot() {
final String alreadyRoot = "root.base";
String rooted = assureRoot(queueName);
- assertTrue("Queue should have root prefix (base)",
- rooted.startsWith(ROOT_QUEUE + DOT));
+ assertTrue(rooted.startsWith(ROOT_QUEUE + DOT),
+ "Queue should have root prefix (base)");
rooted = assureRoot(rootOnly);
- assertEquals("'root' queue should not have root prefix (root)",
- rootOnly, rooted);
+ assertEquals(rootOnly, rooted,
+ "'root' queue should not have root prefix (root)");
rooted = assureRoot(rootNoDot);
- assertTrue("Queue should have root prefix (rootbase)",
- rooted.startsWith(ROOT_QUEUE + DOT));
- assertEquals("'root' queue base was replaced and not prefixed", 5,
- rooted.lastIndexOf(ROOT_QUEUE));
+ assertTrue(rooted.startsWith(ROOT_QUEUE + DOT),
+ "Queue should have root prefix (rootbase)");
+ assertEquals(5, rooted.lastIndexOf(ROOT_QUEUE),
+ "'root' queue base was replaced and not prefixed");
rooted = assureRoot(alreadyRoot);
- assertEquals("Root prefixed queue changed and it should not (root.base)",
- rooted, alreadyRoot);
- assertNull("Null queue did not return null queue",
- assureRoot(null));
- assertEquals("Empty queue did not return empty name", "",
- assureRoot(""));
+ assertEquals(rooted, alreadyRoot,
+ "Root prefixed queue changed and it should not (root.base)");
+ assertNull(assureRoot(null), "Null queue did not return null queue");
+ assertEquals("", assureRoot(""),
+ "Empty queue did not return empty name");
}
@Test
@@ -113,25 +112,24 @@ public void testIsValidQueueName() {
final String endSpace = "invalid ";
final String unicodeSpace = "\u00A0invalid";
- assertFalse("'null' queue was not marked as invalid",
- isValidQueueName(null));
- assertTrue("empty queue was not tagged valid", isValidQueueName(""));
- assertTrue("Simple queue name was not tagged valid (valid)",
- isValidQueueName(valid));
- assertTrue("Root only queue was not tagged valid (root)",
- isValidQueueName(rootOnly));
- assertTrue("Root prefixed queue was not tagged valid (root.valid)",
- isValidQueueName(validRooted));
- assertFalse("Queue starting with dot was not tagged invalid (.invalid)",
- isValidQueueName(startDot));
- assertFalse("Queue ending with dot was not tagged invalid (invalid.)",
- isValidQueueName(endDot));
- assertFalse("Queue starting with space was not tagged invalid ( invalid)",
- isValidQueueName(startSpace));
- assertFalse("Queue ending with space was not tagged invalid (invalid )",
- isValidQueueName(endSpace));
+ assertFalse(isValidQueueName(null), "'null' queue was not marked as invalid");
+ assertTrue(isValidQueueName(""), "empty queue was not tagged valid");
+ assertTrue(isValidQueueName(valid),
+ "Simple queue name was not tagged valid (valid)");
+ assertTrue(isValidQueueName(rootOnly),
+ "Root only queue was not tagged valid (root)");
+ assertTrue(isValidQueueName(validRooted),
+ "Root prefixed queue was not tagged valid (root.valid)");
+ assertFalse(isValidQueueName(startDot),
+ "Queue starting with dot was not tagged invalid (.invalid)");
+ assertFalse(isValidQueueName(endDot),
+ "Queue ending with dot was not tagged invalid (invalid.)");
+ assertFalse(isValidQueueName(startSpace),
+ "Queue starting with space was not tagged invalid ( invalid)");
+ assertFalse(isValidQueueName(endSpace),
+ "Queue ending with space was not tagged invalid (invalid )");
// just one for sanity check extensive tests are in the scheduler utils
- assertFalse("Queue with unicode space was not tagged as invalid (unicode)",
- isValidQueueName(unicodeSpace));
+ assertFalse(isValidQueueName(unicodeSpace),
+ "Queue with unicode space was not tagged as invalid (unicode)");
}
}
\ No newline at end of file
diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/placement/TestPlacementFactory.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/placement/TestPlacementFactory.java
index f4d1733008924b..90fa481d2c465a 100644
--- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/placement/TestPlacementFactory.java
+++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/placement/TestPlacementFactory.java
@@ -18,11 +18,12 @@
package org.apache.hadoop.yarn.server.resourcemanager.placement;
-import org.junit.Test;
+import org.junit.jupiter.api.Test;
-import static org.junit.Assert.assertEquals;
-import static org.junit.Assert.assertNotNull;
-import static org.junit.Assert.fail;
+import static org.junit.jupiter.api.Assertions.assertEquals;
+import static org.junit.jupiter.api.Assertions.assertNotNull;
+import static org.junit.jupiter.api.Assertions.assertThrows;
+import static org.junit.jupiter.api.Assertions.fail;
/**
* Test for the {@link PlacementFactory}.
@@ -34,10 +35,12 @@ public class TestPlacementFactory {
*
* @throws ClassNotFoundException
*/
- @Test(expected = ClassNotFoundException.class)
+ @Test
public void testGetNonExistRuleText() throws ClassNotFoundException {
- final String nonExist = "my.placement.Rule";
- PlacementFactory.getPlacementRule(nonExist, null);
+ assertThrows(ClassNotFoundException.class, ()->{
+ final String nonExist = "my.placement.Rule";
+ PlacementFactory.getPlacementRule(nonExist, null);
+ });
}
/**
@@ -53,8 +56,8 @@ public void testGetExistRuleText() {
} catch (ClassNotFoundException cnfe) {
fail("Class should have been found");
}
- assertNotNull("Rule object is null", rule);
- assertEquals("Names not equal", rule.getName(), exists);
+ assertNotNull(rule, "Rule object is null");
+ assertEquals(rule.getName(), exists, "Names not equal");
}
/**
@@ -65,11 +68,11 @@ public void testGetExistRuleText() {
public void testGetRuleClass() {
PlacementRule rule = PlacementFactory.getPlacementRule(
DefaultPlacementRule.class, null);
- assertNotNull("Rule object is null", rule);
+ assertNotNull(rule, "Rule object is null");
// Should take anything as the second object: ignores unknown types in the
// default implementation.
rule = PlacementFactory.getPlacementRule(
DefaultPlacementRule.class, "");
- assertNotNull("Rule object is null", rule);
+ assertNotNull(rule, "Rule object is null");
}
}
diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/placement/TestPlacementManager.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/placement/TestPlacementManager.java
index e27c4ec532171b..4f286edf24f06f 100644
--- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/placement/TestPlacementManager.java
+++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/placement/TestPlacementManager.java
@@ -28,16 +28,18 @@
import org.apache.hadoop.yarn.server.resourcemanager.scheduler.capacity.CapacityScheduler;
import org.apache.hadoop.yarn.server.resourcemanager.scheduler.capacity.CapacitySchedulerConfiguration;
import org.apache.hadoop.yarn.util.Records;
-import org.junit.After;
-import org.junit.Assert;
-import org.junit.Before;
-import org.junit.Test;
+import org.junit.jupiter.api.AfterEach;
+import org.junit.jupiter.api.BeforeEach;
+import org.junit.jupiter.api.Test;
import java.util.ArrayList;
import java.util.List;
import static org.apache.hadoop.yarn.server.resourcemanager.scheduler.capacity.CapacitySchedulerConfiguration.DOT;
import static org.apache.hadoop.yarn.server.resourcemanager.scheduler.capacity.TestCapacitySchedulerAutoCreatedQueueBase.setupQueueConfiguration;
+import static org.junit.jupiter.api.Assertions.assertEquals;
+import static org.junit.jupiter.api.Assertions.assertNotNull;
+import static org.junit.jupiter.api.Assertions.assertNull;
public class TestPlacementManager {
@@ -56,7 +58,7 @@ private String getQueueMapping(String parentQueue, String leafQueue) {
return parentQueue + DOT + leafQueue;
}
- @Before
+ @BeforeEach
public void setup() {
conf = new CapacitySchedulerConfiguration();
setupQueueConfiguration(conf);
@@ -96,8 +98,7 @@ public void testPlaceApplicationWithPlacementRuleChain() throws Exception {
asc.setQueue(YarnConfiguration.DEFAULT_QUEUE_NAME);
asc.setApplicationName(APP_NAME);
- Assert.assertNull("Placement should be null",
- pm.placeApplication(asc, USER2));
+ assertNull(pm.placeApplication(asc, USER2), "Placement should be null");
QueueMapping queueMappingEntity = QueueMapping.QueueMappingBuilder.create()
.type(MappingType.APPLICATION)
.source(APP_NAME)
@@ -112,7 +113,7 @@ public void testPlaceApplicationWithPlacementRuleChain() throws Exception {
queuePlacementRules.add(anRule);
pm.updateRules(queuePlacementRules);
ApplicationPlacementContext pc = pm.placeApplication(asc, USER2);
- Assert.assertNotNull(pc);
+ assertNotNull(pc);
}
@Test
@@ -135,13 +136,13 @@ public void testPlacementRuleUpdationOrder() throws Exception {
// As we are setting placement rule, It shouldn't update default
// placement rule ie user-group. Number of placement rules should be 1.
- Assert.assertEquals(1, pm.getPlacementRules().size());
+ assertEquals(1, pm.getPlacementRules().size());
// Verifying if placement rule set is same as the one we configured
- Assert.assertEquals(ugRule.getName(),
+ assertEquals(ugRule.getName(),
pm.getPlacementRules().get(0).getName());
}
- @After
+ @AfterEach
public void tearDown() {
if (null != mockRM) {
mockRM.stop();
diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/placement/TestPlacementRuleFS.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/placement/TestPlacementRuleFS.java
index 1c7e5fa513175b..0e8bd594691be7 100644
--- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/placement/TestPlacementRuleFS.java
+++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/placement/TestPlacementRuleFS.java
@@ -23,9 +23,9 @@
import org.apache.hadoop.yarn.server.resourcemanager.scheduler.fair.FairScheduler;
import org.apache.hadoop.yarn.server.resourcemanager.scheduler.fair.FairSchedulerConfiguration;
import org.apache.hadoop.yarn.server.resourcemanager.scheduler.fair.QueueManager;
-import org.junit.After;
-import org.junit.Before;
-import org.junit.Test;
+import org.junit.jupiter.api.AfterEach;
+import org.junit.jupiter.api.BeforeEach;
+import org.junit.jupiter.api.Test;
import org.w3c.dom.Document;
import org.w3c.dom.Element;
@@ -37,10 +37,10 @@
import java.util.List;
import static org.apache.hadoop.yarn.server.resourcemanager.placement.PlacementFactory.getPlacementRule;
-import static org.junit.Assert.assertFalse;
-import static org.junit.Assert.assertNotNull;
-import static org.junit.Assert.assertTrue;
-import static org.junit.Assert.fail;
+import static org.junit.jupiter.api.Assertions.assertFalse;
+import static org.junit.jupiter.api.Assertions.assertNotNull;
+import static org.junit.jupiter.api.Assertions.assertTrue;
+import static org.junit.jupiter.api.Assertions.fail;
import static org.mockito.Mockito.mock;
import static org.mockito.Mockito.when;
@@ -75,7 +75,7 @@ public class TestPlacementRuleFS {
private QueueManager queueManager;
- @Before
+ @BeforeEach
public void initTest() {
scheduler = mock(FairScheduler.class);
// needed for all rules that rely on group info
@@ -85,7 +85,7 @@ public void initTest() {
when(scheduler.getQueueManager()).thenReturn(queueManager);
}
- @After
+ @AfterEach
public void cleanTest() {
queueManager = null;
scheduler = null;
@@ -126,26 +126,26 @@ public void testRuleInitOnly() {
private void ruleCreateNoConfig(Class extends PlacementRule> ruleClass) {
PlacementRule rule = getPlacementRule(ruleClass, null);
String name = ruleClass.getName();
- assertNotNull("Rule object should not be null for " + name, rule);
+ assertNotNull(rule, "Rule object should not be null for " + name);
}
private void ruleCreateWrongObject(
Class extends PlacementRule> ruleClass) {
PlacementRule rule = getPlacementRule(ruleClass, "a string object");
String name = ruleClass.getName();
- assertNotNull("Rule object should not be null for " + name, rule);
+ assertNotNull(rule, "Rule object should not be null for " + name);
}
private void ruleCreateBoolean(Class extends PlacementRule> ruleClass) {
PlacementRule rule = getPlacementRule(ruleClass, true);
String name = ruleClass.getName();
- assertNotNull("Rule object should not be null for " + name, rule);
- assertTrue("Create flag was not set to true on " + name,
- getCreateFlag(rule));
+ assertNotNull(rule, "Rule object should not be null for " + name);
+ assertTrue(getCreateFlag(rule),
+ "Create flag was not set to true on " + name);
rule = getPlacementRule(ruleClass, false);
- assertNotNull("Rule object should not be null for " + name, rule);
- assertFalse("Create flag was not set to false on " + name,
- getCreateFlag(rule));
+ assertNotNull(rule, "Rule object should not be null for " + name);
+ assertFalse(getCreateFlag(rule),
+ "Create flag was not set to false on " + name);
}
private void ruleCreateElement(Class extends PlacementRule> ruleClass) {
@@ -153,21 +153,21 @@ private void ruleCreateElement(Class extends PlacementRule> ruleClass) {
Element conf = createConf(str);
PlacementRule rule = getPlacementRule(ruleClass, conf);
String name = ruleClass.getName();
- assertNotNull("Rule object should not be null for " + name, rule);
- assertTrue("Create flag was not set to true on " + name,
- getCreateFlag(rule));
+ assertNotNull(rule, "Rule object should not be null for " + name);
+ assertTrue(getCreateFlag(rule),
+ "Create flag was not set to true on " + name);
str = "";
conf = createConf(str);
rule = getPlacementRule(ruleClass, conf);
- assertNotNull("Rule object should not be null for " + name, rule);
- assertFalse("Create flag was not set to false on " + name,
- getCreateFlag(rule));
+ assertNotNull(rule, "Rule object should not be null for " + name);
+ assertFalse(getCreateFlag(rule),
+ "Create flag was not set to false on " + name);
}
private void ruleInit(Class extends PlacementRule> ruleClass) {
PlacementRule rule = getPlacementRule(ruleClass, null);
String name = ruleClass.getName();
- assertNotNull("Rule object should not be null for " + name, rule);
+ assertNotNull(rule, "Rule object should not be null for " + name);
try {
rule.initialize(scheduler);
} catch (IOException ioe) {
@@ -183,8 +183,8 @@ private void ruleInit(Class extends PlacementRule> ruleClass) {
} catch (IOException ioe) {
exceptionThrown = true;
}
- assertTrue("Initialize with parent rule should have thrown exception " +
- name, exceptionThrown);
+ assertTrue(exceptionThrown,
+ "Initialize with parent rule should have thrown exception " + name);
}
private Element createConf(String str) {
diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/placement/TestUserGroupMappingPlacementRule.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/placement/TestUserGroupMappingPlacementRule.java
index 84a3e6c34aa3cf..6998134d83efa2 100644
--- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/placement/TestUserGroupMappingPlacementRule.java
+++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/placement/TestUserGroupMappingPlacementRule.java
@@ -18,6 +18,7 @@
package org.apache.hadoop.yarn.server.resourcemanager.placement;
+import static org.junit.jupiter.api.Assertions.assertEquals;
import static org.mockito.Mockito.mock;
import static org.mockito.Mockito.when;
import static org.mockito.Mockito.isNull;
@@ -42,14 +43,13 @@
import org.apache.hadoop.yarn.server.resourcemanager.scheduler.fair.PrimaryGroupMapping;
import org.apache.hadoop.yarn.server.resourcemanager.scheduler.fair.SimpleGroupsMapping;
import org.apache.hadoop.yarn.util.Records;
-import org.junit.Assert;
-import org.junit.Before;
-import org.junit.Test;
+import org.junit.jupiter.api.BeforeEach;
+import org.junit.jupiter.api.Test;
public class TestUserGroupMappingPlacementRule {
private final YarnConfiguration conf = new YarnConfiguration();
- @Before
+ @BeforeEach
public void setup() {
conf.setClass(CommonConfigurationKeys.HADOOP_SECURITY_GROUP_MAPPING,
SimpleGroupsMapping.class, GroupMappingServiceProvider.class);
@@ -94,11 +94,11 @@ private void verifyQueueMapping(QueueMappingTestData queueMappingTestData)
ApplicationSubmissionContext.class);
asc.setQueue(inputQueue);
ApplicationPlacementContext ctx = engine.getPlacementForApp(asc, inputUser);
- Assert.assertEquals("Queue", expectedQueue,
- ctx != null ? ctx.getQueue() : inputQueue);
+ assertEquals(expectedQueue,
+ ctx != null ? ctx.getQueue() : inputQueue, "Queue");
if (ctx != null && expectedParentQueue != null) {
- Assert.assertEquals("Parent Queue", expectedParentQueue,
- ctx.getParentQueue());
+ assertEquals(expectedParentQueue,
+ ctx.getParentQueue(), "Parent Queue");
}
}
diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/placement/csmappingrule/TestCSMappingPlacementRule.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/placement/csmappingrule/TestCSMappingPlacementRule.java
index 41ce2b56eab208..d2da49001766e3 100644
--- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/placement/csmappingrule/TestCSMappingPlacementRule.java
+++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/placement/csmappingrule/TestCSMappingPlacementRule.java
@@ -33,9 +33,8 @@
import org.apache.hadoop.yarn.server.resourcemanager.scheduler.capacity.CapacitySchedulerConfiguration;
import org.apache.hadoop.yarn.server.resourcemanager.scheduler.capacity.CapacitySchedulerQueueManager;
import org.apache.hadoop.yarn.util.Records;
-import org.junit.Rule;
-import org.junit.Test;
-import org.junit.rules.TemporaryFolder;
+import org.junit.jupiter.api.Test;
+import org.junit.jupiter.api.io.TempDir;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -43,17 +42,19 @@
import java.io.File;
import java.io.FileWriter;
import java.io.IOException;
+import java.nio.file.Path;
import java.util.ArrayList;
import java.util.List;
import java.util.Map;
import java.util.Set;
-import static junit.framework.TestCase.assertEquals;
-import static junit.framework.TestCase.assertNotNull;
-import static junit.framework.TestCase.assertNull;
-import static junit.framework.TestCase.assertTrue;
-import static junit.framework.TestCase.fail;
import static org.apache.hadoop.fs.CommonConfigurationKeysPublic.HADOOP_SECURITY_GROUP_MAPPING;
+import static org.junit.jupiter.api.Assertions.assertEquals;
+import static org.junit.jupiter.api.Assertions.assertNotNull;
+import static org.junit.jupiter.api.Assertions.assertNull;
+import static org.junit.jupiter.api.Assertions.assertThrows;
+import static org.junit.jupiter.api.Assertions.assertTrue;
+import static org.junit.jupiter.api.Assertions.fail;
import static org.mockito.ArgumentMatchers.isNull;
import static org.mockito.Mockito.mock;
import static org.mockito.Mockito.when;
@@ -63,8 +64,8 @@ public class TestCSMappingPlacementRule {
private static final Logger LOG = LoggerFactory
.getLogger(TestCSMappingPlacementRule.class);
- @Rule
- public TemporaryFolder folder = new TemporaryFolder();
+ @TempDir
+ private Path folder;
private Map> userGroups =
ImmutableMap.>builder()
@@ -185,11 +186,11 @@ private void assertPlace(String message, CSMappingPlacementRule engine,
ApplicationSubmissionContext asc, String user, String expectedQueue) {
try {
ApplicationPlacementContext apc = engine.getPlacementForApp(asc, user);
- assertNotNull(message, apc);
+ assertNotNull(apc, message);
String queue = apc.getParentQueue() == null ? "" :
(apc.getParentQueue() + DOT);
queue += apc.getQueue();
- assertEquals(message, expectedQueue, queue);
+ assertEquals(expectedQueue, queue, message);
} catch (YarnException e) {
LOG.error(message, e);
fail(message);
@@ -199,7 +200,7 @@ private void assertPlace(String message, CSMappingPlacementRule engine,
private void assertNullResult(String message, CSMappingPlacementRule engine,
ApplicationSubmissionContext asc, String user) {
try {
- assertNull(message, engine.getPlacementForApp(asc, user));
+ assertNull(engine.getPlacementForApp(asc, user), message);
} catch (YarnException e) {
LOG.error(message, e);
fail(message);
@@ -628,15 +629,14 @@ public void testSecondaryGroupWithParent() throws IOException {
void assertConfigTestResult(List rules) {
- assertEquals("We only specified one rule", 1, rules.size());
+ assertEquals(1, rules.size(), "We only specified one rule");
MappingRule rule = rules.get(0);
String ruleStr = rule.toString();
- assertTrue("Rule's matcher variable should be %user",
- ruleStr.contains("variable='%user'"));
- assertTrue("Rule's match value should be bob",
- ruleStr.contains("value='bob'"));
- assertTrue("Rule's action should be place to queue", ruleStr.contains(
- "action=PlaceToQueueAction{queueName='%primary_group'"));
+ assertTrue(ruleStr.contains("variable='%user'"),
+ "Rule's matcher variable should be %user");
+ assertTrue(ruleStr.contains("value='bob'"), "Rule's match value should be bob");
+ assertTrue(ruleStr.contains("action=PlaceToQueueAction{queueName='%primary_group'"),
+ "Rule's action should be place to queue");
}
@Test
@@ -677,27 +677,31 @@ public void testEmptyJSONConfiguration() throws IOException {
conf.set(CapacitySchedulerConfiguration.MAPPING_RULE_JSON, "");
List rules = conf.getMappingRules();
- assertEquals("We expect no rules", 0, rules.size());
+ assertEquals(0, rules.size(), "We expect no rules");
}
- @Test(expected = IOException.class)
+ @Test
public void testInvalidJSONConfiguration() throws IOException {
- CapacitySchedulerConfiguration conf = new CapacitySchedulerConfiguration();
- conf.set(CapacitySchedulerConfiguration.MAPPING_RULE_FORMAT,
- CapacitySchedulerConfiguration.MAPPING_RULE_FORMAT_JSON);
- conf.set(CapacitySchedulerConfiguration.MAPPING_RULE_JSON,
- "I'm a bad JSON, since I'm not a JSON.");
- List rules = conf.getMappingRules();
+ assertThrows(IOException.class, ()->{
+ CapacitySchedulerConfiguration conf = new CapacitySchedulerConfiguration();
+ conf.set(CapacitySchedulerConfiguration.MAPPING_RULE_FORMAT,
+ CapacitySchedulerConfiguration.MAPPING_RULE_FORMAT_JSON);
+ conf.set(CapacitySchedulerConfiguration.MAPPING_RULE_JSON,
+ "I'm a bad JSON, since I'm not a JSON.");
+ List rules = conf.getMappingRules();
+ });
}
- @Test(expected = IOException.class)
+ @Test
public void testMissingJSONFileConfiguration() throws IOException {
- CapacitySchedulerConfiguration conf = new CapacitySchedulerConfiguration();
- conf.set(CapacitySchedulerConfiguration.MAPPING_RULE_FORMAT,
- CapacitySchedulerConfiguration.MAPPING_RULE_FORMAT_JSON);
- conf.set(CapacitySchedulerConfiguration.MAPPING_RULE_JSON_FILE,
- "/dev/null/nofile");
- List rules = conf.getMappingRules();
+ assertThrows(IOException.class, ()->{
+ CapacitySchedulerConfiguration conf = new CapacitySchedulerConfiguration();
+ conf.set(CapacitySchedulerConfiguration.MAPPING_RULE_FORMAT,
+ CapacitySchedulerConfiguration.MAPPING_RULE_FORMAT_JSON);
+ conf.set(CapacitySchedulerConfiguration.MAPPING_RULE_JSON_FILE,
+ "/dev/null/nofile");
+ List rules = conf.getMappingRules();
+ });
}
@Test
@@ -706,7 +710,7 @@ public void testJSONFileConfiguration() throws IOException {
conf.set(CapacitySchedulerConfiguration.MAPPING_RULE_FORMAT,
CapacitySchedulerConfiguration.MAPPING_RULE_FORMAT_JSON);
- File jsonFile = folder.newFile("testJSONFileConfiguration.json");
+ File jsonFile = folder.resolve("testJSONFileConfiguration.json").toFile();
BufferedWriter writer = new BufferedWriter(new FileWriter(jsonFile));
try {
diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/placement/csmappingrule/TestMappingRule.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/placement/csmappingrule/TestMappingRule.java
index 5421f476419628..29966fdb7ec4ad 100644
--- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/placement/csmappingrule/TestMappingRule.java
+++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/placement/csmappingrule/TestMappingRule.java
@@ -18,13 +18,13 @@
package org.apache.hadoop.yarn.server.resourcemanager.placement.csmappingrule;
-import static org.junit.Assert.assertEquals;
-import static org.junit.Assert.assertTrue;
+import static org.junit.jupiter.api.Assertions.assertEquals;
+import static org.junit.jupiter.api.Assertions.assertTrue;
import org.apache.hadoop.util.Sets;
import org.apache.hadoop.util.StringUtils;
import org.apache.hadoop.yarn.server.resourcemanager.placement.VariableContext;
-import org.junit.Test;
+import org.junit.jupiter.api.Test;
public class TestMappingRule {
VariableContext setupVariables(
diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/placement/csmappingrule/TestMappingRuleActions.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/placement/csmappingrule/TestMappingRuleActions.java
index 9224e673325dcb..ed7d7b1019ebed 100644
--- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/placement/csmappingrule/TestMappingRuleActions.java
+++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/placement/csmappingrule/TestMappingRuleActions.java
@@ -18,9 +18,12 @@
package org.apache.hadoop.yarn.server.resourcemanager.placement.csmappingrule;
import org.apache.hadoop.yarn.server.resourcemanager.placement.VariableContext;
-import org.junit.Test;
+import org.junit.jupiter.api.Test;
-import static org.junit.Assert.*;
+import static org.junit.jupiter.api.Assertions.assertEquals;
+import static org.junit.jupiter.api.Assertions.assertSame;
+import static org.junit.jupiter.api.Assertions.assertTrue;
+import static org.junit.jupiter.api.Assertions.fail;
public class TestMappingRuleActions {
void assertRejectResult(MappingRuleResult result) {
diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/placement/csmappingrule/TestMappingRuleMatchers.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/placement/csmappingrule/TestMappingRuleMatchers.java
index d245051600b222..eba4b88649d13a 100644
--- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/placement/csmappingrule/TestMappingRuleMatchers.java
+++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/placement/csmappingrule/TestMappingRuleMatchers.java
@@ -18,15 +18,17 @@
package org.apache.hadoop.yarn.server.resourcemanager.placement.csmappingrule;
-import junit.framework.TestCase;
+import static org.junit.jupiter.api.Assertions.assertEquals;
+import static org.junit.jupiter.api.Assertions.assertFalse;
+import static org.junit.jupiter.api.Assertions.assertTrue;
import org.apache.hadoop.util.Sets;
import org.apache.hadoop.yarn.server.resourcemanager.placement.VariableContext;
-import org.junit.Test;
+import org.junit.jupiter.api.Test;
import java.util.HashMap;
import java.util.Map;
-public class TestMappingRuleMatchers extends TestCase {
+public class TestMappingRuleMatchers {
@Test
public void testCatchAll() {
@@ -64,12 +66,12 @@ public void testVariableMatcher() {
new MappingRuleMatchers.VariableMatcher("%custom", "Matching string"));
matchers.forEach((matcherName, matcher) -> {
- assertTrue(matcherName + " with matchingContext should match",
- matcher.match(matchingContext));
- assertFalse(matcherName + " with mismatchingContext shouldn't match",
- matcher.match(mismatchingContext));
- assertFalse(matcherName + " with emptyContext shouldn't match",
- matcher.match(emptyContext));
+ assertTrue(matcher.match(matchingContext),
+ matcherName + " with matchingContext should match");
+ assertFalse(matcher.match(mismatchingContext),
+ matcherName + " with mismatchingContext shouldn't match");
+ assertFalse(matcher.match(emptyContext),
+ matcherName + " with emptyContext shouldn't match");
});
}
@@ -106,31 +108,27 @@ public void testVariableMatcherSubstitutions() {
MappingRuleMatcher userStatic =
new MappingRuleMatchers.VariableMatcher("%user", "bob");
- assertTrue("%custom should match %user in matching context",
- customUser.match(matchingContext));
- assertTrue("%user should match %custom in matching context",
- userCustom.match(matchingContext));
- assertTrue("%user (bob) should match %cus%tom (b + ob) in matching context",
- userCusTom.match(matchingContext));
- assertTrue("%user should match %user in any context",
- userUser.match(matchingContext));
- assertTrue("%user (bob) should match bob in in matching context",
- userStatic.match(matchingContext));
-
- assertFalse(
- "%custom (bob) should NOT match %user (dave) in mismatching context",
- customUser.match(mismatchingContext));
- assertFalse(
- "%user (dave) should NOT match %custom (bob) in mismatching context",
- userCustom.match(mismatchingContext));
- assertFalse(
- "%user (dave) should NOT match %cus%tom (b+ob) in mismatching context",
- userCusTom.match(mismatchingContext));
- assertTrue("%user should match %user in any context",
- userUser.match(mismatchingContext));
- assertFalse(
- "%user (dave) should NOT match match bob in in matching context",
- userStatic.match(mismatchingContext));
+ assertTrue(customUser.match(matchingContext),
+ "%custom should match %user in matching context");
+ assertTrue(userCustom.match(matchingContext),
+ "%user should match %custom in matching context");
+ assertTrue(userCusTom.match(matchingContext),
+ "%user (bob) should match %cus%tom (b + ob) in matching context");
+ assertTrue(userUser.match(matchingContext),
+ "%user should match %user in any context");
+ assertTrue(userStatic.match(matchingContext),
+ "%user (bob) should match bob in in matching context");
+
+ assertFalse(customUser.match(mismatchingContext),
+ "%custom (bob) should NOT match %user (dave) in mismatching context");
+ assertFalse(userCustom.match(mismatchingContext),
+ "%user (dave) should NOT match %custom (bob) in mismatching context");
+ assertFalse(userCusTom.match(mismatchingContext),
+ "%user (dave) should NOT match %cus%tom (b+ob) in mismatching context");
+ assertTrue(userUser.match(mismatchingContext),
+ "%user should match %user in any context");
+ assertFalse(userStatic.match(mismatchingContext),
+ "%user (dave) should NOT match match bob in in matching context");
}
@Test
diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/placement/csmappingrule/TestMappingRuleValidationContextImpl.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/placement/csmappingrule/TestMappingRuleValidationContextImpl.java
index a015e315c35a99..6e2ad9f736147c 100644
--- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/placement/csmappingrule/TestMappingRuleValidationContextImpl.java
+++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/placement/csmappingrule/TestMappingRuleValidationContextImpl.java
@@ -21,9 +21,12 @@
import org.apache.hadoop.yarn.exceptions.YarnException;
import org.apache.hadoop.yarn.server.resourcemanager.placement.MockQueueHierarchyBuilder;
import org.apache.hadoop.yarn.server.resourcemanager.scheduler.capacity.CapacitySchedulerQueueManager;
-import org.junit.Test;
+import org.junit.jupiter.api.Test;
-import static org.junit.Assert.*;
+import static org.junit.jupiter.api.Assertions.assertEquals;
+import static org.junit.jupiter.api.Assertions.assertFalse;
+import static org.junit.jupiter.api.Assertions.assertTrue;
+import static org.junit.jupiter.api.Assertions.fail;
import static org.mockito.ArgumentMatchers.isNull;
import static org.mockito.Mockito.mock;
import static org.mockito.Mockito.when;
diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/placement/csmappingrule/TestVariableContext.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/placement/csmappingrule/TestVariableContext.java
index 30d265b9e8c85c..080908adac2725 100644
--- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/placement/csmappingrule/TestVariableContext.java
+++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/placement/csmappingrule/TestVariableContext.java
@@ -20,13 +20,19 @@
import org.apache.hadoop.thirdparty.com.google.common.collect.ImmutableSet;
import org.apache.hadoop.yarn.server.resourcemanager.placement.VariableContext;
-import org.junit.Test;
+import org.junit.jupiter.api.Test;
import java.util.HashMap;
import java.util.HashSet;
import java.util.Set;
-import static org.junit.Assert.*;
+import static org.junit.jupiter.api.Assertions.assertEquals;
+import static org.junit.jupiter.api.Assertions.assertFalse;
+import static org.junit.jupiter.api.Assertions.assertNull;
+import static org.junit.jupiter.api.Assertions.assertSame;
+import static org.junit.jupiter.api.Assertions.assertThrows;
+import static org.junit.jupiter.api.Assertions.assertTrue;
+import static org.junit.jupiter.api.Assertions.fail;
public class TestVariableContext {
@@ -49,32 +55,38 @@ public void testAddAndGet() {
assertEquals("", variables.get("%empty"));
}
- @Test(expected = IllegalStateException.class)
+ @Test
public void testImmutablesCanOnlySetOnceFromSet() {
- VariableContext variables = new VariableContext();
- ImmutableSet immutables =
- ImmutableSet.of("%user", "%primary_group", "%secondary_group");
-
- variables.setImmutables(immutables);
- variables.setImmutables(immutables);
+ assertThrows(IllegalStateException.class, () -> {
+ VariableContext variables = new VariableContext();
+ ImmutableSet immutables =
+ ImmutableSet.of("%user", "%primary_group", "%secondary_group");
+
+ variables.setImmutables(immutables);
+ variables.setImmutables(immutables);
+ });
}
- @Test(expected = IllegalStateException.class)
+ @Test
public void testImmutablesCanOnlySetOnceFromArray() {
- VariableContext variables = new VariableContext();
+ assertThrows(IllegalStateException.class, () -> {
+ VariableContext variables = new VariableContext();
- variables.setImmutables("%user", "%primary_group", "%secondary_group");
- variables.setImmutables("%user", "%primary_group", "%secondary_group");
+ variables.setImmutables("%user", "%primary_group", "%secondary_group");
+ variables.setImmutables("%user", "%primary_group", "%secondary_group");
+ });
}
- @Test(expected = IllegalStateException.class)
+ @Test
public void testImmutablesCanOnlySetOnceFromSetAndArray() {
- VariableContext variables = new VariableContext();
- ImmutableSet immutables =
- ImmutableSet.of("%user", "%primary_group", "%secondary_group");
-
- variables.setImmutables(immutables);
- variables.setImmutables("%user", "%primary_group", "%secondary_group");
+ assertThrows(IllegalStateException.class, () -> {
+ VariableContext variables = new VariableContext();
+ ImmutableSet immutables =
+ ImmutableSet.of("%user", "%primary_group", "%secondary_group");
+
+ variables.setImmutables(immutables);
+ variables.setImmutables("%user", "%primary_group", "%secondary_group");
+ });
}
@Test
@@ -87,15 +99,17 @@ public void testImmutableVariableCanBeSetOnce() {
variables.put("%user", "bob");
}
- @Test(expected = IllegalStateException.class)
+ @Test
public void testImmutableVariableProtection() {
- VariableContext variables = new VariableContext();
- ImmutableSet immutables =
- ImmutableSet.of("%user", "%primary_group", "%secondary_group");
-
- variables.setImmutables(immutables);
- variables.put("%user", "bob");
- variables.put("%user", "bob");
+ assertThrows(IllegalStateException.class, () -> {
+ VariableContext variables = new VariableContext();
+ ImmutableSet immutables =
+ ImmutableSet.of("%user", "%primary_group", "%secondary_group");
+
+ variables.setImmutables(immutables);
+ variables.put("%user", "bob");
+ variables.put("%user", "bob");
+ });
}
@Test
diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/preprocessor/TestContextProcessor.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/preprocessor/TestContextProcessor.java
index 039e794eddb474..708c2899039d28 100644
--- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/preprocessor/TestContextProcessor.java
+++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/preprocessor/TestContextProcessor.java
@@ -24,9 +24,11 @@
import java.util.Set;
import org.apache.hadoop.yarn.api.records.ApplicationId;
import org.apache.hadoop.yarn.api.records.ApplicationSubmissionContext;
-import org.junit.Test;
+import org.junit.jupiter.api.Test;
-import static org.mockito.Mockito.*;
+import static org.mockito.Mockito.mock;
+import static org.mockito.Mockito.times;
+import static org.mockito.Mockito.verify;
/**
diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/preprocessor/TestNodeLabelProcessor.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/preprocessor/TestNodeLabelProcessor.java
index bb55b72ce5b47b..3c466bb2b294a1 100644
--- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/preprocessor/TestNodeLabelProcessor.java
+++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/preprocessor/TestNodeLabelProcessor.java
@@ -21,7 +21,7 @@
import org.apache.hadoop.yarn.api.records.ApplicationId;
import org.apache.hadoop.yarn.api.records.ApplicationSubmissionContext;
-import org.junit.Test;
+import org.junit.jupiter.api.Test;
import static org.mockito.Mockito.*;
diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/preprocessor/TestQueueProcessor.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/preprocessor/TestQueueProcessor.java
index fc032bb1497b29..421d5c6fc25de0 100644
--- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/preprocessor/TestQueueProcessor.java
+++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/preprocessor/TestQueueProcessor.java
@@ -20,9 +20,12 @@
import org.apache.hadoop.yarn.api.records.ApplicationId;
import org.apache.hadoop.yarn.api.records.ApplicationSubmissionContext;
-import org.junit.Test;
+import org.junit.jupiter.api.Test;
-import static org.mockito.Mockito.*;
+import static org.mockito.Mockito.mock;
+import static org.mockito.Mockito.times;
+import static org.mockito.Mockito.verify;
+import static org.mockito.Mockito.when;
/**
diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/preprocessor/TestTagAddProcessor.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/preprocessor/TestTagAddProcessor.java
index abe06740450268..6d5880c0881892 100644
--- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/preprocessor/TestTagAddProcessor.java
+++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/preprocessor/TestTagAddProcessor.java
@@ -22,8 +22,12 @@
import java.util.Set;
import org.apache.hadoop.yarn.api.records.ApplicationId;
import org.apache.hadoop.yarn.api.records.ApplicationSubmissionContext;
-import org.junit.Test;
-import static org.mockito.Mockito.*;
+import org.junit.jupiter.api.Test;
+
+import static org.mockito.Mockito.mock;
+import static org.mockito.Mockito.times;
+import static org.mockito.Mockito.verify;
+import static org.mockito.Mockito.when;
/**
diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/recovery/RMStateStoreTestBase.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/recovery/RMStateStoreTestBase.java
index 1773c7aaa88e77..202ecf811b16b3 100644
--- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/recovery/RMStateStoreTestBase.java
+++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/recovery/RMStateStoreTestBase.java
@@ -18,12 +18,14 @@
package org.apache.hadoop.yarn.server.resourcemanager.recovery;
-import static org.junit.Assert.assertArrayEquals;
-import static org.junit.Assert.assertEquals;
-import static org.junit.Assert.assertNotNull;
-import static org.junit.Assert.assertNull;
-import static org.junit.Assert.assertTrue;
-import static org.junit.Assert.fail;
+import static org.junit.jupiter.api.Assertions.assertArrayEquals;
+import static org.junit.jupiter.api.Assertions.assertEquals;
+import static org.junit.jupiter.api.Assertions.assertFalse;
+import static org.junit.jupiter.api.Assertions.assertNotNull;
+import static org.junit.jupiter.api.Assertions.assertNotEquals;
+import static org.junit.jupiter.api.Assertions.assertNull;
+import static org.junit.jupiter.api.Assertions.assertTrue;
+import static org.junit.jupiter.api.Assertions.fail;
import static org.mockito.Mockito.mock;
import static org.mockito.Mockito.spy;
import static org.mockito.Mockito.when;
@@ -86,7 +88,6 @@
import org.apache.hadoop.yarn.server.webproxy.ProxyCA;
import org.apache.hadoop.yarn.util.resource.DefaultResourceCalculator;
import org.apache.hadoop.yarn.util.resource.ResourceCalculator;
-import org.junit.Assert;
public class RMStateStoreTestBase {
@@ -484,13 +485,13 @@ public void testRMDTSecretManagerStateStore(
RMDTSecretManagerState secretManagerState =
store.loadState().getRMDTSecretManagerState();
- Assert.assertEquals(token1, secretManagerState.getTokenState());
- Assert.assertEquals(keySet, secretManagerState.getMasterKeyState());
- Assert.assertEquals(sequenceNumber,
+ assertEquals(token1, secretManagerState.getTokenState());
+ assertEquals(keySet, secretManagerState.getMasterKeyState());
+ assertEquals(sequenceNumber,
secretManagerState.getDTSequenceNumber());
RMDelegationTokenIdentifier tokenAfterStore =
secretManagerState.getTokenState().keySet().iterator().next();
- Assert.assertTrue(Arrays.equals(tokenBeforeStore,
+ assertTrue(Arrays.equals(tokenBeforeStore,
tokenAfterStore.getBytes()));
// update RM delegation token;
@@ -500,9 +501,9 @@ public void testRMDTSecretManagerStateStore(
RMDTSecretManagerState updateSecretManagerState =
store.loadState().getRMDTSecretManagerState();
- Assert.assertEquals(token1, updateSecretManagerState.getTokenState());
- Assert.assertEquals(keySet, updateSecretManagerState.getMasterKeyState());
- Assert.assertEquals(sequenceNumber,
+ assertEquals(token1, updateSecretManagerState.getTokenState());
+ assertEquals(keySet, updateSecretManagerState.getMasterKeyState());
+ assertEquals(sequenceNumber,
updateSecretManagerState.getDTSequenceNumber());
// check to delete delegationKey
@@ -510,9 +511,9 @@ public void testRMDTSecretManagerStateStore(
keySet.clear();
RMDTSecretManagerState noKeySecretManagerState =
store.loadState().getRMDTSecretManagerState();
- Assert.assertEquals(token1, noKeySecretManagerState.getTokenState());
- Assert.assertEquals(keySet, noKeySecretManagerState.getMasterKeyState());
- Assert.assertEquals(sequenceNumber,
+ assertEquals(token1, noKeySecretManagerState.getTokenState());
+ assertEquals(keySet, noKeySecretManagerState.getMasterKeyState());
+ assertEquals(sequenceNumber,
noKeySecretManagerState.getDTSequenceNumber());
// check to delete delegationToken
@@ -520,11 +521,11 @@ public void testRMDTSecretManagerStateStore(
RMDTSecretManagerState noKeyAndTokenSecretManagerState =
store.loadState().getRMDTSecretManagerState();
token1.clear();
- Assert.assertEquals(token1,
+ assertEquals(token1,
noKeyAndTokenSecretManagerState.getTokenState());
- Assert.assertEquals(keySet,
+ assertEquals(keySet,
noKeyAndTokenSecretManagerState.getMasterKeyState());
- Assert.assertEquals(sequenceNumber,
+ assertEquals(sequenceNumber,
noKeySecretManagerState.getDTSequenceNumber());
store.close();
@@ -547,17 +548,17 @@ public void testCheckVersion(RMStateStoreHelper stateStoreHelper)
// default version
Version defaultVersion = stateStoreHelper.getCurrentVersion();
store.checkVersion();
- Assert.assertEquals(defaultVersion, store.loadVersion());
+ assertEquals(defaultVersion, store.loadVersion());
// compatible version
Version compatibleVersion =
Version.newInstance(defaultVersion.getMajorVersion(),
defaultVersion.getMinorVersion() + 2);
stateStoreHelper.writeVersion(compatibleVersion);
- Assert.assertEquals(compatibleVersion, store.loadVersion());
+ assertEquals(compatibleVersion, store.loadVersion());
store.checkVersion();
// overwrite the compatible version
- Assert.assertEquals(defaultVersion, store.loadVersion());
+ assertEquals(defaultVersion, store.loadVersion());
// incompatible version
Version incompatibleVersion =
@@ -566,9 +567,9 @@ public void testCheckVersion(RMStateStoreHelper stateStoreHelper)
stateStoreHelper.writeVersion(incompatibleVersion);
try {
store.checkVersion();
- Assert.fail("Invalid version, should fail.");
+ fail("Invalid version, should fail.");
} catch (Throwable t) {
- Assert.assertTrue(t instanceof RMStateVersionIncompatibleException);
+ assertTrue(t instanceof RMStateVersionIncompatibleException);
}
}
@@ -578,13 +579,13 @@ public void testEpoch(RMStateStoreHelper stateStoreHelper)
store.setRMDispatcher(new TestDispatcher());
long firstTimeEpoch = store.getAndIncrementEpoch();
- Assert.assertEquals(epoch, firstTimeEpoch);
+ assertEquals(epoch, firstTimeEpoch);
long secondTimeEpoch = store.getAndIncrementEpoch();
- Assert.assertEquals(epoch + 1, secondTimeEpoch);
+ assertEquals(epoch + 1, secondTimeEpoch);
long thirdTimeEpoch = store.getAndIncrementEpoch();
- Assert.assertEquals(epoch + 2, thirdTimeEpoch);
+ assertEquals(epoch + 2, thirdTimeEpoch);
for (int i = 0; i < epochRange; ++i) {
store.getAndIncrementEpoch();
@@ -592,7 +593,7 @@ public void testEpoch(RMStateStoreHelper stateStoreHelper)
long wrappedEpoch = store.getAndIncrementEpoch();
// Epoch should have wrapped around and then incremented once for a total
// of + 3
- Assert.assertEquals(epoch + 3, wrappedEpoch);
+ assertEquals(epoch + 3, wrappedEpoch);
}
public void testAppDeletion(RMStateStoreHelper stateStoreHelper)
@@ -625,7 +626,7 @@ private ArrayList createAndStoreApps(
appList.add(app);
}
- Assert.assertEquals(numApps, appList.size());
+ assertEquals(numApps, appList.size());
for (RMApp app : appList) {
// wait for app to be stored.
while (true) {
@@ -646,7 +647,7 @@ public void testDeleteStore(RMStateStoreHelper stateStoreHelper)
store.deleteStore();
// verify apps deleted
for (RMApp app : appList) {
- Assert.assertFalse(stateStoreHelper.appExists(app));
+ assertFalse(stateStoreHelper.appExists(app));
}
}
@@ -659,10 +660,10 @@ public void testRemoveApplication(RMStateStoreHelper stateStoreHelper)
RMApp rmApp1 = appList.get(0);
store.removeApplication(rmApp1.getApplicationId());
- Assert.assertFalse(stateStoreHelper.appExists(rmApp1));
+ assertFalse(stateStoreHelper.appExists(rmApp1));
RMApp rmApp2 = appList.get(1);
- Assert.assertTrue(stateStoreHelper.appExists(rmApp2));
+ assertTrue(stateStoreHelper.appExists(rmApp2));
}
public void testRemoveAttempt(RMStateStoreHelper stateStoreHelper)
@@ -685,8 +686,8 @@ public void testRemoveAttempt(RMStateStoreHelper stateStoreHelper)
ContainerId.newContainerId(attemptId2, 1).toString(),
null, null, dispatcher);
store.removeApplicationAttemptInternal(attemptId1);
- Assert.assertFalse(stateStoreHelper.attemptExists(attempt1));
- Assert.assertTrue(stateStoreHelper.attemptExists(attempt2));
+ assertFalse(stateStoreHelper.attemptExists(attempt1));
+ assertTrue(stateStoreHelper.attemptExists(attempt2));
// let things settle down
Thread.sleep(1000);
@@ -742,10 +743,10 @@ public void testAMRMTokenSecretManagerStateStore(
when(rmContext.getStateStore()).thenReturn(store);
store.setRMDispatcher(dispatcher);
RMState state = store.loadState();
- Assert.assertNotNull(state.getAMRMTokenSecretManagerState());
- Assert.assertEquals(firstMasterKeyData.getMasterKey(), state
+ assertNotNull(state.getAMRMTokenSecretManagerState());
+ assertEquals(firstMasterKeyData.getMasterKey(), state
.getAMRMTokenSecretManagerState().getCurrentMasterKey());
- Assert.assertNull(state
+ assertNull(state
.getAMRMTokenSecretManagerState().getNextMasterKey());
//create and save the second masterkey
@@ -762,18 +763,18 @@ public void testAMRMTokenSecretManagerStateStore(
when(rmContext.getStateStore()).thenReturn(store);
store.setRMDispatcher(dispatcher);
RMState state_2 = store.loadState();
- Assert.assertNotNull(state_2.getAMRMTokenSecretManagerState());
- Assert.assertEquals(firstMasterKeyData.getMasterKey(), state_2
+ assertNotNull(state_2.getAMRMTokenSecretManagerState());
+ assertEquals(firstMasterKeyData.getMasterKey(), state_2
.getAMRMTokenSecretManagerState().getCurrentMasterKey());
- Assert.assertEquals(secondMasterKeyData.getMasterKey(), state_2
+ assertEquals(secondMasterKeyData.getMasterKey(), state_2
.getAMRMTokenSecretManagerState().getNextMasterKey());
// re-create the masterKeyData based on the recovered masterkey
// should have the same secretKey
appTokenMgr.recover(state_2);
- Assert.assertEquals(appTokenMgr.getCurrnetMasterKeyData().getSecretKey(),
+ assertEquals(appTokenMgr.getCurrnetMasterKeyData().getSecretKey(),
firstMasterKeyData.getSecretKey());
- Assert.assertEquals(appTokenMgr.getNextMasterKeyData().getSecretKey(),
+ assertEquals(appTokenMgr.getNextMasterKeyData().getSecretKey(),
secondMasterKeyData.getSecretKey());
store.close();
@@ -814,7 +815,7 @@ public void testReservationStateStore(
RMState state = store.loadState();
Map>
reservationState = state.getReservationState();
- Assert.assertNotNull(reservationState);
+ assertNotNull(reservationState);
// 2. Store single reservation and verify
String reservationIdName = r1.toString();
@@ -868,13 +869,13 @@ public void testReservationStateStore(
store.setRMDispatcher(dispatcher);
state = store.loadState();
reservationState = state.getReservationState();
- Assert.assertNotNull(reservationState);
+ assertNotNull(reservationState);
reservations = reservationState.get(planName);
- Assert.assertNotNull(reservations);
+ assertNotNull(reservations);
ReservationAllocationStateProto storedReservationAllocation =
reservations.get(r1);
- Assert.assertNull("Removed reservation should not be available in store",
- storedReservationAllocation);
+ assertNull(storedReservationAllocation,
+ "Removed reservation should not be available in store");
storedReservationAllocation = reservations.get(r2);
assertAllocationStateEqual(
@@ -890,9 +891,9 @@ public void testReservationStateStore(
store.setRMDispatcher(dispatcher);
state = store.loadState();
reservationState = state.getReservationState();
- Assert.assertNotNull(reservationState);
+ assertNotNull(reservationState);
reservations = reservationState.get(planName);
- Assert.assertNull(reservations);
+ assertNull(reservations);
}
public void testProxyCA(
@@ -908,22 +909,22 @@ public void testProxyCA(
RMStateStore.ProxyCAState proxyCAState =
store.loadState().getProxyCAState();
- Assert.assertEquals(originalProxyCA.getCaCert(), proxyCAState.getCaCert());
- Assert.assertEquals(originalProxyCA.getCaKeyPair().getPrivate(),
+ assertEquals(originalProxyCA.getCaCert(), proxyCAState.getCaCert());
+ assertEquals(originalProxyCA.getCaKeyPair().getPrivate(),
proxyCAState.getCaPrivateKey());
// Try replacing with a different ProxyCA
ProxyCA newProxyCA = new ProxyCA();
newProxyCA.init();
- Assert.assertNotEquals(originalProxyCA.getCaCert(), newProxyCA.getCaCert());
- Assert.assertNotEquals(originalProxyCA.getCaKeyPair().getPrivate(),
+ assertNotEquals(originalProxyCA.getCaCert(), newProxyCA.getCaCert());
+ assertNotEquals(originalProxyCA.getCaKeyPair().getPrivate(),
newProxyCA.getCaKeyPair().getPrivate());
store.storeProxyCACert(newProxyCA.getCaCert(),
newProxyCA.getCaKeyPair().getPrivate());
proxyCAState = store.loadState().getProxyCAState();
- Assert.assertEquals(newProxyCA.getCaCert(), proxyCAState.getCaCert());
- Assert.assertEquals(newProxyCA.getCaKeyPair().getPrivate(),
+ assertEquals(newProxyCA.getCaCert(), proxyCAState.getCaCert());
+ assertEquals(newProxyCA.getCaKeyPair().getPrivate(),
proxyCAState.getCaPrivateKey());
}
@@ -938,13 +939,13 @@ private void validateStoredReservation(
RMState state = store.loadState();
Map>
reservationState = state.getReservationState();
- Assert.assertNotNull(reservationState);
+ assertNotNull(reservationState);
Map reservations =
reservationState.get(planName);
- Assert.assertNotNull(reservations);
+ assertNotNull(reservations);
ReservationAllocationStateProto storedReservationAllocation =
reservations.get(r1);
- Assert.assertNotNull(storedReservationAllocation);
+ assertNotNull(storedReservationAllocation);
assertAllocationStateEqual(
allocationStateProto, storedReservationAllocation);
@@ -955,12 +956,12 @@ void assertAllocationStateEqual(
ReservationAllocationStateProto expected,
ReservationAllocationStateProto actual) {
- Assert.assertEquals(
+ assertEquals(
expected.getAcceptanceTime(), actual.getAcceptanceTime());
- Assert.assertEquals(expected.getStartTime(), actual.getStartTime());
- Assert.assertEquals(expected.getEndTime(), actual.getEndTime());
- Assert.assertEquals(expected.getContainsGangs(), actual.getContainsGangs());
- Assert.assertEquals(expected.getUser(), actual.getUser());
+ assertEquals(expected.getStartTime(), actual.getStartTime());
+ assertEquals(expected.getEndTime(), actual.getEndTime());
+ assertEquals(expected.getContainsGangs(), actual.getContainsGangs());
+ assertEquals(expected.getUser(), actual.getUser());
assertEquals(
expected.getReservationDefinition(), actual.getReservationDefinition());
assertEquals(expected.getAllocationRequestsList(),
@@ -970,12 +971,12 @@ void assertAllocationStateEqual(
void assertAllocationStateEqual(
ReservationAllocation expected,
ReservationAllocationStateProto actual) {
- Assert.assertEquals(
+ assertEquals(
expected.getAcceptanceTime(), actual.getAcceptanceTime());
- Assert.assertEquals(expected.getStartTime(), actual.getStartTime());
- Assert.assertEquals(expected.getEndTime(), actual.getEndTime());
- Assert.assertEquals(expected.containsGangs(), actual.getContainsGangs());
- Assert.assertEquals(expected.getUser(), actual.getUser());
+ assertEquals(expected.getStartTime(), actual.getStartTime());
+ assertEquals(expected.getEndTime(), actual.getEndTime());
+ assertEquals(expected.containsGangs(), actual.getContainsGangs());
+ assertEquals(expected.getUser(), actual.getUser());
assertEquals(
expected.getReservationDefinition(),
ReservationSystemUtil.convertFromProtoFormat(
diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/recovery/TestCheckRemoveZKNodeRMStateStore.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/recovery/TestCheckRemoveZKNodeRMStateStore.java
index e8d38ebf742f65..a547e673a0825e 100644
--- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/recovery/TestCheckRemoveZKNodeRMStateStore.java
+++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/recovery/TestCheckRemoveZKNodeRMStateStore.java
@@ -44,16 +44,26 @@
import org.apache.hadoop.yarn.server.resourcemanager.rmapp.RMApp;
import org.apache.hadoop.yarn.server.resourcemanager.rmapp.attempt.RMAppAttempt;
import org.apache.zookeeper.KeeperException;
-import org.junit.After;
-import org.junit.Before;
-import org.junit.Test;
+import org.junit.jupiter.api.AfterEach;
+import org.junit.jupiter.api.BeforeEach;
+import org.junit.jupiter.api.Test;
+import org.junit.jupiter.api.Timeout;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import java.io.IOException;
-import org.mockito.Mockito;
-import org.junit.Assert;
+import static org.junit.jupiter.api.Assertions.assertEquals;
+import static org.junit.jupiter.api.Assertions.assertTrue;
+import static org.junit.jupiter.api.Assertions.fail;
+import static org.mockito.Mockito.anyList;
+import static org.mockito.Mockito.anyString;
+import static org.mockito.Mockito.doThrow;
+import static org.mockito.Mockito.mock;
+import static org.mockito.Mockito.RETURNS_DEEP_STUBS;
+import static org.mockito.Mockito.times;
+import static org.mockito.Mockito.verify;
+import static org.mockito.Mockito.when;
public class TestCheckRemoveZKNodeRMStateStore extends RMStateStoreTestBase {
@@ -78,13 +88,13 @@ public static CuratorFramework setupCuratorFramework(
return curatorFramework;
}
- @Before
+ @BeforeEach
public void setupCurator() throws Exception {
curatorTestingServer = setupCuratorServer();
curatorFramework = setupCuratorFramework(curatorTestingServer);
}
- @After
+ @AfterEach
public void cleanupCuratorServer() throws IOException {
curatorFramework.close();
curatorTestingServer.stop();
@@ -101,31 +111,31 @@ class TestZKRMStateStoreInternal extends ZKRMStateStore {
private ZKCuratorManager zkCuratorManager;
TestZKRMStateStoreInternal(Configuration conf, String workingZnode)
throws Exception {
- resourceManager = Mockito.mock(ResourceManager.class);
- zkCuratorManager = Mockito.mock(ZKCuratorManager.class, Mockito.RETURNS_DEEP_STUBS);
+ resourceManager = mock(ResourceManager.class);
+ zkCuratorManager = mock(ZKCuratorManager.class, RETURNS_DEEP_STUBS);
- Mockito.when(resourceManager.getZKManager()).thenReturn(zkCuratorManager);
- Mockito.when(resourceManager.createAndStartZKManager(conf)).thenReturn(zkCuratorManager);
- Mockito.when(zkCuratorManager.exists(getAppNode("application_1708333280_0001")))
+ when(resourceManager.getZKManager()).thenReturn(zkCuratorManager);
+ when(resourceManager.createAndStartZKManager(conf)).thenReturn(zkCuratorManager);
+ when(zkCuratorManager.exists(getAppNode("application_1708333280_0001")))
.thenReturn(true);
- Mockito.when(zkCuratorManager.exists(getAppNode("application_1708334188_0001")))
+ when(zkCuratorManager.exists(getAppNode("application_1708334188_0001")))
.thenReturn(true).thenReturn(false);
- Mockito.when(zkCuratorManager.exists(getDelegationTokenNode(0, 0)))
+ when(zkCuratorManager.exists(getDelegationTokenNode(0, 0)))
.thenReturn(true).thenReturn(false);
- Mockito.when(zkCuratorManager.exists(getAppNode("application_1709705779_0001")))
+ when(zkCuratorManager.exists(getAppNode("application_1709705779_0001")))
.thenReturn(true);
- Mockito.when(zkCuratorManager.exists(getAttemptNode("application_1709705779_0001",
+ when(zkCuratorManager.exists(getAttemptNode("application_1709705779_0001",
"appattempt_1709705779_0001_000001")))
.thenReturn(true);
- Mockito.doThrow(new KeeperException.NoNodeException()).when(zkCuratorManager)
- .safeDelete(Mockito.anyString(), Mockito.anyList(), Mockito.anyString());
+ doThrow(new KeeperException.NoNodeException()).when(zkCuratorManager)
+ .safeDelete(anyString(), anyList(), anyString());
setResourceManager(resourceManager);
init(conf);
dispatcher.disableExitOnDispatchException();
start();
- Assert.assertTrue(znodeWorkingPath.equals(workingZnode));
+ assertTrue(znodeWorkingPath.equals(workingZnode));
}
private String getVersionNode() {
@@ -236,7 +246,8 @@ public boolean attemptExists(RMAppAttempt attempt) throws Exception {
}
}
- @Test (timeout = 60000)
+ @Test
+ @Timeout(value = 60)
public void testSafeDeleteZKNode() throws Exception {
TestZKRMStateStoreTester zkTester = new TestZKRMStateStoreTester();
testRemoveAttempt(zkTester);
@@ -262,12 +273,12 @@ public void testRemoveAttempt(RMStateStoreHelper stateStoreHelper) throws Except
try {
store.removeApplicationAttemptInternal(attemptIdRemoved);
} catch (KeeperException.NoNodeException nne) {
- Assert.fail("NoNodeException should not happen.");
+ fail("NoNodeException should not happen.");
}
// The verification method safeDelete is called once.
- Mockito.verify(store.resourceManager.getZKManager(), Mockito.times(1))
- .safeDelete(Mockito.anyString(), Mockito.anyList(), Mockito.anyString());
+ verify(store.resourceManager.getZKManager(), times(1))
+ .safeDelete(anyString(), anyList(), anyString());
store.close();
}
@@ -296,7 +307,7 @@ public void testRemoveApplication(RMStateStoreHelper stateStoreHelper) throws Ex
// The occurrence of NoNodeException is induced by calling the safeDelete method.
store.removeApplicationStateInternal(appStateRemoved);
} catch (KeeperException.NoNodeException nne) {
- Assert.fail("NoNodeException should not happen.");
+ fail("NoNodeException should not happen.");
}
store.close();
@@ -312,12 +323,12 @@ public void testRemoveRMDelegationToken(RMStateStoreHelper stateStoreHelper) thr
try {
store.removeRMDelegationTokenState(tokenIdRemoved);
} catch (KeeperException.NoNodeException nne) {
- Assert.fail("NoNodeException should not happen.");
+ fail("NoNodeException should not happen.");
}
// The verification method safeDelete is called once.
- Mockito.verify(store.resourceManager.getZKManager(), Mockito.times(1))
- .safeDelete(Mockito.anyString(), Mockito.anyList(), Mockito.anyString());
+ verify(store.resourceManager.getZKManager(), times(1))
+ .safeDelete(anyString(), anyList(), anyString());
store.close();
}
@@ -332,12 +343,12 @@ public void testRemoveRMDTMasterKeyState(RMStateStoreHelper stateStoreHelper) th
try {
store.removeRMDTMasterKeyState(keyRemoved);
} catch (KeeperException.NoNodeException nne) {
- Assert.fail("NoNodeException should not happen.");
+ fail("NoNodeException should not happen.");
}
// The verification method safeDelete is called once.
- Mockito.verify(store.resourceManager.getZKManager(), Mockito.times(1))
- .safeDelete(Mockito.anyString(), Mockito.anyList(), Mockito.anyString());
+ verify(store.resourceManager.getZKManager(), times(1))
+ .safeDelete(anyString(), anyList(), anyString());
store.close();
}
@@ -353,12 +364,12 @@ public void testRemoveReservationState(RMStateStoreHelper stateStoreHelper) thro
try {
store.removeReservationState(planName, reservationIdRemoved.toString());
} catch (KeeperException.NoNodeException nne) {
- Assert.fail("NoNodeException should not happen.");
+ fail("NoNodeException should not happen.");
}
// The verification method safeDelete is called once.
- Mockito.verify(store.resourceManager.getZKManager(), Mockito.times(1))
- .safeDelete(Mockito.anyString(), Mockito.anyList(), Mockito.anyString());
+ verify(store.resourceManager.getZKManager(), times(1))
+ .safeDelete(anyString(), anyList(), anyString());
store.close();
}
@@ -376,11 +387,11 @@ public void testTransitionedToStandbyAfterCheckNode(RMStateStoreHelper stateStor
// Transition to active.
rm.getRMContext().getRMAdminService().transitionToActive(req);
- Assert.assertEquals("RM with ZKStore didn't start",
- Service.STATE.STARTED, rm.getServiceState());
- Assert.assertEquals("RM should be Active",
- HAServiceProtocol.HAServiceState.ACTIVE,
- rm.getRMContext().getRMAdminService().getServiceStatus().getState());
+ assertEquals(Service.STATE.STARTED, rm.getServiceState(),
+ "RM with ZKStore didn't start");
+ assertEquals(HAServiceProtocol.HAServiceState.ACTIVE,
+ rm.getRMContext().getRMAdminService().getServiceStatus().getState(),
+ "RM should be Active");
// Simulate throw NodeExistsException
ZKRMStateStore zKStore = (ZKRMStateStore) rm.getRMContext().getStateStore();
@@ -397,7 +408,7 @@ public void testTransitionedToStandbyAfterCheckNode(RMStateStoreHelper stateStor
try {
zKStore.removeApplicationAttemptInternal(attemptIdRemoved);
} catch (Exception e) {
- Assert.assertTrue(e instanceof KeeperException.NodeExistsException);
+ assertTrue(e instanceof KeeperException.NodeExistsException);
}
rm.close();
diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/recovery/TestFSRMStateStore.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/recovery/TestFSRMStateStore.java
index 65de39d7ab21ce..15319a7e515859 100644
--- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/recovery/TestFSRMStateStore.java
+++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/recovery/TestFSRMStateStore.java
@@ -19,7 +19,12 @@
package org.apache.hadoop.yarn.server.resourcemanager.recovery;
import static org.assertj.core.api.Assertions.assertThat;
-import static org.junit.Assert.assertTrue;
+import static org.junit.jupiter.api.Assertions.assertEquals;
+import static org.junit.jupiter.api.Assertions.assertFalse;
+import static org.junit.jupiter.api.Assertions.assertNotNull;
+import static org.junit.jupiter.api.Assertions.assertNull;
+import static org.junit.jupiter.api.Assertions.assertTrue;
+import static org.junit.jupiter.api.Assertions.fail;
import java.io.IOException;
import java.security.PrivilegedExceptionAction;
@@ -50,8 +55,8 @@
import org.apache.hadoop.yarn.server.resourcemanager.rmapp.RMAppState;
import org.apache.hadoop.yarn.server.resourcemanager.rmapp.attempt.RMAppAttempt;
-import org.junit.Assert;
-import org.junit.Test;
+import org.junit.jupiter.api.Test;
+import org.junit.jupiter.api.Timeout;
public class TestFSRMStateStore extends RMStateStoreTestBase {
@@ -71,11 +76,11 @@ class TestFileSystemRMStore extends FileSystemRMStateStore {
TestFileSystemRMStore(Configuration conf) throws Exception {
init(conf);
- Assert.assertNull(fs);
+ assertNull(fs);
assertTrue(workingDirPathURI.equals(fsWorkingPath));
dispatcher.disableExitOnDispatchException();
start();
- Assert.assertNotNull(fs);
+ assertNotNull(fs);
}
public Path getVersionNode() {
@@ -128,11 +133,11 @@ public RMStateStore getRMStateStore() throws Exception {
this.store = new TestFileSystemRMStore(conf);
assertThat(store.getNumRetries()).isEqualTo(8);
assertThat(store.getRetryInterval()).isEqualTo(900L);
- Assert.assertTrue(store.fs.getConf() == store.fsConf);
+ assertTrue(store.fs.getConf() == store.fsConf);
FileSystem previousFs = store.fs;
store.startInternal();
- Assert.assertTrue(store.fs != previousFs);
- Assert.assertTrue(store.fs.getConf() == store.fsConf);
+ assertTrue(store.fs != previousFs);
+ assertTrue(store.fs.getConf() == store.fsConf);
return store;
}
@@ -172,7 +177,8 @@ public boolean attemptExists(RMAppAttempt attempt) throws IOException {
}
}
- @Test(timeout = 120000)
+ @Test
+ @Timeout(value = 120)
public void testFSRMStateStore() throws Exception {
HdfsConfiguration conf = new HdfsConfiguration();
MiniDFSCluster cluster =
@@ -196,7 +202,7 @@ public void testFSRMStateStore() throws Exception {
fsOut.close();
testRMAppStateStore(fsTester);
- Assert.assertFalse(fsTester.workingDirPathURI
+ assertFalse(fsTester.workingDirPathURI
.getFileSystem(conf).exists(tempAppAttemptFile));
testRMDTSecretManagerStateStore(fsTester);
testCheckVersion(fsTester);
@@ -213,7 +219,8 @@ public void testFSRMStateStore() throws Exception {
}
}
- @Test(timeout = 60000)
+ @Test
+ @Timeout(value = 60)
public void testHDFSRMStateStore() throws Exception {
final HdfsConfiguration conf = new HdfsConfiguration();
UserGroupInformation yarnAdmin =
@@ -293,11 +300,12 @@ private void verifyFilesUnreadablebyHDFS(MiniDFSCluster cluster,
try {
LOG.warn("\n\n ##Testing path [" + p + "]\n\n");
fs.open(p);
- Assert.fail("Super user should not be able to read ["+ UserGroupInformation.getCurrentUser() + "] [" + p.getName() + "]");
+ fail("Super user should not be able to read ["+
+ UserGroupInformation.getCurrentUser() + "] [" + p.getName() + "]");
} catch (AccessControlException e) {
- Assert.assertTrue(e.getMessage().contains("superuser is not allowed to perform this operation"));
+ assertTrue(e.getMessage().contains("superuser is not allowed to perform this operation"));
} catch (Exception e) {
- Assert.fail("Should get an AccessControlException here");
+ fail("Should get an AccessControlException here");
}
}
if (stat.isDirectory()) {
@@ -310,7 +318,8 @@ private void verifyFilesUnreadablebyHDFS(MiniDFSCluster cluster,
}
- @Test(timeout = 60000)
+ @Test
+ @Timeout(value = 60)
public void testCheckMajorVersionChange() throws Exception {
HdfsConfiguration conf = new HdfsConfiguration();
MiniDFSCluster cluster =
@@ -355,7 +364,7 @@ protected synchronized void storeVersion() throws Exception {
RMStateStore store = fsTester.getRMStateStore();
Version defaultVersion = fsTester.getCurrentVersion();
store.checkVersion();
- Assert.assertEquals(defaultVersion, store.loadVersion());
+ assertEquals(defaultVersion, store.loadVersion());
} finally {
cluster.shutdown();
}
@@ -391,7 +400,8 @@ protected void modifyRMDelegationTokenState() throws Exception {
nodeCreatePath.getName() + ".new"));
}
- @Test (timeout = 30000)
+ @Test
+ @Timeout(value = 30)
public void testFSRMStateStoreClientRetry() throws Exception {
HdfsConfiguration conf = new HdfsConfiguration();
MiniDFSCluster cluster =
@@ -419,7 +429,7 @@ public void testFSRMStateStoreClientRetry() throws Exception {
clientThread.start();
cluster.restartNameNode();
clientThread.join();
- Assert.assertFalse(assertionFailedInThread.get());
+ assertFalse(assertionFailedInThread.get());
} finally {
cluster.shutdown();
}
diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/recovery/TestLeveldbRMStateStore.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/recovery/TestLeveldbRMStateStore.java
index e93599dd47ec4f..57d687b39af8b8 100644
--- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/recovery/TestLeveldbRMStateStore.java
+++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/recovery/TestLeveldbRMStateStore.java
@@ -36,9 +36,10 @@
import org.fusesource.leveldbjni.JniDBFactory;
import org.iq80.leveldb.DB;
import org.iq80.leveldb.Options;
-import org.junit.After;
-import org.junit.Before;
-import org.junit.Test;
+import org.junit.jupiter.api.AfterEach;
+import org.junit.jupiter.api.BeforeEach;
+import org.junit.jupiter.api.Test;
+import org.junit.jupiter.api.Timeout;
public class TestLeveldbRMStateStore extends RMStateStoreTestBase {
@@ -50,14 +51,14 @@ public class TestLeveldbRMStateStore extends RMStateStoreTestBase {
private YarnConfiguration conf;
private LeveldbRMStateStore stateStore = null;
- @Before
+ @BeforeEach
public void setup() throws IOException {
FileUtil.fullyDelete(TEST_DIR);
conf = new YarnConfiguration();
conf.set(YarnConfiguration.RM_LEVELDB_STORE_PATH, TEST_DIR.toString());
}
- @After
+ @AfterEach
public void cleanup() throws IOException {
if (stateStore != null) {
stateStore.close();
@@ -65,25 +66,29 @@ public void cleanup() throws IOException {
FileUtil.fullyDelete(TEST_DIR);
}
- @Test(timeout = 60000)
+ @Test
+ @Timeout(value = 60)
public void testApps() throws Exception {
LeveldbStateStoreTester tester = new LeveldbStateStoreTester();
testRMAppStateStore(tester);
}
- @Test(timeout = 60000)
+ @Test
+ @Timeout(value = 60)
public void testClientTokens() throws Exception {
LeveldbStateStoreTester tester = new LeveldbStateStoreTester();
testRMDTSecretManagerStateStore(tester);
}
- @Test(timeout = 60000)
+ @Test
+ @Timeout(value = 60)
public void testVersion() throws Exception {
LeveldbStateStoreTester tester = new LeveldbStateStoreTester();
testCheckVersion(tester);
}
- @Test(timeout = 60000)
+ @Test
+ @Timeout(value = 60)
public void testEpoch() throws Exception {
conf.setLong(YarnConfiguration.RM_EPOCH, epoch);
conf.setLong(YarnConfiguration.RM_EPOCH_RANGE, getEpochRange());
@@ -91,49 +96,57 @@ public void testEpoch() throws Exception {
testEpoch(tester);
}
- @Test(timeout = 60000)
+ @Test
+ @Timeout(value = 60)
public void testAppDeletion() throws Exception {
LeveldbStateStoreTester tester = new LeveldbStateStoreTester();
testAppDeletion(tester);
}
- @Test(timeout = 60000)
+ @Test
+ @Timeout(value = 60)
public void testDeleteStore() throws Exception {
LeveldbStateStoreTester tester = new LeveldbStateStoreTester();
testDeleteStore(tester);
}
- @Test(timeout = 60000)
+ @Test
+ @Timeout(value = 60)
public void testRemoveApplication() throws Exception {
LeveldbStateStoreTester tester = new LeveldbStateStoreTester();
testRemoveApplication(tester);
}
- @Test(timeout = 60000)
+ @Test
+ @Timeout(value = 60)
public void testRemoveAttempt() throws Exception {
LeveldbStateStoreTester tester = new LeveldbStateStoreTester();
testRemoveAttempt(tester);
}
- @Test(timeout = 60000)
+ @Test
+ @Timeout(value = 60)
public void testAMTokens() throws Exception {
LeveldbStateStoreTester tester = new LeveldbStateStoreTester();
testAMRMTokenSecretManagerStateStore(tester);
}
- @Test(timeout = 60000)
+ @Test
+ @Timeout(value = 60)
public void testReservation() throws Exception {
LeveldbStateStoreTester tester = new LeveldbStateStoreTester();
testReservationStateStore(tester);
}
- @Test(timeout = 60000)
+ @Test
+ @Timeout(value = 60)
public void testProxyCA() throws Exception {
LeveldbStateStoreTester tester = new LeveldbStateStoreTester();
testProxyCA(tester);
}
- @Test(timeout = 60000)
+ @Test
+ @Timeout(value = 60)
public void testCompactionCycle() {
final DB mockdb = mock(DB.class);
conf.setLong(YarnConfiguration.RM_LEVELDB_COMPACTION_INTERVAL_SECS, 1);
diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/recovery/TestMemoryRMStateStore.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/recovery/TestMemoryRMStateStore.java
index cb278c06e61700..6563e8de4f449f 100644
--- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/recovery/TestMemoryRMStateStore.java
+++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/recovery/TestMemoryRMStateStore.java
@@ -22,9 +22,9 @@
import org.apache.hadoop.yarn.conf.YarnConfiguration;
import org.apache.hadoop.yarn.security.client.RMDelegationTokenIdentifier;
import org.apache.hadoop.yarn.server.resourcemanager.ResourceManager;
-import org.junit.Test;
+import org.junit.jupiter.api.Test;
-import static org.junit.Assert.assertTrue;
+import static org.junit.jupiter.api.Assertions.assertTrue;
import static org.mockito.Mockito.mock;
public class TestMemoryRMStateStore {
@@ -47,8 +47,8 @@ public synchronized void removeRMDelegationTokenState(
RMDelegationTokenIdentifier mockTokenId =
mock(RMDelegationTokenIdentifier.class);
store.removeRMDelegationToken(mockTokenId);
- assertTrue("RMStateStore should have been in fenced state",
- store.isFencedState());
+ assertTrue(store.isFencedState(),
+ "RMStateStore should have been in fenced state");
store = new MemoryRMStateStore() {
@Override
public synchronized void removeRMDelegationToken(
@@ -61,7 +61,7 @@ public synchronized void removeRMDelegationToken(
store.setResourceManager(mockRM);
store.setRMDispatcher(new RMStateStoreTestBase.TestDispatcher());
store.removeRMDelegationToken(mockTokenId);
- assertTrue("RMStateStore should have been in fenced state",
- store.isFencedState());
+ assertTrue(store.isFencedState(),
+ "RMStateStore should have been in fenced state");
}
}
diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/recovery/TestProtos.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/recovery/TestProtos.java
index d42b411a858e37..f4858f4398902a 100644
--- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/recovery/TestProtos.java
+++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/recovery/TestProtos.java
@@ -18,7 +18,8 @@
package org.apache.hadoop.yarn.server.resourcemanager.recovery;
-import static org.junit.Assert.*;
+import static org.junit.jupiter.api.Assertions.assertNotNull;
+import static org.junit.jupiter.api.Assertions.fail;
import java.util.ArrayList;
import java.util.List;
@@ -27,8 +28,7 @@
import org.apache.hadoop.yarn.api.records.NMToken;
import org.apache.hadoop.yarn.proto.YarnServerResourceManagerRecoveryProtos.EpochProto;
import org.apache.hadoop.yarn.proto.YarnServiceProtos.AllocateResponseProto;
-import org.junit.Assert;
-import org.junit.Test;
+import org.junit.jupiter.api.Test;
/**
* Simple test to verify the protos generated are valid
@@ -39,7 +39,7 @@ public class TestProtos {
public void testProtoCanBePrinted() throws Exception {
EpochProto proto = EpochProto.newBuilder().setEpoch(100).build();
String protoString = proto.toString();
- Assert.assertNotNull(protoString);
+ assertNotNull(protoString);
}
@Test
diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/recovery/TestRMStateStoreUtils.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/recovery/TestRMStateStoreUtils.java
index 889f74f9bf6329..6cfa834f879280 100644
--- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/recovery/TestRMStateStoreUtils.java
+++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/recovery/TestRMStateStoreUtils.java
@@ -23,9 +23,9 @@
import org.apache.hadoop.io.Text;
import org.apache.hadoop.yarn.security.client.RMDelegationTokenIdentifier;
import org.apache.hadoop.yarn.server.resourcemanager.recovery.records.RMDelegationTokenIdentifierData;
-import org.junit.Test;
+import org.junit.jupiter.api.Test;
-import static org.junit.Assert.assertEquals;
+import static org.junit.jupiter.api.Assertions.assertEquals;
public class TestRMStateStoreUtils {
@@ -64,8 +64,8 @@ public void testReadRMDelegationTokenIdentifierData(boolean oldFormat)
RMDelegationTokenIdentifierData identifierData
= RMStateStoreUtils.readRMDelegationTokenIdentifierData(inBuf);
- assertEquals("Found unexpected data still in the InputStream",
- -1, inBuf.read());
+ assertEquals(-1, inBuf.read(),
+ "Found unexpected data still in the InputStream");
RMDelegationTokenIdentifier identifier
= identifierData.getTokenIdentifier();
diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/recovery/TestZKRMStateStore.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/recovery/TestZKRMStateStore.java
index bbf5e2ed351c7c..47ed3760842561 100644
--- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/recovery/TestZKRMStateStore.java
+++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/recovery/TestZKRMStateStore.java
@@ -69,9 +69,10 @@
import org.apache.zookeeper.KeeperException;
import org.apache.zookeeper.ZooDefs.Perms;
import org.apache.zookeeper.data.ACL;
-import org.junit.After;
-import org.junit.Before;
-import org.junit.Test;
+import org.junit.jupiter.api.AfterEach;
+import org.junit.jupiter.api.BeforeEach;
+import org.junit.jupiter.api.Test;
+import org.junit.jupiter.api.Timeout;
import org.apache.hadoop.thirdparty.com.google.common.base.Joiner;
import org.apache.hadoop.thirdparty.com.google.common.collect.ImmutableMap;
@@ -80,12 +81,12 @@
import org.slf4j.LoggerFactory;
import static org.assertj.core.api.Assertions.assertThat;
-import static org.junit.Assert.assertArrayEquals;
-import static org.junit.Assert.assertEquals;
-import static org.junit.Assert.assertFalse;
-import static org.junit.Assert.assertNotNull;
-import static org.junit.Assert.assertTrue;
-import static org.junit.Assert.fail;
+import static org.junit.jupiter.api.Assertions.assertArrayEquals;
+import static org.junit.jupiter.api.Assertions.assertEquals;
+import static org.junit.jupiter.api.Assertions.assertFalse;
+import static org.junit.jupiter.api.Assertions.assertNotNull;
+import static org.junit.jupiter.api.Assertions.assertTrue;
+import static org.junit.jupiter.api.Assertions.fail;
import static org.mockito.Mockito.mock;
import static org.mockito.Mockito.spy;
import static org.mockito.Mockito.when;
@@ -125,13 +126,13 @@ public static CuratorFramework setupCuratorFramework(
return curatorFramework;
}
- @Before
+ @BeforeEach
public void setupCurator() throws Exception {
curatorTestingServer = setupCuratorServer();
curatorFramework = setupCuratorFramework(curatorTestingServer);
}
- @After
+ @AfterEach
public void cleanupCuratorServer() throws IOException {
curatorFramework.close();
curatorTestingServer.stop();
@@ -280,7 +281,8 @@ public int getDelegationTokenNodeSplitIndex() {
}
}
- @Test (timeout = 60000)
+ @Test
+ @Timeout(value = 60)
public void testZKRMStateStoreRealZK() throws Exception {
TestZKRMStateStoreTester zkTester = new TestZKRMStateStoreTester();
testRMAppStateStore(zkTester);
@@ -333,7 +335,8 @@ public void handle(Event event) {
;
}
- @Test (timeout = 60000)
+ @Test
+ @Timeout(value = 60)
public void testCheckMajorVersionChange() throws Exception {
TestZKRMStateStoreTester zkTester = new TestZKRMStateStoreTester() {
Version VERSION_INFO = Version.newInstance(Integer.MAX_VALUE, 0);
@@ -376,8 +379,8 @@ protected synchronized void storeVersion() throws Exception {
RMStateStore store = zkTester.getRMStateStore();
Version defaultVersion = zkTester.getCurrentVersion();
store.checkVersion();
- assertEquals("Store had wrong version",
- defaultVersion, store.loadVersion());
+ assertEquals(
+ defaultVersion, store.loadVersion(), "Store had wrong version");
}
public static Configuration createHARMConf(String rmIds, String rmId,
@@ -487,22 +490,22 @@ public void testFencing() throws Exception {
ResourceManager rm1 = new MockRM(conf1);
rm1.start();
rm1.getRMContext().getRMAdminService().transitionToActive(req);
- assertEquals("RM with ZKStore didn't start",
- Service.STATE.STARTED, rm1.getServiceState());
- assertEquals("RM should be Active",
- HAServiceProtocol.HAServiceState.ACTIVE,
- rm1.getRMContext().getRMAdminService().getServiceStatus().getState());
+ assertEquals(Service.STATE.STARTED, rm1.getServiceState(),
+ "RM with ZKStore didn't start");
+ assertEquals(HAServiceProtocol.HAServiceState.ACTIVE,
+ rm1.getRMContext().getRMAdminService().getServiceStatus().getState(),
+ "RM should be Active");
Configuration conf2 =
createHARMConf("rm1,rm2", "rm2", 5678, false, curatorTestingServer);
ResourceManager rm2 = new MockRM(conf2);
rm2.start();
rm2.getRMContext().getRMAdminService().transitionToActive(req);
- assertEquals("RM with ZKStore didn't start",
- Service.STATE.STARTED, rm2.getServiceState());
- assertEquals("RM should be Active",
- HAServiceProtocol.HAServiceState.ACTIVE,
- rm2.getRMContext().getRMAdminService().getServiceStatus().getState());
+ assertEquals(Service.STATE.STARTED, rm2.getServiceState(),
+ "RM with ZKStore didn't start");
+ assertEquals(HAServiceProtocol.HAServiceState.ACTIVE,
+ rm2.getRMContext().getRMAdminService().getServiceStatus().getState(),
+ "RM should be Active");
for (int i = 0; i < ZK_TIMEOUT_MS / 50; i++) {
if (HAServiceProtocol.HAServiceState.ACTIVE ==
@@ -510,12 +513,12 @@ public void testFencing() throws Exception {
Thread.sleep(100);
}
}
- assertEquals("RM should have been fenced",
- HAServiceProtocol.HAServiceState.STANDBY,
- rm1.getRMContext().getRMAdminService().getServiceStatus().getState());
- assertEquals("RM should be Active",
- HAServiceProtocol.HAServiceState.ACTIVE,
- rm2.getRMContext().getRMAdminService().getServiceStatus().getState());
+ assertEquals(HAServiceProtocol.HAServiceState.STANDBY,
+ rm1.getRMContext().getRMAdminService().getServiceStatus().getState(),
+ "RM should have been fenced");
+ assertEquals(HAServiceProtocol.HAServiceState.ACTIVE,
+ rm2.getRMContext().getRMAdminService().getServiceStatus().getState(),
+ "RM should be Active");
rm1.close();
rm2.close();
}
@@ -527,8 +530,8 @@ public void testFencedState() throws Exception {
// Move state to FENCED from ACTIVE
store.updateFencedState();
- assertEquals("RMStateStore should have been in fenced state",
- true, store.isFencedState());
+ assertEquals(true, store.isFencedState(),
+ "RMStateStore should have been in fenced state");
long submitTime = System.currentTimeMillis();
long startTime = submitTime + 1000;
@@ -542,8 +545,8 @@ public void testFencedState() throws Exception {
when(mockApp.getApplicationSubmissionContext()).thenReturn(context);
when(mockApp.getUser()).thenReturn("test");
store.storeNewApplication(mockApp);
- assertEquals("RMStateStore should have been in fenced state",
- true, store.isFencedState());
+ assertEquals(true, store.isFencedState(),
+ "RMStateStore should have been in fenced state");
// Add a new attempt
ClientToAMTokenSecretManagerInRM clientToAMTokenMgr =
@@ -566,8 +569,8 @@ public void testFencedState() throws Exception {
when(mockRmAppAttemptMetrics.getAggregateAppResourceUsage())
.thenReturn(new AggregateAppResourceUsage(new HashMap<>()));
store.storeNewApplicationAttempt(mockAttempt);
- assertEquals("RMStateStore should have been in fenced state",
- true, store.isFencedState());
+ assertEquals(true, store.isFencedState(),
+ "RMStateStore should have been in fenced state");
long finishTime = submitTime + 1000;
// Update attempt
@@ -578,20 +581,20 @@ public void testFencedState() throws Exception {
"test", FinalApplicationStatus.SUCCEEDED, 100,
finishTime, new HashMap<>(), new HashMap<>(), 0);
store.updateApplicationAttemptState(newAttemptState);
- assertEquals("RMStateStore should have been in fenced state",
- true, store.isFencedState());
+ assertEquals(true, store.isFencedState(),
+ "RMStateStore should have been in fenced state");
// Update app
ApplicationStateData appState = ApplicationStateData.newInstance(submitTime,
startTime, context, "test");
store.updateApplicationState(appState);
- assertEquals("RMStateStore should have been in fenced state",
- true, store.isFencedState());
+ assertEquals(true, store.isFencedState(),
+ "RMStateStore should have been in fenced state");
// Remove app
store.removeApplication(mockApp);
- assertEquals("RMStateStore should have been in fenced state",
- true, store.isFencedState());
+ assertEquals(true, store.isFencedState(),
+ "RMStateStore should have been in fenced state");
// store RM delegation token;
RMDelegationTokenIdentifier dtId1 =
@@ -599,43 +602,40 @@ public void testFencedState() throws Exception {
new Text("renewer1"), new Text("realuser1"));
Long renewDate1 = new Long(System.currentTimeMillis());
dtId1.setSequenceNumber(1111);
- assertFalse("Token " + dtId1
- + " should not exist but was found in ZooKeeper",
- zkTester.delegationTokenExists(dtId1, 0));
+ assertFalse(zkTester.delegationTokenExists(dtId1, 0),
+ "Token " + dtId1 + " should not exist but was found in ZooKeeper");
store.storeRMDelegationToken(dtId1, renewDate1);
- assertFalse("Token " + dtId1
- + " should not exist but was found in ZooKeeper",
- zkTester.delegationTokenExists(dtId1, 0));
- assertEquals("RMStateStore should have been in fenced state", true,
- store.isFencedState());
+ assertFalse(zkTester.delegationTokenExists(dtId1, 0),
+ "Token " + dtId1 + " should not exist but was found in ZooKeeper");
+ assertEquals(true, store.isFencedState(),
+ "RMStateStore should have been in fenced state");
store.updateRMDelegationToken(dtId1, renewDate1);
- assertFalse("Token " + dtId1
- + " should not exist but was found in ZooKeeper",
- zkTester.delegationTokenExists(dtId1, 0));
- assertEquals("RMStateStore should have been in fenced state", true,
- store.isFencedState());
+ assertFalse(zkTester.delegationTokenExists(dtId1, 0), "Token " + dtId1
+ + " should not exist but was found in ZooKeeper");
+ assertEquals(true, store.isFencedState(),
+ "RMStateStore should have been in fenced state");
// remove delegation key;
store.removeRMDelegationToken(dtId1);
- assertEquals("RMStateStore should have been in fenced state", true,
- store.isFencedState());
+ assertEquals(true, store.isFencedState(),
+ "RMStateStore should have been in fenced state");
// store delegation master key;
DelegationKey key = new DelegationKey(1234, 4321, "keyBytes".getBytes());
store.storeRMDTMasterKey(key);
- assertEquals("RMStateStore should have been in fenced state", true,
- store.isFencedState());
+ assertEquals(true, store.isFencedState(),
+ "RMStateStore should have been in fenced state");
// remove delegation master key;
store.removeRMDTMasterKey(key);
- assertEquals("RMStateStore should have been in fenced state", true,
- store.isFencedState());
+ assertEquals(true, store.isFencedState(),
+ "RMStateStore should have been in fenced state");
// store or update AMRMToken;
store.storeOrUpdateAMRMTokenSecretManager(null, false);
- assertEquals("RMStateStore should have been in fenced state", true,
- store.isFencedState());
+ assertEquals(true, store.isFencedState(),
+ "RMStateStore should have been in fenced state");
store.close();
}
@@ -707,19 +707,20 @@ private static void verifyLoadedApp(ApplicationStateData appState,
ApplicationId appId, String user, long submitTime, long startTime,
RMAppState state, long finishTime, String diagnostics) {
// Check if app is loaded correctly
- assertNotNull("App " + appId + " should have been loaded.", appState);
- assertEquals("App submit time in app state", submitTime,
- appState.getSubmitTime());
- assertEquals("App start time in app state", startTime,
- appState.getStartTime());
- assertEquals("App ID in app state", appId,
- appState.getApplicationSubmissionContext().getApplicationId());
- assertEquals("App state", state, appState.getState());
- assertEquals("Finish time in app state", finishTime,
- appState.getFinishTime());
- assertEquals("User in app state", user, appState.getUser());
- assertEquals("Diagnostics in app state", diagnostics,
- appState.getDiagnostics());
+ assertNotNull(appState, "App " + appId + " should have been loaded.");
+ assertEquals(submitTime,
+ appState.getSubmitTime(), "App submit time in app state");
+ assertEquals(startTime,
+ appState.getStartTime(), "App start time in app state");
+ assertEquals(appId,
+ appState.getApplicationSubmissionContext().getApplicationId(),
+ "App ID in app state");
+ assertEquals(state, appState.getState(), "App state");
+ assertEquals(finishTime,
+ appState.getFinishTime(), "Finish time in app state");
+ assertEquals(user, appState.getUser(), "User in app state");
+ assertEquals(diagnostics,
+ appState.getDiagnostics(), "Diagnostics in app state");
}
private static void verifyLoadedApp(RMState rmState,
@@ -737,14 +738,14 @@ private static void verifyLoadedApp(RMState rmState,
Map rmAppState =
rmState.getApplicationState();
ApplicationStateData appState = rmAppState.get(appId);
- assertNotNull(appId + " is not there in loaded apps", appState);
+ assertNotNull(appState, appId + " is not there in loaded apps");
verifyLoadedApp(appState, appId, "test", submitTime, startTime,
isFinished ? RMAppState.FINISHED : null, finishTime,
isFinished ? "appDiagnostics" : "");
// Check attempt state.
if (attempts != null) {
- assertEquals("Attempts loaded for app " + appId, attempts.size(),
- appState.attempts.size());
+ assertEquals(attempts.size(),
+ appState.attempts.size(), "Attempts loaded for app " + appId);
if (finalStatuses != null && amExitStatuses != null) {
for (int i = 0; i < attempts.size(); i++) {
if (finalStatuses.get(i) != null) {
@@ -757,8 +758,8 @@ private static void verifyLoadedApp(RMState rmState,
}
}
} else {
- assertEquals(
- "Attempts loaded for app " + appId, 0, appState.attempts.size());
+ assertEquals(0, appState.attempts.size(),
+ "Attempts loaded for app " + appId);
}
}
@@ -778,28 +779,29 @@ private static void verifyLoadedAttempt(ApplicationStateData appState,
int amExitStatus, FinalApplicationStatus finalStatus) {
ApplicationAttemptStateData attemptState = appState.getAttempt(attemptId);
// Check if attempt is loaded correctly
- assertNotNull(
- "Attempt " + attemptId + " should have been loaded.", attemptState);
- assertEquals("Attempt Id in attempt state",
- attemptId, attemptState.getAttemptId());
- assertEquals("Master Container Id in attempt state",
- masterContainerId, attemptState.getMasterContainer().getId());
+ assertNotNull(attemptState,
+ "Attempt " + attemptId + " should have been loaded.");
+ assertEquals(attemptId, attemptState.getAttemptId(),
+ "Attempt Id in attempt state");
+ assertEquals(masterContainerId, attemptState.getMasterContainer().getId(),
+ "Master Container Id in attempt state");
if (null != clientTokenKey) {
- assertArrayEquals("Client token key in attempt state",
- clientTokenKey.getEncoded(), attemptState.getAppAttemptTokens().
- getSecretKey(RMStateStore.AM_CLIENT_TOKEN_MASTER_KEY_NAME));
+ assertArrayEquals(clientTokenKey.getEncoded(),
+ attemptState.getAppAttemptTokens().
+ getSecretKey(RMStateStore.AM_CLIENT_TOKEN_MASTER_KEY_NAME),
+ "Client token key in attempt state");
}
- assertEquals("Attempt state", state, attemptState.getState());
- assertEquals("Finish time in attempt state", finishTime,
- attemptState.getFinishTime());
- assertEquals("Diagnostics in attempt state", diagnostics,
- attemptState.getDiagnostics());
- assertEquals("AM Container exit status in attempt state", amExitStatus,
- attemptState.getAMContainerExitStatus());
- assertEquals("Final app status in attempt state", finalStatus,
- attemptState.getFinalApplicationStatus());
- assertEquals("Tracking URL in attempt state", trackingURL,
- attemptState.getFinalTrackingUrl());
+ assertEquals(state, attemptState.getState(), "Attempt state");
+ assertEquals(finishTime, attemptState.getFinishTime(),
+ "Finish time in attempt state");
+ assertEquals(diagnostics, attemptState.getDiagnostics(),
+ "Diagnostics in attempt state");
+ assertEquals(amExitStatus, attemptState.getAMContainerExitStatus(),
+ "AM Container exit status in attempt state");
+ assertEquals(finalStatus, attemptState.getFinalApplicationStatus(),
+ "Final app status in attempt state");
+ assertEquals(trackingURL, attemptState.getFinalTrackingUrl(),
+ "Tracking URL in attempt state");
}
private static ApplicationStateData createAppState(
@@ -931,8 +933,9 @@ private static void verifyAppPathPath(RMStateStore store, ApplicationId appId,
ZKRMStateStore.ROOT_ZNODE_NAME, ZKRMStateStore.RM_APP_ROOT,
ZKRMStateStore.RM_APP_ROOT_HIERARCHIES, String.valueOf(splitIndex),
appParent, appPath);
- assertTrue("Application with id " + appIdStr + " does not exist as per " +
- "split in state store.", ((ZKRMStateStore)store).exists(path));
+ assertTrue(((ZKRMStateStore)store).exists(path),
+ "Application with id " + appIdStr + " does not exist as per " +
+ "split in state store.");
}
private static void verifyAppInHierarchicalPath(RMStateStore store,
@@ -946,8 +949,8 @@ private static void verifyAppInHierarchicalPath(RMStateStore store,
} else {
path = createPath(path, appId);
}
- assertTrue(appId + " should exist in path " + path,
- ((ZKRMStateStore)store).exists(createPath(path)));
+ assertTrue(((ZKRMStateStore)store).exists(createPath(path)),
+ appId + " should exist in path " + path);
}
private static void assertHierarchicalPaths(RMStateStore store,
@@ -959,9 +962,8 @@ private static void assertHierarchicalPaths(RMStateStore store,
path = createPath(path, ZKRMStateStore.RM_APP_ROOT_HIERARCHIES,
String.valueOf(entry.getKey()));
}
- assertEquals("Number of childrens for path " + path,
- (int) entry.getValue(),
- ((ZKRMStateStore)store).getChildren(path).size());
+ assertEquals((int) entry.getValue(), ((ZKRMStateStore)store).getChildren(path).size(),
+ "Number of childrens for path " + path);
}
}
@@ -1056,7 +1058,7 @@ public void testAppNodeSplit() throws Exception {
FinalApplicationStatus.SUCCEEDED));
// assert store is in expected state after everything is cleaned
- assertTrue("Store is not in expected state", zkTester.isFinalStateValid());
+ assertTrue(zkTester.isFinalStateValid(), "Store is not in expected state");
store.close();
}
@@ -1128,8 +1130,8 @@ public void testAppNodeSplitChangeAcrossRestarts() throws Exception {
store = zkTester.getRMStateStore(createConfForAppNodeSplit(0));
store.setRMDispatcher(dispatcher);
state = store.loadState();
- assertEquals("Number of Apps loaded should be 4.", 4,
- state.getApplicationState().size());
+ assertEquals(4, state.getApplicationState().size(),
+ "Number of Apps loaded should be 4.");
verifyLoadedApp(state, appId1, submitTime, startTime, 1234, true,
Lists.newArrayList(attemptId1, attemptId2), Lists.newArrayList(-1000,
100), Lists.newArrayList(null, FinalApplicationStatus.SUCCEEDED));
@@ -1144,8 +1146,8 @@ public void testAppNodeSplitChangeAcrossRestarts() throws Exception {
store = zkTester.getRMStateStore(createConfForAppNodeSplit(3));
store.setRMDispatcher(dispatcher);
state = store.loadState();
- assertEquals("Number of apps loaded should be 5.", 5,
- state.getApplicationState().size());
+ assertEquals(5, state.getApplicationState().size(),
+ "Number of apps loaded should be 5.");
verifyLoadedApp(state, dummyAppId, submitTime, startTime, 1234, true,
Lists.newArrayList(dummyAttemptId), Lists.newArrayList(111),
Lists.newArrayList(FinalApplicationStatus.SUCCEEDED));
@@ -1192,8 +1194,8 @@ public void testAppNodeSplitChangeAcrossRestarts() throws Exception {
store = zkTester.getRMStateStore(createConfForAppNodeSplit(3));
store.setRMDispatcher(dispatcher);
state = store.loadState();
- assertEquals("Number of apps loaded should be 0.", 0,
- state.getApplicationState().size());
+ assertEquals(0, state.getApplicationState().size(),
+ "Number of apps loaded should be 0.");
// Close the state store.
store.close();
}
@@ -1213,16 +1215,15 @@ private void verifyDelegationTokensStateStore(
int sequenceNumber) throws Exception {
RMStateStore.RMDTSecretManagerState secretManagerState =
zkTester.store.loadState().getRMDTSecretManagerState();
- assertEquals("Unexpected token state",
- tokensWithRenewal, secretManagerState.getTokenState());
- assertEquals("Unexpected sequence number", sequenceNumber,
- secretManagerState.getDTSequenceNumber());
+ assertEquals(tokensWithRenewal, secretManagerState.getTokenState(),
+ "Unexpected token state");
+ assertEquals(sequenceNumber, secretManagerState.getDTSequenceNumber(),
+ "Unexpected sequence number");
for (Map.Entry tokenEntry
: tokensWithIndex.entrySet()) {
- assertTrue("Expected to find token " + tokenEntry.getKey()
- + " in zookeeper but did not",
- zkTester.delegationTokenExists(tokenEntry.getKey(),
- tokenEntry.getValue()));
+ assertTrue(zkTester.delegationTokenExists(tokenEntry.getKey(),
+ tokenEntry.getValue()), "Expected to find token " + tokenEntry.getKey()
+ + " in zookeeper but did not");
}
}
@@ -1233,12 +1234,12 @@ private void verifyDelegationTokenInStateStore(
zkTester.store.loadState().getRMDTSecretManagerState();
Map tokenState =
secretManagerState.getTokenState();
- assertTrue("token state does not contain " + token,
- tokenState.containsKey(token));
- assertTrue("token state does not contain a token with renewal " + renewDate,
- tokenState.containsValue(renewDate));
- assertTrue("Token " + token + "should exist but was not found in ZooKeeper",
- zkTester.delegationTokenExists(token, index));
+ assertTrue(tokenState.containsKey(token),
+ "token state does not contain " + token);
+ assertTrue(tokenState.containsValue(renewDate),
+ "token state does not contain a token with renewal " + renewDate);
+ assertTrue(zkTester.delegationTokenExists(token, index),
+ "Token " + token + "should exist but was not found in ZooKeeper");
}
private RMDelegationTokenIdentifier storeUpdateAndVerifyDelegationToken(
@@ -1250,8 +1251,8 @@ private RMDelegationTokenIdentifier storeUpdateAndVerifyDelegationToken(
RMDelegationTokenIdentifier token =
new RMDelegationTokenIdentifier(new Text("owner"),
new Text("renewer"), new Text("realuser"));
- assertFalse("Token should not exist but was found in ZooKeeper",
- zkTester.delegationTokenExists(token, split));
+ assertFalse(zkTester.delegationTokenExists(token, split),
+ "Token should not exist but was found in ZooKeeper");
token.setSequenceNumber(sequenceNumber);
Long renewDate = System.currentTimeMillis();
zkTester.store.storeRMDelegationToken(token, renewDate);
@@ -1281,28 +1282,28 @@ public void testDelegationTokenSplitIndexConfig() throws Exception {
// Valid values
TestZKRMStateStoreTester zkTester = new TestZKRMStateStoreTester();
zkTester.getRMStateStore(createConfForDelegationTokenNodeSplit(0)).close();
- assertEquals("Incorrect split index",
- 0, zkTester.getDelegationTokenNodeSplitIndex());
+ assertEquals(0, zkTester.getDelegationTokenNodeSplitIndex(),
+ "Incorrect split index");
zkTester.getRMStateStore(createConfForDelegationTokenNodeSplit(1)).close();
- assertEquals("Incorrect split index",
- 1, zkTester.getDelegationTokenNodeSplitIndex());
+ assertEquals(1, zkTester.getDelegationTokenNodeSplitIndex(),
+ "Incorrect split index");
zkTester.getRMStateStore(createConfForDelegationTokenNodeSplit(2)).close();
- assertEquals("Incorrect split index",
- 2, zkTester.getDelegationTokenNodeSplitIndex());
+ assertEquals(2, zkTester.getDelegationTokenNodeSplitIndex(),
+ "Incorrect split index");
zkTester.getRMStateStore(createConfForDelegationTokenNodeSplit(3)).close();
- assertEquals("Incorrect split index",
- 3, zkTester.getDelegationTokenNodeSplitIndex());
+ assertEquals(3, zkTester.getDelegationTokenNodeSplitIndex(),
+ "Incorrect split index");
zkTester.getRMStateStore(createConfForDelegationTokenNodeSplit(4)).close();
- assertEquals("Incorrect split index",
- 4, zkTester.getDelegationTokenNodeSplitIndex());
+ assertEquals(4, zkTester.getDelegationTokenNodeSplitIndex(),
+ "Incorrect split index");
// Invalid values --> override to 0
zkTester.getRMStateStore(createConfForDelegationTokenNodeSplit(-1)).close();
- assertEquals("Incorrect split index",
- 0, zkTester.getDelegationTokenNodeSplitIndex());
+ assertEquals(0, zkTester.getDelegationTokenNodeSplitIndex(),
+ "Incorrect split index");
zkTester.getRMStateStore(createConfForDelegationTokenNodeSplit(5)).close();
- assertEquals("Incorrect split index",
- 0, zkTester.getDelegationTokenNodeSplitIndex());
+ assertEquals(0, zkTester.getDelegationTokenNodeSplitIndex(),
+ "Incorrect split index");
}
@Test
@@ -1348,12 +1349,12 @@ public void testDelegationTokenNode(int split) throws Exception {
store.loadState().getRMDTSecretManagerState();
tokensWithRenewal.clear();
tokensWithIndex.clear();
- assertEquals("Unexpected token state",
- tokensWithRenewal, state.getTokenState());
- assertEquals("Unexpected sequence number",
- sequenceNumber, state.getDTSequenceNumber());
- assertFalse("Token should not exist but was found in ZooKeeper",
- zkTester.delegationTokenExists(token, split));
+ assertEquals(tokensWithRenewal, state.getTokenState(),
+ "Unexpected token state");
+ assertEquals(sequenceNumber, state.getDTSequenceNumber(),
+ "Unexpected sequence number");
+ assertFalse(zkTester.delegationTokenExists(token, split),
+ "Token should not exist but was found in ZooKeeper");
store.close();
}
@@ -1375,8 +1376,8 @@ public void testDelegationTokenNodeWithSplitMultiple() throws Exception {
new Text("renewer" + i), new Text("realuser" + i));
sequenceNumber = i;
token.setSequenceNumber(sequenceNumber);
- assertFalse("Token should not exist but was found in ZooKeeper",
- zkTester.delegationTokenExists(token, 1));
+ assertFalse(zkTester.delegationTokenExists(token, 1),
+ "Token should not exist but was found in ZooKeeper");
Long renewDate = System.currentTimeMillis();
store.storeRMDelegationToken(token, renewDate);
modifyRMDelegationTokenState();
@@ -1419,9 +1420,8 @@ public void testDelegationTokenNodeWithSplitMultiple() throws Exception {
verifyDelegationTokensStateStore(zkTester, tokensWithRenewal,
tokensWithIndex, sequenceNumber);
for (RMDelegationTokenIdentifier token : tokensToDelete) {
- assertFalse("Token " + token
- + " should not exist but was found in ZooKeeper",
- zkTester.delegationTokenExists(token, 1));
+ assertFalse(zkTester.delegationTokenExists(token, 1),
+ "Token " + token + " should not exist but was found in ZooKeeper");
}
store.close();
}
@@ -1495,15 +1495,12 @@ public void testDelegationTokenNodeWithSplitChangeAcrossRestarts()
tokensWithIndex.clear();
verifyDelegationTokensStateStore(
zkTester, tokensWithRenewal, tokensWithIndex, sequenceNumber);
- assertFalse("Token " + token1
- + " should not exist but was found in ZooKeeper",
- zkTester.delegationTokenExists(token1, 1));
- assertFalse("Token " + token1
- + " should not exist but was found in ZooKeeper",
- zkTester.delegationTokenExists(token2, 2));
- assertFalse("Token " + token1
- + " should not exist but was found in ZooKeeper",
- zkTester.delegationTokenExists(token0, 0));
+ assertFalse(zkTester.delegationTokenExists(token1, 1),
+ "Token " + token1 + " should not exist but was found in ZooKeeper");
+ assertFalse(zkTester.delegationTokenExists(token2, 2), "Token " + token1 +
+ " should not exist but was found in ZooKeeper");
+ assertFalse(zkTester.delegationTokenExists(token0, 0), "Token " + token1 +
+ " should not exist but was found in ZooKeeper");
// Store a token with index 3
sequenceNumber++;
storeUpdateAndVerifyDelegationToken(zkTester, tokensWithRenewal,
@@ -1550,10 +1547,11 @@ public void testAppSubmissionContextIsPrunedInFinalApplicationState()
ctx = rmState.getApplicationState().get(appId)
.getApplicationSubmissionContext();
- assertEquals("ApplicationSchedulingPropertiesMap should not have been "
+ assertEquals(schedulingPropertiesMap,
+ ctx.getApplicationSchedulingPropertiesMap(),
+ "ApplicationSchedulingPropertiesMap should not have been "
+ "pruned from the application submission context before the "
- + "FINISHED state",
- schedulingPropertiesMap, ctx.getApplicationSchedulingPropertiesMap());
+ + "FINISHED state");
appState.setState(RMAppState.FINISHED);
store.handleStoreEvent(new RMStateUpdateAppEvent(appState, false, null));
@@ -1566,9 +1564,9 @@ public void testAppSubmissionContextIsPrunedInFinalApplicationState()
assertEquals("a_queue", ctx.getQueue());
assertNotNull(ctx.getAMContainerSpec());
assertEquals(17L, ctx.getResource().getMemorySize());
- assertEquals("ApplicationSchedulingPropertiesMap should have been pruned"
- + " from the application submission context when in FINISHED STATE",
- Collections.emptyMap(), ctx.getApplicationSchedulingPropertiesMap());
+ assertEquals(Collections.emptyMap(), ctx.getApplicationSchedulingPropertiesMap(),
+ "ApplicationSchedulingPropertiesMap should have been pruned"
+ + " from the application submission context when in FINISHED STATE");
store.close();
}
@@ -1589,8 +1587,8 @@ public void testMetricsInited() throws Exception {
Thread.sleep(110);
opDurations.getMetrics(collector, true);
- assertEquals("Incorrect number of perf metrics", 1,
- collector.getRecords().size());
+ assertEquals(1, collector.getRecords().size(),
+ "Incorrect number of perf metrics");
MetricsRecord record = collector.getRecords().get(0);
MetricsRecords.assertTag(record,
ZKRMStateStoreOpDurations.RECORD_INFO.name(),
diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/recovery/TestZKRMStateStorePerf.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/recovery/TestZKRMStateStorePerf.java
index 3cb428c5c5960f..c0ac6bcc2b4a12 100644
--- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/recovery/TestZKRMStateStorePerf.java
+++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/recovery/TestZKRMStateStorePerf.java
@@ -45,9 +45,9 @@
import org.apache.hadoop.yarn.server.resourcemanager.rmapp.RMApp;
import org.apache.hadoop.yarn.server.resourcemanager.security.AMRMTokenSecretManager;
import org.apache.hadoop.yarn.server.resourcemanager.security.ClientToAMTokenSecretManagerInRM;
-import org.junit.After;
-import org.junit.Before;
-import org.junit.Test;
+import org.junit.jupiter.api.AfterEach;
+import org.junit.jupiter.api.BeforeEach;
+import org.junit.jupiter.api.Test;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -78,12 +78,12 @@ public class TestZKRMStateStorePerf extends RMStateStoreTestBase
private ClientToAMTokenSecretManagerInRM clientToAMTokenMgr;
private TestingServer curatorTestingServer;
- @Before
+ @BeforeEach
public void setUpZKServer() throws Exception {
curatorTestingServer = new TestingServer();
}
- @After
+ @AfterEach
public void tearDown() throws Exception {
if (store != null) {
store.stop();
diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/recovery/TestZKRMStateStoreZKClientConnections.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/recovery/TestZKRMStateStoreZKClientConnections.java
index dce2bed5522e70..d41c8235b5c8c0 100644
--- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/recovery/TestZKRMStateStoreZKClientConnections.java
+++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/recovery/TestZKRMStateStoreZKClientConnections.java
@@ -29,16 +29,17 @@
import org.apache.hadoop.util.ZKUtil;
import org.apache.zookeeper.server.auth.DigestAuthenticationProvider;
-import org.junit.After;
-import org.junit.Assert;
-import org.junit.Before;
-import org.junit.Test;
+import org.junit.jupiter.api.AfterEach;
+import org.junit.jupiter.api.BeforeEach;
+import org.junit.jupiter.api.Test;
+import org.junit.jupiter.api.Timeout;
import java.security.NoSuchAlgorithmException;
import java.util.concurrent.atomic.AtomicBoolean;
-import static org.junit.Assert.assertTrue;
-import static org.junit.Assert.fail;
+import static org.junit.jupiter.api.Assertions.assertFalse;
+import static org.junit.jupiter.api.Assertions.assertTrue;
+import static org.junit.jupiter.api.Assertions.fail;
public class TestZKRMStateStoreZKClientConnections {
private static final Logger LOG =
@@ -60,13 +61,13 @@ public class TestZKRMStateStoreZKClientConnections {
private TestingServer testingServer;
- @Before
+ @BeforeEach
public void setupZKServer() throws Exception {
testingServer = new TestingServer();
testingServer.start();
}
- @After
+ @AfterEach
public void cleanupZKServer() throws Exception {
testingServer.stop();
}
@@ -96,7 +97,8 @@ public RMStateStore getRMStateStore(Configuration conf) throws Exception {
}
}
- @Test (timeout = 20000)
+ @Test
+ @Timeout(value = 20)
public void testZKClientRetry() throws Exception {
TestZKClient zkClientTester = new TestZKClient();
final String path = "/test";
@@ -124,10 +126,11 @@ public void run() {
Thread.sleep(2000);
testingServer.start();
clientThread.join();
- Assert.assertFalse(assertionFailedInThread.get());
+ assertFalse(assertionFailedInThread.get());
}
- @Test(timeout = 20000)
+ @Test
+ @Timeout(value = 20)
public void testSetZKAcl() {
TestZKClient zkClientTester = new TestZKClient();
YarnConfiguration conf = new YarnConfiguration();
@@ -140,7 +143,8 @@ public void testSetZKAcl() {
}
}
- @Test(timeout = 20000)
+ @Test
+ @Timeout(value = 20)
public void testInvalidZKAclConfiguration() {
TestZKClient zkClientTester = new TestZKClient();
YarnConfiguration conf = new YarnConfiguration();
diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/reservation/BaseSharingPolicyTest.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/reservation/BaseSharingPolicyTest.java
index b9ce54e6a5cbe5..1495dd8c2d3e84 100644
--- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/reservation/BaseSharingPolicyTest.java
+++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/reservation/BaseSharingPolicyTest.java
@@ -17,8 +17,8 @@
*******************************************************************************/
package org.apache.hadoop.yarn.server.resourcemanager.reservation;
-import static junit.framework.TestCase.fail;
-import static org.junit.Assert.assertTrue;
+import static org.junit.jupiter.api.Assertions.fail;
+import static org.junit.jupiter.api.Assertions.assertTrue;
import static org.mockito.Mockito.mock;
import java.io.IOException;
@@ -33,33 +33,25 @@
import org.apache.hadoop.yarn.util.resource.DefaultResourceCalculator;
import org.apache.hadoop.yarn.util.resource.ResourceCalculator;
import org.apache.hadoop.yarn.util.resource.Resources;
-import org.junit.Before;
-import org.junit.runner.RunWith;
-import org.junit.runners.Parameterized;
+import org.junit.jupiter.api.BeforeEach;
import net.jcip.annotations.NotThreadSafe;
/**
* This class is a base test for {@code SharingPolicy} implementors.
*/
-@RunWith(value = Parameterized.class)
@NotThreadSafe
@SuppressWarnings("VisibilityModifier")
public abstract class BaseSharingPolicyTest {
- @Parameterized.Parameter(value = 0)
public long duration;
- @Parameterized.Parameter(value = 1)
public double height;
- @Parameterized.Parameter(value = 2)
public int numSubmissions;
- @Parameterized.Parameter(value = 3)
public String recurrenceExpression;
- @Parameterized.Parameter(value = 4)
public Class expectedError;
private long step;
@@ -75,7 +67,7 @@ public abstract class BaseSharingPolicyTest {
protected ReservationSchedulerConfiguration conf;
- @Before
+ @BeforeEach
public void setup() {
// 1 sec step
step = 1000L;
@@ -138,7 +130,7 @@ public void runTest() throws IOException, PlanningException {
"dedicated", rstart, rend, reservationIntervalResourceMap, res,
minAlloc);
- assertTrue(plan.toString(), plan.addReservation(resAlloc, false));
+ assertTrue(plan.addReservation(resAlloc, false), plan.toString());
}
// fail if error was expected
if (expectedError != null) {
diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/reservation/ReservationSystemTestUtil.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/reservation/ReservationSystemTestUtil.java
index 7e172aee353086..59b476c7bc19ba 100644
--- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/reservation/ReservationSystemTestUtil.java
+++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/reservation/ReservationSystemTestUtil.java
@@ -17,6 +17,10 @@
*****************************************************************************/
package org.apache.hadoop.yarn.server.resourcemanager.reservation;
+import static org.junit.jupiter.api.Assertions.assertEquals;
+import static org.junit.jupiter.api.Assertions.assertNotNull;
+import static org.junit.jupiter.api.Assertions.assertTrue;
+import static org.junit.jupiter.api.Assertions.fail;
import static org.mockito.ArgumentMatchers.any;
import static org.mockito.ArgumentMatchers.anySet;
import static org.mockito.Mockito.doReturn;
@@ -65,8 +69,7 @@
import org.apache.hadoop.yarn.server.resourcemanager.security.NMTokenSecretManagerInRM;
import org.apache.hadoop.yarn.server.resourcemanager.security.RMContainerTokenSecretManager;
import org.apache.hadoop.yarn.util.resource.DefaultResourceCalculator;
-import org.junit.Assert;
-import org.mockito.Mockito;
+import org.junit.jupiter.api.Assertions;
import org.mockito.invocation.InvocationOnMock;
import org.mockito.stubbing.Answer;
@@ -112,13 +115,13 @@ public static ReservationSchedulerConfiguration createConf(
public static void validateReservationQueue(
AbstractReservationSystem reservationSystem, String planQName) {
Plan plan = reservationSystem.getPlan(planQName);
- Assert.assertNotNull(plan);
- Assert.assertTrue(plan instanceof InMemoryPlan);
- Assert.assertEquals(planQName, plan.getQueueName());
- Assert.assertEquals(8192, plan.getTotalCapacity().getMemorySize());
- Assert.assertTrue(
+ assertNotNull(plan);
+ assertTrue(plan instanceof InMemoryPlan);
+ assertEquals(planQName, plan.getQueueName());
+ assertEquals(8192, plan.getTotalCapacity().getMemorySize());
+ assertTrue(
plan.getReservationAgent() instanceof AlignedPlannerWithGreedy);
- Assert
+ Assertions
.assertTrue(plan.getSharingPolicy() instanceof CapacityOverTimePolicy);
}
@@ -247,7 +250,7 @@ public CapacityScheduler mockCapacityScheduler(int numContainers)
CapacitySchedulerConfiguration conf = new CapacitySchedulerConfiguration();
setupQueueConfiguration(conf);
- CapacityScheduler cs = Mockito.spy(new CapacityScheduler());
+ CapacityScheduler cs = spy(new CapacityScheduler());
cs.setConf(new YarnConfiguration());
RMContext mockRmContext = createRMContext(conf);
@@ -256,7 +259,7 @@ public CapacityScheduler mockCapacityScheduler(int numContainers)
try {
cs.serviceInit(conf);
} catch (Exception e) {
- Assert.fail(e.getMessage());
+ fail(e.getMessage());
}
initializeRMContext(numContainers, cs, mockRmContext);
@@ -273,7 +276,7 @@ public static void initializeRMContext(int numContainers,
}
public static RMContext createRMContext(Configuration conf) {
- RMContext mockRmContext = Mockito.spy(new RMContextImpl(null, null, null,
+ RMContext mockRmContext = spy(new RMContextImpl(null, null, null,
null, null, null, new RMContainerTokenSecretManager(conf),
new NMTokenSecretManagerInRM(conf),
new ClientToAMTokenSecretManagerInRM(), null));
diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/reservation/TestCapacityOverTimePolicy.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/reservation/TestCapacityOverTimePolicy.java
index a988211d78f14d..afcee0fd716cbd 100644
--- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/reservation/TestCapacityOverTimePolicy.java
+++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/reservation/TestCapacityOverTimePolicy.java
@@ -25,14 +25,12 @@
import org.apache.hadoop.yarn.server.resourcemanager.reservation.exceptions.PlanningException;
import org.apache.hadoop.yarn.server.resourcemanager.reservation.exceptions.PlanningQuotaException;
-import org.junit.Test;
-import org.junit.runner.RunWith;
-import org.junit.runners.Parameterized;
+import org.junit.jupiter.params.ParameterizedTest;
+import org.junit.jupiter.params.provider.MethodSource;
/**
* This class tests the {@code CapacityOvertimePolicy} sharing policy.
*/
-@RunWith(value = Parameterized.class)
@NotThreadSafe
@SuppressWarnings("VisibilityModifier")
public class TestCapacityOverTimePolicy extends BaseSharingPolicyTest {
@@ -43,8 +41,16 @@ public class TestCapacityOverTimePolicy extends BaseSharingPolicyTest {
final static String TWOHOURPERIOD = "7200000";
final static String ONEDAYPERIOD = "86400000";
- @Parameterized.Parameters(name = "Duration {0}, height {1}," +
- " numSubmission {2}, periodic {3})")
+ public void initTestCapacityOverTimePolicy(long pDuration,
+ double pHeight, int pNumSubmissions, String pRecurrenceExpression, Class pExpectedError) {
+ this.duration = pDuration;
+ this.height = pHeight;
+ this.numSubmissions = pNumSubmissions;
+ this.recurrenceExpression = pRecurrenceExpression;
+ this.expectedError = pExpectedError;
+ super.setup();
+ }
+
public static Collection