Skip to content

Commit 52e14ff

Browse files
committed
fix queuepath params
1 parent bdb7515 commit 52e14ff

File tree

2 files changed

+3
-3
lines changed

2 files changed

+3
-3
lines changed

hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/capacity/CapacitySchedulerConfiguration.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1827,7 +1827,7 @@ private Integer getDefaultApplicationPriority() {
18271827
DEFAULT_CONFIGURATION_APPLICATION_PRIORITY);
18281828
}
18291829

1830-
public Integer getDefaultApplicationPriorityConfPerQueue(String queue) {
1830+
public Integer getDefaultApplicationPriorityConfPerQueue(QueuePath queue) {
18311831
return getInt(getQueuePrefix(queue) + DEFAULT_APPLICATION_PRIORITY,
18321832
getDefaultApplicationPriority());
18331833
}

hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/capacity/TestApplicationLimits.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -387,15 +387,15 @@ public void testLimitsComputation() throws Exception {
387387
assertEquals(
388388
(int)CapacitySchedulerConfiguration.DEFAULT_CONFIGURATION_APPLICATION_PRIORITY,
389389
(int)csConf.getDefaultApplicationPriorityConfPerQueue(
390-
queue.getQueuePath())
390+
queue.getQueuePathObject())
391391
);
392392

393393
csConf.setInt(PREFIX + queue.getQueuePath()
394394
+ ".default-application-priority", 6);
395395

396396
assertEquals((int) 6,
397397
(int) csConf.getDefaultApplicationPriorityConfPerQueue(
398-
queue.getQueuePath())
398+
queue.getQueuePathObject())
399399
);
400400

401401
assertThat(queue.calculateAndGetAMResourceLimit()).isEqualTo(

0 commit comments

Comments
 (0)