Repository: hadoop Updated Branches: refs/heads/branch-3.0 cba1fa496 -> e785e8327
YARN-7389. Make TestResourceManager Scheduler agnostic. (Robert Kanter via Haibo Chen) (cherry picked from commit d7f3737f3b3236fbf8c25fdd4656251ed63a2be9) Project: http://git-wip-us.apache.org/repos/asf/hadoop/repo Commit: http://git-wip-us.apache.org/repos/asf/hadoop/commit/e785e832 Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/e785e832 Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/e785e832 Branch: refs/heads/branch-3.0 Commit: e785e83270efbfc6d47eee35a1a112643607f81a Parents: cba1fa4 Author: Haibo Chen <[email protected]> Authored: Tue Oct 24 22:17:56 2017 -0700 Committer: Andrew Wang <[email protected]> Committed: Tue Oct 31 13:41:44 2017 -0700 ---------------------------------------------------------------------- .../yarn/server/resourcemanager/TestResourceManager.java | 9 ++------- 1 file changed, 2 insertions(+), 7 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hadoop/blob/e785e832/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/TestResourceManager.java ---------------------------------------------------------------------- diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/TestResourceManager.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/TestResourceManager.java index ad8c335..941e477 100644 --- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/TestResourceManager.java +++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/TestResourceManager.java @@ -39,7 +39,7 @@ import org.apache.hadoop.yarn.exceptions.YarnException; import org.apache.hadoop.yarn.exceptions.YarnRuntimeException; import org.apache.hadoop.yarn.server.resourcemanager.rmapp.attempt.RMAppAttemptState; import org.apache.hadoop.yarn.server.resourcemanager.rmnode.RMNode; -import org.apache.hadoop.yarn.server.resourcemanager.scheduler.capacity.CapacityScheduler; +import org.apache.hadoop.yarn.server.resourcemanager.scheduler.AbstractYarnScheduler; import org.apache.hadoop.yarn.server.resourcemanager.scheduler.event.AppAttemptRemovedSchedulerEvent; import org.apache.hadoop.yarn.server.resourcemanager.scheduler.event.NodeAddedSchedulerEvent; import org.apache.hadoop.yarn.server.resourcemanager.scheduler.event.NodeUpdateSchedulerEvent; @@ -58,8 +58,6 @@ public class TestResourceManager { @Before public void setUp() throws Exception { Configuration conf = new YarnConfiguration(); - conf.set(YarnConfiguration.RM_SCHEDULER, - CapacityScheduler.class.getCanonicalName()); UserGroupInformation.setConfiguration(conf); resourceManager = new ResourceManager(); resourceManager.init(conf); @@ -133,6 +131,7 @@ public class TestResourceManager { // Send a heartbeat to kick the tires on the Scheduler nodeUpdate(nm1); + ((AbstractYarnScheduler)resourceManager.getResourceScheduler()).update(); // Get allocations from the scheduler application.schedule(); @@ -262,8 +261,6 @@ public class TestResourceManager { } }; Configuration conf = new YarnConfiguration(); - conf.set(YarnConfiguration.RM_SCHEDULER, - CapacityScheduler.class.getCanonicalName()); conf.set(filterInitializerConfKey, filterInitializer); conf.set("hadoop.security.authentication", "kerberos"); conf.set("hadoop.http.authentication.type", "kerberos"); @@ -298,8 +295,6 @@ public class TestResourceManager { for (String filterInitializer : simpleFilterInitializers) { resourceManager = new ResourceManager(); Configuration conf = new YarnConfiguration(); - conf.set(YarnConfiguration.RM_SCHEDULER, - CapacityScheduler.class.getCanonicalName()); conf.set(filterInitializerConfKey, filterInitializer); try { UserGroupInformation.setConfiguration(conf); --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
