Package | Description |
---|---|
org.apache.flink.runtime.clusterframework.messages |
This package contains the actor messages that are sent between the
cluster resource framework and the JobManager, as well as the generic
messages sent between the cluster resource framework and the client.
|
org.apache.flink.runtime.messages |
This package contains the messages that are sent between actors, like the
JobManager and
TaskManager to coordinate the distributed operations. |
org.apache.flink.yarn |
Modifier and Type | Class and Description |
---|---|
class |
NotifyResourceStarted
Notifies the ResourceManager that a TaskManager has been started in a container with the given
resource id.
|
class |
ReconnectResourceManager
This message signals that the ResourceManager should reconnect to the JobManager.
|
class |
RegisterInfoMessageListener
This message signals to the resource master to register the sender as an
info message listener.
|
class |
RegisterInfoMessageListenerSuccessful
This message signals to the application client that the registration was successful.
|
class |
RegisterResourceManager
This message signals that the resource manager wants to register at the JobManager leader.
|
class |
RegisterResourceManagerSuccessful
Message that informs the resource manager that the JobManager accepted its registration.
|
class |
RemoveResource
Message sent to the ResourceManager by the JobManager to instruct to remove a resource.
|
class |
ResourceRemoved
Message sent to the JobManager by the Resource Manager to inform
about the removal of a resource.
|
class |
SetWorkerPoolSize
Message sent to the resource master actor to adjust the designated number of
workers it maintains.
|
class |
StopCluster
Generic message to signal the cluster framework to shut the cluster down.
|
class |
StopClusterSuccessful
Generic message to signal the cluster listener that the cluster has been shut down.
|
class |
TriggerRegistrationAtJobManager
Causes the resource manager to try and apply at the leader JobManager.
|
class |
UnRegisterInfoMessageListener
This message signals to the resource master to register the sender as an
info message listener.
|
Modifier and Type | Interface and Description |
---|---|
static interface |
RegistrationMessages.RegistrationMessage
Marker trait for registration messages.
|
Modifier and Type | Class and Description |
---|---|
static class |
ExecutionGraphMessages.ExecutionStateChanged
Denotes the execution state change of an
ExecutionVertex |
static class |
ExecutionGraphMessages.JobStatusChanged
Denotes the job state change of a job.
|
static class |
JobClientMessages.ConnectionTimeout$
Message which is triggered when the connection timeout has been reached.
|
static class |
JobClientMessages.JobManagerActorRef
Notifies the JobClientActor about the ActorRef of the new leader.
|
static class |
JobClientMessages.RegistrationTimeout$
Message which is triggered when the JobClient registration at the JobManager times out
|
static class |
JobClientMessages.SubmissionTimeout$
Message which is triggered when the submission timeout has been reached.
|
static class |
JobManagerMessages.CancelJob
Cancels a job with the given
jobID at the JobManager. |
static class |
JobManagerMessages.CancelJobWithSavepoint
Cancels the job with the given
jobID at the JobManager. |
static class |
JobManagerMessages.DisposeSavepoint
Disposes a savepoint.
|
static class |
JobManagerMessages.RecoverAllJobs$
Triggers recovery of all available jobs.
|
static class |
JobManagerMessages.RecoverJob
Triggers the recovery of the job with the given ID.
|
static class |
JobManagerMessages.RecoverSubmittedJob
Triggers the submission of the recovered job
|
static class |
JobManagerMessages.RegisterJobClient
Registers the sender of the message as the client for the provided job identifier.
|
static class |
JobManagerMessages.RemoveJob
Triggers the removal of the job with the given job ID
|
static class |
JobManagerMessages.RequestNextInputSplit
Requesting next input split for the
ExecutionJobVertex
of the job specified by jobID . |
static class |
JobManagerMessages.RequestPartitionProducerState
Requests the execution state of the execution producing a result partition.
|
static class |
JobManagerMessages.ScheduleOrUpdateConsumers
Notifies the
JobManager about available data for a
produced partition. |
static class |
JobManagerMessages.StopJob
Stops a (streaming) job with the given
jobID at the JobManager. |
static class |
JobManagerMessages.SubmitJob
Submits a job to the job manager.
|
static class |
JobManagerMessages.TriggerSavepoint
Triggers a savepoint for the specified job.
|
static class |
Messages.Disconnect
Signals that the receiver (JobManager/TaskManager) shall disconnect the sender.
|
static class |
RegistrationMessages.AcknowledgeRegistration
Denotes the successful registration of a task manager at the JobManager.
|
static class |
RegistrationMessages.AlreadyRegistered
Denotes that the TaskManager has already been registered at the JobManager.
|
static class |
RegistrationMessages.RefuseRegistration
Denotes the unsuccessful registration of a task manager at the JobManager.
|
static class |
RegistrationMessages.RegisterTaskManager
Registers a task manager at the JobManager.
|
static class |
RegistrationMessages.TriggerTaskManagerRegistration
Triggers the TaskManager to attempt a registration at the JobManager.
|
static class |
TaskMessages.CancelTask
Cancels the task associated with
attemptID . |
static class |
TaskMessages.FailIntermediateResultPartitions
Fails (and releases) all intermediate result partitions identified by
executionID from the task manager. |
static class |
TaskMessages.StopTask
Stops the task associated with
attemptID . |
static class |
TaskMessages.SubmitTask
Submits a task to the task manager.
|
static class |
TaskMessages.UpdatePartitionInfo
Base class for messages that update the information about location of input partitions
|
static class |
TaskMessages.UpdateTaskExecutionState
Denotes a state change of a task at the JobManager.
|
static class |
TaskMessages.UpdateTaskMultiplePartitionInfos |
static class |
TaskMessages.UpdateTaskSinglePartitionInfo |
Modifier and Type | Class and Description |
---|---|
static class |
YarnMessages.AcknowledgeApplicationClientRegistration$
Response to a
RegisterApplicationClient message which led to a successful registration
of the ApplicationClient |
static class |
YarnMessages.RegisterApplicationClient$
Registration message sent from the
ApplicationClient to the YarnFlinkResourceManager . |
static class |
YarnMessages.TriggerApplicationClientRegistration
Triggers the registration of the ApplicationClient to the YarnJobManager
|
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.