Class | Description |
---|---|
ApplicationClient |
Actor which is responsible to repeatedly poll the Yarn cluster status from the JobManager.
|
ApplicationClient$ | |
ApplicationMaster |
Default implementation of the
ApplicationMasterBase which starts a YarnJobManager and a
MemoryArchivist . |
ApplicationMaster$ | |
ApplicationMasterBase |
Base class for all application masters.
|
ApplicationMasterBase$ | |
FlinkYarnClient |
Default implementation of
FlinkYarnClientBase which starts an ApplicationMaster . |
FlinkYarnClientBase |
All classes in this package contain code taken from
https://github.com/apache/hadoop-common/blob/trunk/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-applications-distributedshell/src/main/java/org/apache/hadoop/yarn/applications/distributedshell/Client.java?source=cc
and
https://github.com/hortonworks/simple-yarn-app
and
https://github.com/yahoo/storm-yarn/blob/master/src/main/java/com/yahoo/storm/yarn/StormOnYarn.java
The Flink jar is uploaded to HDFS by this client.
|
FlinkYarnCluster |
Java representation of a running Flink cluster within YARN.
|
FlinkYarnCluster.PollingThread | |
RegisterApplicationMasterResponseReflector |
Singleton object to reflect the getContainersFromPreviousAttempts method for
RegisterApplicationMasterResponse . |
RegisterApplicationMasterResponseReflector$ |
Singleton object to reflect the getContainersFromPreviousAttempts method for
RegisterApplicationMasterResponse . |
Utils |
Utility class that provides helper methods to work with Apache Hadoop YARN.
|
YarnJobManager |
JobManager actor for execution on Yarn.
|
YarnMessages | |
YarnMessages.AcknowledgeApplicationClientRegistration$ |
Response to a
RegisterApplicationClient message which led to a successful registration
of the ApplicationClient |
YarnMessages.ApplicationMasterStatus | |
YarnMessages.ApplicationMasterStatus$ | |
YarnMessages.CheckForUserCommand$ | |
YarnMessages.HeartbeatWithYarn$ | |
YarnMessages.JobManagerLeaderAddress |
Notification message that a new leader has been found.
|
YarnMessages.JobManagerLeaderAddress$ | |
YarnMessages.JobManagerStopped$ | |
YarnMessages.LocalGetYarnClusterStatus$ | |
YarnMessages.LocalGetYarnMessage$ | |
YarnMessages.LocalStopAMAfterJob | |
YarnMessages.LocalStopAMAfterJob$ | |
YarnMessages.LocalStopYarnSession | |
YarnMessages.LocalStopYarnSession$ | |
YarnMessages.PollYarnClusterStatus$ | |
YarnMessages.RegisterApplicationClient$ |
Registration message sent from the
ApplicationClient to the YarnJobManager . |
YarnMessages.StartYarnSession |
Entry point to start a new YarnSession.
|
YarnMessages.StartYarnSession$ | |
YarnMessages.StopAMAfterJob | |
YarnMessages.StopAMAfterJob$ | |
YarnMessages.StopYarnSession | |
YarnMessages.StopYarnSession$ | |
YarnMessages.TriggerApplicationClientRegistration |
Triggers the registration of the ApplicationClient to the YarnJobManager
|
YarnMessages.TriggerApplicationClientRegistration$ | |
YarnMessages.UnregisterClient$ | |
YarnMessages.YarnContainersAllocated |
Callback from the async resource manager client when containers were allocated.
|
YarnMessages.YarnContainersAllocated$ | |
YarnMessages.YarnContainersCompleted |
Callback from the async resource manager client when containers were completed.
|
YarnMessages.YarnContainersCompleted$ | |
YarnMessages.YarnMessage | |
YarnMessages.YarnMessage$ | |
YarnMessages$ | |
YarnTaskManager |
An extension of the TaskManager that listens for additional YARN related
messages.
|
YarnTaskManagerRunner |
The entry point for running a TaskManager in a YARN container.
|
Exception | Description |
---|---|
FlinkYarnClientBase.YarnDeploymentException |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.