Skip to content

Commit b196d22

Browse files
committed
changed capacitySchedulerConfiguration as a Configuration object to CapacitySchedulerConfiguration object
Change-Id: Ifdab821bee6f0f6db4f8b17208d01cf3901820b7
1 parent 442a5fb commit b196d22

File tree

3 files changed

+96
-84
lines changed

3 files changed

+96
-84
lines changed

hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/fair/converter/FSQueueConverter.java

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -23,7 +23,6 @@
2323
import java.util.List;
2424
import java.util.stream.Collectors;
2525

26-
import org.apache.hadoop.conf.Configuration;
2726
import org.apache.hadoop.yarn.api.records.Resource;
2827
import org.apache.hadoop.yarn.server.resourcemanager.scheduler.capacity.CapacitySchedulerConfiguration;
2928
import org.apache.hadoop.yarn.server.resourcemanager.scheduler.fair.ConfigurableResource;
@@ -48,7 +47,7 @@ public class FSQueueConverter {
4847
private static final String FIFO_POLICY = "fifo";
4948

5049
private final FSConfigToCSConfigRuleHandler ruleHandler;
51-
private Configuration capacitySchedulerConfig;
50+
private CapacitySchedulerConfiguration capacitySchedulerConfig;
5251
private final boolean preemptionEnabled;
5352
private final boolean sizeBasedWeight;
5453
@SuppressWarnings("unused")

hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/fair/converter/FSQueueConverterBuilder.java

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -18,13 +18,13 @@
1818

1919
package org.apache.hadoop.yarn.server.resourcemanager.scheduler.fair.converter;
2020

21-
import org.apache.hadoop.conf.Configuration;
2221
import org.apache.hadoop.yarn.api.records.Resource;
22+
import org.apache.hadoop.yarn.server.resourcemanager.scheduler.capacity.CapacitySchedulerConfiguration;
2323

2424
@SuppressWarnings({"checkstyle:visibilitymodifier", "checkstyle:hiddenfield"})
2525
public final class FSQueueConverterBuilder {
2626
FSConfigToCSConfigRuleHandler ruleHandler;
27-
Configuration capacitySchedulerConfig;
27+
CapacitySchedulerConfiguration capacitySchedulerConfig;
2828
boolean preemptionEnabled;
2929
boolean sizeBasedWeight;
3030
Resource clusterResource;
@@ -48,8 +48,8 @@ public FSQueueConverterBuilder withRuleHandler(
4848
}
4949

5050
public FSQueueConverterBuilder withCapacitySchedulerConfig(
51-
Configuration config) {
52-
this.capacitySchedulerConfig = config;
51+
CapacitySchedulerConfiguration capacitySchedulerConfig) {
52+
this.capacitySchedulerConfig = capacitySchedulerConfig;
5353
return this;
5454
}
5555

0 commit comments

Comments
 (0)