import org.apache.hadoop.yarn.server.nodemanager.containermanager.monitor.ContainerStopMonitoringEvent; //导入依赖的package包/类
@SuppressWarnings("unchecked")
private void sendFinishedEvents() {
  // Inform the application
  @SuppressWarnings("rawtypes")
  EventHandler eventHandler = dispatcher.getEventHandler();
  eventHandler.handle(new ApplicationContainerFinishedEvent(containerId));
  // Remove the container from the resource-monitor
  eventHandler.handle(new ContainerStopMonitoringEvent(containerId));
  // Tell the logService too
  eventHandler.handle(new LogHandlerContainerFinishedEvent(
    containerId, exitCode));
}
 

import org.apache.hadoop.yarn.server.nodemanager.containermanager.monitor.ContainerStopMonitoringEvent; //导入依赖的package包/类
@SuppressWarnings({"fallthrough", "unchecked"})
private void finished() {
  ApplicationId applicationId =
      containerId.getApplicationAttemptId().getApplicationId();
  switch (getContainerState()) {
    case EXITED_WITH_SUCCESS:
      metrics.endRunningContainer();
      metrics.completedContainer();
      NMAuditLogger.logSuccess(user,
          AuditConstants.FINISH_SUCCESS_CONTAINER, "ContainerImpl",
          applicationId, containerId);
      break;
    case EXITED_WITH_FAILURE:
      metrics.endRunningContainer();
      // fall through
    case LOCALIZATION_FAILED:
      metrics.failedContainer();
      NMAuditLogger.logFailure(user,
          AuditConstants.FINISH_FAILED_CONTAINER, "ContainerImpl",
          "Container failed with state: " + getContainerState(),
          applicationId, containerId);
      break;
    case CONTAINER_CLEANEDUP_AFTER_KILL:
      metrics.endRunningContainer();
      // fall through
    case NEW:
      metrics.killedContainer();
      NMAuditLogger.logSuccess(user,
          AuditConstants.FINISH_KILLED_CONTAINER, "ContainerImpl",
          applicationId,
          containerId);
  }

  metrics.releaseContainer(this.resource);

  // Inform the application
  @SuppressWarnings("rawtypes")
  EventHandler eventHandler = dispatcher.getEventHandler();
  eventHandler.handle(new ApplicationContainerFinishedEvent(containerId));
  // Remove the container from the resource-monitor
  eventHandler.handle(new ContainerStopMonitoringEvent(containerId));
  // Tell the logService too
  eventHandler.handle(new LogHandlerContainerFinishedEvent(
    containerId, exitCode));
}
 

import org.apache.hadoop.yarn.server.nodemanager.containermanager.monitor.ContainerStopMonitoringEvent; //导入依赖的package包/类
@SuppressWarnings({"fallthrough", "unchecked"})
private void finished() {
  ApplicationId applicationId =
      containerId.getApplicationAttemptId().getApplicationId();
  switch (getContainerState()) {
    case EXITED_WITH_SUCCESS:
      metrics.endRunningContainer();
      metrics.completedContainer();
      NMAuditLogger.logSuccess(user,
          AuditConstants.FINISH_SUCCESS_CONTAINER, "ContainerImpl",
          applicationId, containerId);
      break;
    case EXITED_WITH_FAILURE:
      if (wasLaunched) {
        metrics.endRunningContainer();
      }
      // fall through
    case LOCALIZATION_FAILED:
      metrics.failedContainer();
      NMAuditLogger.logFailure(user,
          AuditConstants.FINISH_FAILED_CONTAINER, "ContainerImpl",
          "Container failed with state: " + getContainerState(),
          applicationId, containerId);
      break;
    case CONTAINER_CLEANEDUP_AFTER_KILL:
      if (wasLaunched) {
        metrics.endRunningContainer();
      }
      // fall through
    case NEW:
      metrics.killedContainer();
      NMAuditLogger.logSuccess(user,
          AuditConstants.FINISH_KILLED_CONTAINER, "ContainerImpl",
          applicationId,
          containerId);
  }

  metrics.releaseContainer(this.resource);

  // Inform the application
  @SuppressWarnings("rawtypes")
  EventHandler eventHandler = dispatcher.getEventHandler();
  eventHandler.handle(new ApplicationContainerFinishedEvent(containerId));
  // Remove the container from the resource-monitor
  eventHandler.handle(new ContainerStopMonitoringEvent(containerId));
  // Tell the logService too
  eventHandler.handle(new LogHandlerContainerFinishedEvent(
    containerId, exitCode));
}