Package org.apache.flink.runtime.messages
This package contains the messages that are sent between Flink's distributed components to
coordinate the distributed operations.
-
Class Summary Class Description Acknowledge A generic acknowledgement message.TaskBackPressureResponse Response to the task back pressure request rpc call.TaskThreadInfoResponse Response to the request to collect thread details samples.ThreadInfoSample A serializable wrapper container for transferring parts of theThreadInfo
. -
Exception Summary Exception Description FlinkJobNotFoundException Exception indicating that we could not find a Flink job with the given job ID.FlinkJobTerminatedWithoutCancellationException Exception indicating that the Flink job with the given job ID has terminated without cancellation.