Package org.apache.hadoop.yarn.server.nodemanager

Class ContainerExecutor.DelayedProcessKiller

java.lang.Object

java.lang.Thread

org.apache.hadoop.util.concurrent.SubjectInheritingThread

org.apache.hadoop.yarn.server.nodemanager.ContainerExecutor.DelayedProcessKiller

All Implemented Interfaces:

Runnable

Enclosing class:

ContainerExecutor

public static class ContainerExecutor.DelayedProcessKiller
extends org.apache.hadoop.util.concurrent.SubjectInheritingThread

This class will signal a target container after a specified delay.

See Also:

• ContainerExecutor.signalContainer(org.apache.hadoop.yarn.server.nodemanager.executor.ContainerSignalContext)

Nested Class Summary

Nested classes/interfaces inherited from class java.lang.Thread

Thread.State, Thread.UncaughtExceptionHandler

Field Summary

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor	Description
DelayedProcessKiller(Container container, String user, String pid, long delayMS, ContainerExecutor.Signal signal, ContainerExecutor containerExecutor)	Basic constructor.

Method Summary

Modifier and Type	Method	Description
void	work()

Methods inherited from class org.apache.hadoop.util.concurrent.SubjectInheritingThread

run, start

Methods inherited from class java.lang.Thread

activeCount, checkAccess, clone, countStackFrames, currentThread, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, onSpinWait, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, stop, suspend, toString, yield

Methods inherited from class java.lang.Object

equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Details

DelayedProcessKiller

public DelayedProcessKiller(Container container,
 String user,
 String pid,
 long delayMS,
 ContainerExecutor.Signal signal,
 ContainerExecutor containerExecutor)

Basic constructor.

Parameters:

container - the container to signal

user - the user as whow to send the signal

pid - the PID of the container process

delayMS - the period of time to wait in millis before signaling the container

signal - the signal to send

containerExecutor - the executor to use to send the signal

Method Details

work

public void work()

Overrides:

work in class org.apache.hadoop.util.concurrent.SubjectInheritingThread