Searched refs:getNumRunnableApps (Results 1 – 8 of 8) sorted by relevance
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/fair/ |
| H A D | TestMaxRunningAppsEnforcer.java | 100 assertEquals(1, leaf1.getNumRunnableApps()); in testRemoveDoesNotEnableAnyApp()
101 assertEquals(1, leaf2.getNumRunnableApps()); in testRemoveDoesNotEnableAnyApp()
104 assertEquals(0, leaf1.getNumRunnableApps()); in testRemoveDoesNotEnableAnyApp()
105 assertEquals(1, leaf2.getNumRunnableApps()); in testRemoveDoesNotEnableAnyApp()
117 assertEquals(1, leaf1.getNumRunnableApps()); in testRemoveEnablesAppOnCousinQueue()
118 assertEquals(1, leaf2.getNumRunnableApps()); in testRemoveEnablesAppOnCousinQueue()
121 assertEquals(0, leaf1.getNumRunnableApps()); in testRemoveEnablesAppOnCousinQueue()
122 assertEquals(2, leaf2.getNumRunnableApps()); in testRemoveEnablesAppOnCousinQueue()
136 assertEquals(2, leaf1.getNumRunnableApps()); in testRemoveEnablesOneByQueueOneByUser()
140 assertEquals(2, leaf1.getNumRunnableApps()); in testRemoveEnablesOneByQueueOneByUser()
[all …]
|
| H A D | TestFairScheduler.java | 952 .getNumRunnableApps()); in testUserAsDefaultQueue()
954 .getNumRunnableApps()); in testUserAsDefaultQueue()
968 .getNumRunnableApps()); in testNotUserAsDefaultQueue()
970 .getNumRunnableApps()); in testNotUserAsDefaultQueue()
972 .getNumRunnableApps()); in testNotUserAsDefaultQueue()
1454 .getNumRunnableApps()); in testAppAdditionAndRemoval()
1464 .getNumRunnableApps()); in testAppAdditionAndRemoval()
2208 assertEquals(1, userQueue.getNumRunnableApps()); in testPreemptionVariablesForQueueCreatedRuntime()
4317 assertEquals(0, oldQueue.getNumRunnableApps()); in testMoveRunnableApp()
4341 assertEquals(0, oldQueue.getNumRunnableApps()); in testMoveNonRunnableApp()
[all …]
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/fair/ |
| H A D | MaxRunningAppsEnforcer.java | 70 if (queue.getNumRunnableApps() >= queueMaxApps) { in canAppBeRunnable()
145 FSQueue highestQueueWithAppsNowRunnable = (queue.getNumRunnableApps() == in updateRunnabilityOnAppRemoval()
149 if (parent.getNumRunnableApps() == allocConf.getQueueMaxApps(parent in updateRunnabilityOnAppRemoval()
268 if (queue.getNumRunnableApps() < scheduler.getAllocationConfiguration() in gatherPossiblyRunnableAppLists()
|
| H A D | FSQueue.java | 253 public abstract int getNumRunnableApps(); in getNumRunnableApps() method in FSQueue
273 return getNumRunnableApps() > 0; in isActive()
|
| H A D | FSParentQueue.java | 229 public int getNumRunnableApps() { in getNumRunnableApps() method in FSParentQueue
|
| H A D | QueueManager.java | 310 return queue.getNumRunnableApps() == 0 && in isEmpty()
|
| H A D | FSLeafQueue.java | 417 public int getNumRunnableApps() { in getNumRunnableApps() method in FSLeafQueue
|
| H A D | FairScheduler.java | 1573 if (cur.getNumRunnableApps() == allocConf.getQueueMaxApps(cur.getQueueName())) { in verifyMoveDoesNotViolateConstraints()
|