TestFairScheduler.testContinuousScheduling fails Intermittently. Contributed by Zhihai Xu.
This commit is contained in:
parent
96d72118f5
commit
53959e69f7
|
@ -145,6 +145,9 @@ Release 2.8.0 - UNRELEASED
|
||||||
YARN-3435. AM container to be allocated Appattempt AM container shown as null.
|
YARN-3435. AM container to be allocated Appattempt AM container shown as null.
|
||||||
(Bibin A Chundatt via xgong)
|
(Bibin A Chundatt via xgong)
|
||||||
|
|
||||||
|
YARN-2666. TestFairScheduler.testContinuousScheduling fails Intermittently.
|
||||||
|
(Zhihai Xu via ozawa)
|
||||||
|
|
||||||
Release 2.7.0 - UNRELEASED
|
Release 2.7.0 - UNRELEASED
|
||||||
|
|
||||||
INCOMPATIBLE CHANGES
|
INCOMPATIBLE CHANGES
|
||||||
|
|
|
@ -3922,12 +3922,9 @@ public class TestFairScheduler extends FairSchedulerTestBase {
|
||||||
createResourceRequest(1024, 1, ResourceRequest.ANY, 2, 1, true);
|
createResourceRequest(1024, 1, ResourceRequest.ANY, 2, 1, true);
|
||||||
ask.clear();
|
ask.clear();
|
||||||
ask.add(request);
|
ask.add(request);
|
||||||
|
scheduler.stop();
|
||||||
scheduler.allocate(appAttemptId, ask, new ArrayList<ContainerId>(), null, null);
|
scheduler.allocate(appAttemptId, ask, new ArrayList<ContainerId>(), null, null);
|
||||||
|
scheduler.continuousSchedulingAttempt();
|
||||||
// Wait until app gets resources
|
|
||||||
while (app.getCurrentConsumption()
|
|
||||||
.equals(Resources.createResource(1024, 1))) { }
|
|
||||||
|
|
||||||
Assert.assertEquals(2048, app.getCurrentConsumption().getMemory());
|
Assert.assertEquals(2048, app.getCurrentConsumption().getMemory());
|
||||||
Assert.assertEquals(2, app.getCurrentConsumption().getVirtualCores());
|
Assert.assertEquals(2, app.getCurrentConsumption().getVirtualCores());
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue