YARN-2871. TestRMRestart#testRMRestartGetApplicationList sometime fails
in trunk. Contributed by zhihai xu
This commit is contained in:
parent
aa07dea357
commit
fe6c1bd73a
|
@ -559,6 +559,9 @@ Release 2.8.0 - UNRELEASED
|
||||||
YARN-3745. SerializedException should also try to instantiate internal
|
YARN-3745. SerializedException should also try to instantiate internal
|
||||||
exception with the default constructor. (Lavkesh Lahngir via devaraj)
|
exception with the default constructor. (Lavkesh Lahngir via devaraj)
|
||||||
|
|
||||||
|
YARN-2871. TestRMRestart#testRMRestartGetApplicationList sometime fails in trunk.
|
||||||
|
(zhihai xu via xgong)
|
||||||
|
|
||||||
Release 2.7.1 - UNRELEASED
|
Release 2.7.1 - UNRELEASED
|
||||||
|
|
||||||
INCOMPATIBLE CHANGES
|
INCOMPATIBLE CHANGES
|
||||||
|
|
|
@ -21,6 +21,7 @@
|
||||||
import static org.mockito.Matchers.isA;
|
import static org.mockito.Matchers.isA;
|
||||||
import static org.mockito.Mockito.mock;
|
import static org.mockito.Mockito.mock;
|
||||||
import static org.mockito.Mockito.spy;
|
import static org.mockito.Mockito.spy;
|
||||||
|
import static org.mockito.Mockito.timeout;
|
||||||
import static org.mockito.Mockito.times;
|
import static org.mockito.Mockito.times;
|
||||||
import static org.mockito.Mockito.verify;
|
import static org.mockito.Mockito.verify;
|
||||||
import static org.mockito.Mockito.when;
|
import static org.mockito.Mockito.when;
|
||||||
|
@ -976,9 +977,10 @@ protected RMAppManager createRMAppManager() {
|
||||||
List<ApplicationReport> appList2 = response2.getApplicationList();
|
List<ApplicationReport> appList2 = response2.getApplicationList();
|
||||||
Assert.assertTrue(3 == appList2.size());
|
Assert.assertTrue(3 == appList2.size());
|
||||||
|
|
||||||
// check application summary is logged for the completed apps after RM restart.
|
// check application summary is logged for the completed apps with timeout
|
||||||
verify(rm2.getRMAppManager(), times(3)).logApplicationSummary(
|
// to make sure APP_COMPLETED events are processed, after RM restart.
|
||||||
isA(ApplicationId.class));
|
verify(rm2.getRMAppManager(), timeout(1000).times(3)).
|
||||||
|
logApplicationSummary(isA(ApplicationId.class));
|
||||||
}
|
}
|
||||||
|
|
||||||
private MockAM launchAM(RMApp app, MockRM rm, MockNM nm)
|
private MockAM launchAM(RMApp app, MockRM rm, MockNM nm)
|
||||||
|
|
Loading…
Reference in New Issue