YARN-6570. No logs were found for running application, running
container. Contributed by Junping Du
This commit is contained in:
parent
29dd55153e
commit
7c732924a8
|
@ -616,6 +616,7 @@ public class ContainerImpl implements Container {
|
|||
public org.apache.hadoop.yarn.api.records.ContainerState getCurrentState() {
|
||||
switch (stateMachine.getCurrentState()) {
|
||||
case NEW:
|
||||
return org.apache.hadoop.yarn.api.records.ContainerState.NEW;
|
||||
case LOCALIZING:
|
||||
case LOCALIZATION_FAILED:
|
||||
case SCHEDULED:
|
||||
|
|
|
@ -159,7 +159,8 @@ public class TestEventFlow {
|
|||
containerManager.startContainers(allRequests);
|
||||
|
||||
BaseContainerManagerTest.waitForContainerState(containerManager, cID,
|
||||
Arrays.asList(ContainerState.RUNNING, ContainerState.SCHEDULED), 20);
|
||||
Arrays.asList(ContainerState.RUNNING, ContainerState.SCHEDULED,
|
||||
ContainerState.NEW), 20);
|
||||
|
||||
List<ContainerId> containerIds = new ArrayList<ContainerId>();
|
||||
containerIds.add(cID);
|
||||
|
|
|
@ -122,6 +122,8 @@ public class TestContainer {
|
|||
try {
|
||||
wc = new WrappedContainer(7, 314159265358979L, 4344, "yak");
|
||||
assertEquals(ContainerState.NEW, wc.c.getContainerState());
|
||||
ContainerImpl container = (ContainerImpl)wc.c;
|
||||
assertEquals(org.apache.hadoop.yarn.api.records.ContainerState.NEW, container.getCurrentState());
|
||||
wc.initContainer();
|
||||
|
||||
// Verify request for public/private resources to localizer
|
||||
|
@ -131,6 +133,7 @@ public class TestContainer {
|
|||
LocalResourceVisibility.APPLICATION));
|
||||
verify(wc.localizerBus).handle(argThat(matchesReq));
|
||||
assertEquals(ContainerState.LOCALIZING, wc.c.getContainerState());
|
||||
assertEquals(org.apache.hadoop.yarn.api.records.ContainerState.SCHEDULED, container.getCurrentState());
|
||||
}
|
||||
finally {
|
||||
if (wc != null) {
|
||||
|
|
Loading…
Reference in New Issue