|
@@ -656,7 +656,7 @@ public class SchedulerApplicationAttempt implements SchedulableEntity {
|
|
|
@SuppressWarnings("unchecked")
|
|
|
public void containerLaunchedOnNode(ContainerId containerId,
|
|
|
NodeId nodeId) {
|
|
|
- writeLock.lock();
|
|
|
+ readLock.lock();
|
|
|
try {
|
|
|
// Inform the container
|
|
|
RMContainer rmContainer = getRMContainer(containerId);
|
|
@@ -670,7 +670,7 @@ public class SchedulerApplicationAttempt implements SchedulableEntity {
|
|
|
rmContainer.handle(
|
|
|
new RMContainerEvent(containerId, RMContainerEventType.LAUNCHED));
|
|
|
} finally {
|
|
|
- writeLock.unlock();
|
|
|
+ readLock.unlock();
|
|
|
}
|
|
|
}
|
|
|
|