public class ProcessShutDownThread extends Thread
On some Linux distributions, YARN is not able to stop containers, because
the kill
command has different arguments. For example when
running Flink on GCE ("Debian GNU/Linux 7.9 (wheezy)"), YARN containers will
not properly shut down when we don't call System.exit()
.
Thread.State, Thread.UncaughtExceptionHandler
MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY
Constructor and Description |
---|
ProcessShutDownThread(org.slf4j.Logger log,
akka.actor.ActorSystem actorSystem,
scala.concurrent.duration.Duration terminationTimeout)
Creates a shut down thread.
|
Modifier and Type | Method and Description |
---|---|
void |
run() |
activeCount, checkAccess, clone, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, toString, yield
public ProcessShutDownThread(org.slf4j.Logger log, akka.actor.ActorSystem actorSystem, scala.concurrent.duration.Duration terminationTimeout)
log
- Log of the corresponding YARN process.actorSystem
- Actor system to await termination of.terminationTimeout
- Actor system termination timeout before
shutting down the JVM.Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.