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.
param: cause The reason for disconnecting, to be displayed in log and error messages.
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–2018 The Apache Software Foundation. All rights reserved.