org.apache.flink.runtime.messages

Class Messages.Disconnect

java.lang.Object

org.apache.flink.runtime.messages.Messages.Disconnect

All Implemented Interfaces:

Serializable, RequiresLeaderSessionID, scala.Equals, scala.Product

Enclosing class:

Messages

public static class Messages.Disconnect
extends Object
implements RequiresLeaderSessionID, scala.Product, scala.Serializable

Signals that the receiver (JobManager/TaskManager) shall disconnect the sender.

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.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
Disconnect(String reason)

Method Summary

Modifier and Type	Method and Description
String	reason()

Methods inherited from class java.lang.Object

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

Methods inherited from interface scala.Product

productArity, productElement, productIterator, productPrefix

Methods inherited from interface scala.Equals

canEqual, equals

Constructor Detail

Disconnect

public Disconnect(String reason)

Method Detail

reason

public String reason()