|
@@ -54,6 +54,16 @@ public class TestNMSimulator {
|
|
|
node1.init("rack1/node1", GB * 10, 10, 0, 1000, rm);
|
|
|
node1.middleStep();
|
|
|
|
|
|
+ int numClusterNodes = rm.getResourceScheduler().getNumClusterNodes();
|
|
|
+ int cumulativeSleepTime = 0;
|
|
|
+ int sleepInterval = 100;
|
|
|
+
|
|
|
+ while(numClusterNodes != 1 && cumulativeSleepTime < 5000) {
|
|
|
+ Thread.sleep(sleepInterval);
|
|
|
+ cumulativeSleepTime = cumulativeSleepTime + sleepInterval;
|
|
|
+ numClusterNodes = rm.getResourceScheduler().getNumClusterNodes();
|
|
|
+ }
|
|
|
+
|
|
|
Assert.assertEquals(1, rm.getResourceScheduler().getNumClusterNodes());
|
|
|
Assert.assertEquals(GB * 10,
|
|
|
rm.getResourceScheduler().getRootQueueMetrics().getAvailableMB());
|