YARN-10948. Rename SchedulerQueue#activeQueue to activateQueue. Contributed by Adam Antal

This commit is contained in:
Adam Antal 2021-10-22 16:33:03 +02:00 committed by Szilard Nemeth
parent 2c37bebac4
commit 23772d946b
3 changed files with 5 additions and 5 deletions

View File

@ -77,7 +77,7 @@ public synchronized void activateQueue(String queueName)
throw new YarnException("The specified queue:" + queueName throw new YarnException("The specified queue:" + queueName
+ " does not exist!"); + " does not exist!");
} }
queue.activeQueue(); queue.activateQueue();
} }
/** /**

View File

@ -62,8 +62,8 @@ public interface SchedulerQueue<T extends SchedulerQueue> extends Queue {
void stopQueue(); void stopQueue();
/** /**
* Active the queue. * Activate the queue.
* @throws YarnException if the queue can not be activated. * @throws YarnException if the queue can not be activated.
*/ */
void activeQueue() throws YarnException; void activateQueue() throws YarnException;
} }

View File

@ -733,7 +733,7 @@ private void initializeQueueState(CapacitySchedulerConfiguration configuration)
} else { } else {
if (configuredState == QueueState.RUNNING) { if (configuredState == QueueState.RUNNING) {
try { try {
activeQueue(); activateQueue();
} catch (YarnException ex) { } catch (YarnException ex) {
throw new IllegalArgumentException(ex.getMessage()); throw new IllegalArgumentException(ex.getMessage());
} }
@ -1322,7 +1322,7 @@ public void updateQueueState(QueueState queueState) {
} }
@Override @Override
public void activeQueue() throws YarnException { public void activateQueue() throws YarnException {
this.writeLock.lock(); this.writeLock.lock();
try { try {
if (getState() == QueueState.RUNNING) { if (getState() == QueueState.RUNNING) {