|
@@ -2359,6 +2359,7 @@ public class TestRMRestart extends ParameterizedSchedulerTestBase {
|
|
|
// kill app0-attempt
|
|
|
cs.killPreemptedContainer(schedulerAppAttempt.getRMContainer(
|
|
|
app0.getCurrentAppAttempt().getMasterContainer().getId()));
|
|
|
+ am0.waitForState(RMAppAttemptState.FAILED);
|
|
|
}
|
|
|
am0 = MockRM.launchAM(app0, rm1, nm1);
|
|
|
am0.registerAppAttempt();
|