From 5a6251dd5737de21f2f3ca5f384cefdb39807e8c Mon Sep 17 00:00:00 2001 From: Peter Szucs Date: Fri, 19 May 2023 17:58:09 +0200 Subject: [PATCH] YARN-11041. Resolved conflicts Change-Id: I2bd30982c32386d68dc662dc268773e0d56be777 --- .../scheduler/capacity/AbstractParentQueue.java | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/capacity/AbstractParentQueue.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/capacity/AbstractParentQueue.java index 8a849d28a2e..89ef1c41e51 100644 --- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/capacity/AbstractParentQueue.java +++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/capacity/AbstractParentQueue.java @@ -133,7 +133,7 @@ public abstract class AbstractParentQueue extends AbstractCSQueue { this.childQueues = new ArrayList<>(); this.allowZeroCapacitySum = queueContext.getConfiguration() - .getAllowZeroCapacitySum(getQueuePath()); + .getAllowZeroCapacitySum(getQueuePathObject()); } @@ -167,7 +167,7 @@ public abstract class AbstractParentQueue extends AbstractCSQueue { // Initialize queue ordering policy queueOrderingPolicy = configuration.getQueueOrderingPolicy( - getQueuePath(), parent == null ? + getQueuePathObject(), parent == null ? null : ((AbstractParentQueue) parent).getQueueOrderingPolicyConfigName()); queueOrderingPolicy.setQueues(childQueues); @@ -549,7 +549,7 @@ public abstract class AbstractParentQueue extends AbstractCSQueue { */ public boolean isEligibleForAutoQueueCreation() { return isDynamicQueue() || queueContext.getConfiguration(). - isAutoQueueCreationV2Enabled(getQueuePath()); + isAutoQueueCreationV2Enabled(getQueuePathObject()); } @Override @@ -1585,7 +1585,7 @@ public abstract class AbstractParentQueue extends AbstractCSQueue { public boolean isEligibleForAutoDeletion() { return isDynamicQueue() && getChildQueues().size() == 0 && queueContext.getConfiguration(). - isAutoExpiredDeletionEnabled(this.getQueuePath()); + isAutoExpiredDeletionEnabled(this.getQueuePathObject()); } public AutoCreatedQueueTemplate getAutoCreatedQueueTemplate() {