public static class Messages.Disconnect extends Object implements RequiresLeaderSessionID, scala.Product, scala.Serializable
The TaskManager may send this on shutdown to let the JobManager realize the TaskManager loss more quickly.
The JobManager may send this message to its TaskManagers to let them clean up their tasks that depend on the JobManager and go into a clean state.
Constructor and Description |
---|
Disconnect(InstanceID instanceId,
Exception cause) |
Modifier and Type | Method and Description |
---|---|
Exception |
cause() |
InstanceID |
instanceId() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
public Disconnect(InstanceID instanceId, Exception cause)
public InstanceID instanceId()
public Exception cause()
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.