@Override
public void preemptContainer(ContainerId containerId) {
taskScheduler.deallocateContainer(containerId);
// Inform the Containers about completion.
sendEvent(new AMContainerEventCompleted(ContainerStatus.newInstance(
containerId, ContainerState.COMPLETE, "Container Preempted Internally", -1), true));
}