You are viewing a plain text version of this content. The canonical link for it is here.
Posted to common-commits@hadoop.apache.org by sn...@apache.org on 2022/02/17 18:17:47 UTC
[hadoop] branch trunk updated: YARN-10580. Fix some issues in TestRMWebServicesCapacitySchedDynamicConfig. Contributed by Tamas Domok
This is an automated email from the ASF dual-hosted git repository.
snemeth pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/hadoop.git
The following commit(s) were added to refs/heads/trunk by this push:
new 48e02f7 YARN-10580. Fix some issues in TestRMWebServicesCapacitySchedDynamicConfig. Contributed by Tamas Domok
48e02f7 is described below
commit 48e02f79983b32b64d1ae10e8ddf162c06f700d6
Author: Szilard Nemeth <sn...@apache.org>
AuthorDate: Thu Feb 17 19:17:31 2022 +0100
YARN-10580. Fix some issues in TestRMWebServicesCapacitySchedDynamicConfig. Contributed by Tamas Domok
---
.../TestRMWebServicesCapacitySchedDynamicConfig.java | 16 ++++------------
1 file changed, 4 insertions(+), 12 deletions(-)
diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/webapp/TestRMWebServicesCapacitySchedDynamicConfig.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/webapp/TestRMWebServicesCapacitySchedDynamicConfig.java
index df4f18e..0e2ecd0 100644
--- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/webapp/TestRMWebServicesCapacitySchedDynamicConfig.java
+++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/webapp/TestRMWebServicesCapacitySchedDynamicConfig.java
@@ -102,8 +102,6 @@ public class TestRMWebServicesCapacitySchedDynamicConfig extends
throws Exception {
Configuration config = CSConfigGenerator
.createPercentageConfig();
- config.set(YarnConfiguration.SCHEDULER_CONFIGURATION_STORE_CLASS,
- YarnConfiguration.MEMORY_CONFIGURATION_STORE);
initResourceManager(config);
@@ -121,8 +119,6 @@ public class TestRMWebServicesCapacitySchedDynamicConfig extends
throws Exception {
Configuration config = CSConfigGenerator
.createPercentageConfigLegacyAutoCreation();
- config.set(YarnConfiguration.SCHEDULER_CONFIGURATION_STORE_CLASS,
- YarnConfiguration.MEMORY_CONFIGURATION_STORE);
initResourceManager(config);
@@ -141,8 +137,6 @@ public class TestRMWebServicesCapacitySchedDynamicConfig extends
throws Exception {
Configuration config = CSConfigGenerator
.createAbsoluteConfigLegacyAutoCreation();
- config.set(YarnConfiguration.SCHEDULER_CONFIGURATION_STORE_CLASS,
- YarnConfiguration.MEMORY_CONFIGURATION_STORE);
initResourceManager(config);
initAutoQueueHandler(8192 * GB);
@@ -157,8 +151,6 @@ public class TestRMWebServicesCapacitySchedDynamicConfig extends
throws Exception {
Configuration config = CSConfigGenerator
.createAbsoluteConfig();
- config.set(YarnConfiguration.SCHEDULER_CONFIGURATION_STORE_CLASS,
- YarnConfiguration.MEMORY_CONFIGURATION_STORE);
initResourceManager(config);
@@ -176,8 +168,6 @@ public class TestRMWebServicesCapacitySchedDynamicConfig extends
throws Exception {
Configuration config = CSConfigGenerator
.createWeightConfig();
- config.set(YarnConfiguration.SCHEDULER_CONFIGURATION_STORE_CLASS,
- YarnConfiguration.MEMORY_CONFIGURATION_STORE);
initResourceManager(config);
@@ -197,8 +187,6 @@ public class TestRMWebServicesCapacitySchedDynamicConfig extends
throws Exception {
Configuration config = CSConfigGenerator
.createWeightConfigWithAutoQueueCreationEnabled();
- config.set(YarnConfiguration.SCHEDULER_CONFIGURATION_STORE_CLASS,
- YarnConfiguration.MEMORY_CONFIGURATION_STORE);
config.setInt(CapacitySchedulerConfiguration
.getQueuePrefix("root.autoParent1") +
AutoCreatedQueueTemplate.AUTO_QUEUE_TEMPLATE_PREFIX +
@@ -332,6 +320,10 @@ public class TestRMWebServicesCapacitySchedDynamicConfig extends
for (Map.Entry<String, String> entry : configs.entrySet()) {
config.set(entry.getKey(), entry.getValue());
}
+
+ config.set(YarnConfiguration.SCHEDULER_CONFIGURATION_STORE_CLASS,
+ YarnConfiguration.MEMORY_CONFIGURATION_STORE);
+
return config;
}
}
---------------------------------------------------------------------
To unsubscribe, e-mail: common-commits-unsubscribe@hadoop.apache.org
For additional commands, e-mail: common-commits-help@hadoop.apache.org