Examples of ContainerKillEvent

org.apache.hadoop.yarn.server.nodemanager.containermanager.container.ContainerKillEvent

Examples of org.apache.hadoop.yarn.server.nodemanager.containermanager.container.ContainerKillEvent


      // Send event to ContainersLauncher to finish all the containers of this
      // application.
      for (ContainerId containerID : app.containers.keySet()) {
        app.dispatcher.getEventHandler().handle(
            new ContainerKillEvent(containerID,
                ContainerExitStatus.KILLED_AFTER_APP_COMPLETION,
                "Container killed on application-finish event: " + appEvent.getDiagnostic()));
      }
      return ApplicationState.FINISHING_CONTAINERS_WAIT;
    }

View Full Code Here

Examples of org.apache.hadoop.yarn.server.nodemanager.containermanager.container.ContainerKillEvent

    }


    @Override
    public boolean matches(Object argument) {
      if (argument instanceof ContainerKillEvent) {
        ContainerKillEvent event = (ContainerKillEvent) argument;
        return event.getContainerID().equals(cId);
      }
      return false;
    }

View Full Code Here

Examples of org.apache.hadoop.yarn.server.nodemanager.containermanager.container.ContainerKillEvent


      // Send event to ContainersLauncher to finish all the containers of this
      // application.
      for (ContainerId containerID : app.containers.keySet()) {
        app.dispatcher.getEventHandler().handle(
            new ContainerKillEvent(containerID,
                "Container killed on application-finish event from RM."));
      }
      return ApplicationState.FINISHING_CONTAINERS_WAIT;
    }

View Full Code Here

Examples of org.apache.hadoop.yarn.server.nodemanager.containermanager.container.ContainerKillEvent

        throw RPCUtil.getRemoteException("Container " + containerIDStr
          + " is not handled by this NodeManager");
      }
    } else {
      dispatcher.getEventHandler().handle(
        new ContainerKillEvent(containerID,
          "Container killed by the ApplicationMaster."));


      NMAuditLogger.logSuccess(container.getUser(),    
        AuditConstants.STOP_CONTAINER, "ContainerManageImpl", containerID
          .getApplicationAttemptId().getApplicationId(), containerID);

View Full Code Here

Examples of org.apache.hadoop.yarn.server.nodemanager.containermanager.container.ContainerKillEvent

        } else if (containersFinishedEvent.getReason() == 
            CMgrCompletedContainersEvent.Reason.BY_RESOURCEMANAGER) {
          diagnostic = "Container Killed by ResourceManager";
        }
        this.dispatcher.getEventHandler().handle(
            new ContainerKillEvent(container, diagnostic));
      }
      break;
    default:
      LOG.warn("Invalid event " + event.getType() + ". Ignoring.");
    }

View Full Code Here

Examples of org.apache.hadoop.yarn.server.nodemanager.containermanager.container.ContainerKillEvent

        throw RPCUtil.getRemoteException("Container " + containerIDStr
          + " is not handled by this NodeManager");
      }
    } else {
      dispatcher.getEventHandler().handle(
        new ContainerKillEvent(containerID,
            ContainerExitStatus.KILLED_BY_APPMASTER,
            "Container killed by the ApplicationMaster."));


      NMAuditLogger.logSuccess(container.getUser(),    
        AuditConstants.STOP_CONTAINER, "ContainerManageImpl", containerID

View Full Code Here

Examples of org.apache.hadoop.yarn.server.nodemanager.containermanager.container.ContainerKillEvent

      CMgrCompletedContainersEvent containersFinishedEvent =
          (CMgrCompletedContainersEvent) event;
      for (ContainerId container : containersFinishedEvent
          .getContainersToCleanup()) {
          this.dispatcher.getEventHandler().handle(
              new ContainerKillEvent(container,
                  ContainerExitStatus.KILLED_BY_RESOURCEMANAGER,
                  "Container Killed by ResourceManager"));
      }
      break;
    default:

View Full Code Here

Examples of org.apache.hadoop.yarn.server.nodemanager.containermanager.container.ContainerKillEvent

    }


    @Override
    public boolean matches(Object argument) {
      if (argument instanceof ContainerKillEvent) {
        ContainerKillEvent event = (ContainerKillEvent) argument;
        return event.getContainerID().equals(cId);
      }
      return false;
    }

View Full Code Here

Examples of org.apache.hadoop.yarn.server.nodemanager.containermanager.container.ContainerKillEvent

                LOG.error("Killed container process with PID " + pId
                    + " but it is not a process group leader.");
              }
              // kill the container
              eventDispatcher.getEventHandler().handle(
                  new ContainerKillEvent(containerId,
                      containerExitStatus, msg));
              it.remove();
              LOG.info("Removed ProcessTree with root " + pId);
            } else {
              // Accounting the total memory in usage for all containers that

View Full Code Here

Examples of org.apache.hadoop.yarn.server.nodemanager.containermanager.container.ContainerKillEvent

          containerID);
      return response; // Return immediately.
    }


    dispatcher.getEventHandler().handle(
        new ContainerKillEvent(containerID,
            "Container killed by the ApplicationMaster."));
 
    NMAuditLogger.logSuccess(container.getUser(), 
        AuditConstants.STOP_CONTAINER, "ContainerManageImpl", 
        containerID.getApplicationAttemptId().getApplicationId(),

View Full Code Here

0 1 2 3 4 5

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.