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 23772d9 YARN-10948. Rename SchedulerQueue#activeQueue to activateQueue. Contributed by Adam Antal 23772d9 is described below commit 23772d946bdf26a72fb611a9719afe743cdebd52 Author: Adam Antal <aada...@gmail.com> AuthorDate: Fri Oct 22 16:33:03 2021 +0200 YARN-10948. Rename SchedulerQueue#activeQueue to activateQueue. Contributed by Adam Antal --- .../yarn/server/resourcemanager/scheduler/QueueStateManager.java | 2 +- .../hadoop/yarn/server/resourcemanager/scheduler/SchedulerQueue.java | 4 ++-- .../server/resourcemanager/scheduler/capacity/AbstractCSQueue.java | 4 ++-- 3 files changed, 5 insertions(+), 5 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/QueueStateManager.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/QueueStateManager.java index 0127e1e..ab0f445 100644 --- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/QueueStateManager.java +++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/QueueStateManager.java @@ -77,7 +77,7 @@ public class QueueStateManager<T extends SchedulerQueue, throw new YarnException("The specified queue:" + queueName + " does not exist!"); } - queue.activeQueue(); + queue.activateQueue(); } /** 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/SchedulerQueue.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/SchedulerQueue.java index 9a67e01..33037fc 100644 --- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/SchedulerQueue.java +++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/SchedulerQueue.java @@ -62,8 +62,8 @@ public interface SchedulerQueue<T extends SchedulerQueue> extends Queue { void stopQueue(); /** - * Active the queue. + * Activate the queue. * @throws YarnException if the queue can not be activated. */ - void activeQueue() throws YarnException; + void activateQueue() throws YarnException; } 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/AbstractCSQueue.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/AbstractCSQueue.java index ca861fb..2d9bf85 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/AbstractCSQueue.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/AbstractCSQueue.java @@ -733,7 +733,7 @@ public abstract class AbstractCSQueue implements CSQueue { } else { if (configuredState == QueueState.RUNNING) { try { - activeQueue(); + activateQueue(); } catch (YarnException ex) { throw new IllegalArgumentException(ex.getMessage()); } @@ -1322,7 +1322,7 @@ public abstract class AbstractCSQueue implements CSQueue { } @Override - public void activeQueue() throws YarnException { + public void activateQueue() throws YarnException { this.writeLock.lock(); try { if (getState() == QueueState.RUNNING) { --------------------------------------------------------------------- To unsubscribe, e-mail: common-commits-unsubscr...@hadoop.apache.org For additional commands, e-mail: common-commits-h...@hadoop.apache.org