A B C D E F G H I K L M O P R S T U V W Y

A

AbstractYarnClusterDescriptor - Class in org.apache.flink.yarn

The descriptor with deployment information for spawning or resuming a YarnClusterClient.

AbstractYarnClusterDescriptor(Configuration, YarnConfiguration, String, YarnClient, boolean) - Constructor for class org.apache.flink.yarn.AbstractYarnClusterDescriptor

AbstractYarnNonHaServices - Class in org.apache.flink.yarn.highavailability

Abstract base class for the high availability services for Flink YARN applications that support no master fail over.

AbstractYarnNonHaServices(Configuration, Configuration) - Constructor for class org.apache.flink.yarn.highavailability.AbstractYarnNonHaServices

Creates new YARN high-availability services, configuring the file system and recovery data directory based on the working directory in the given Hadoop configuration.

addGeneralOptions(Options) - Method in class org.apache.flink.yarn.cli.FlinkYarnSessionCli

addLibFolderToShipFiles(Collection<File>) - Method in class org.apache.flink.yarn.AbstractYarnClusterDescriptor

addRunOptions(Options) - Method in class org.apache.flink.yarn.cli.FlinkYarnSessionCli

addShipFiles(List<File>) - Method in class org.apache.flink.yarn.AbstractYarnClusterDescriptor

Adds the given files to the list of files to ship.

addToEnvironment(Map<String, String>, String, String) - Static method in class org.apache.flink.yarn.Utils

Copied method from org.apache.hadoop.yarn.util.Apps.

APP_MASTER_RPC_ADDRESS - Static variable in class org.apache.flink.yarn.configuration.YarnConfigOptions

The hostname or address where the application master RPC system is listening.

APP_MASTER_RPC_PORT - Static variable in class org.apache.flink.yarn.configuration.YarnConfigOptions

The port where the application master RPC system is listening.

APPLICATION_ATTEMPTS - Static variable in class org.apache.flink.yarn.configuration.YarnConfigOptions

Set the number of retries for failed YARN ApplicationMasters/JobManagers in high availability mode.

APPLICATION_MASTER_PORT - Static variable in class org.apache.flink.yarn.configuration.YarnConfigOptions

The config parameter defining the Akka actor system port for the ApplicationMaster and JobManager.

APPLICATION_TAGS - Static variable in class org.apache.flink.yarn.configuration.YarnConfigOptions

A comma-separated list of strings to use as YARN application tags.

applyCommandLineOptionsToConfiguration(CommandLine) - Method in class org.apache.flink.yarn.cli.FlinkYarnSessionCli

B

blobStoreService - Variable in class org.apache.flink.yarn.highavailability.YarnHighAvailabilityServices

Blob store service to be used for the BlobServer and BlobCache.

C

calculateHeapSize(int, Configuration) - Static method in class org.apache.flink.yarn.Utils

See documentation.

call() - Method in class org.apache.flink.yarn.YarnTaskManagerRunnerFactory.Runner

CLASSPATH_INCLUDE_USER_JAR - Static variable in class org.apache.flink.yarn.configuration.YarnConfigOptions

Defines whether user-jars are included in the system class path for per-job-clusters as well as their positioning in the path.

close() - Method in class org.apache.flink.yarn.AbstractYarnClusterDescriptor

close() - Method in class org.apache.flink.yarn.cli.YarnApplicationStatusMonitor

close() - Method in class org.apache.flink.yarn.highavailability.YarnHighAvailabilityServices

close() - Method in class org.apache.flink.yarn.highavailability.YarnIntraNonHaMasterServices

closeAndCleanupAllData() - Method in class org.apache.flink.yarn.highavailability.YarnHighAvailabilityServices

CONFIG_FILE_LOG4J_NAME - Static variable in class org.apache.flink.yarn.cli.FlinkYarnSessionCli

CONFIG_FILE_LOGBACK_NAME - Static variable in class org.apache.flink.yarn.cli.FlinkYarnSessionCli

container() - Method in class org.apache.flink.yarn.YarnContainerInLaunch

containers() - Method in class org.apache.flink.yarn.messages.ContainersAllocated

containers() - Method in class org.apache.flink.yarn.messages.ContainersComplete

ContainersAllocated - Class in org.apache.flink.yarn.messages

Message sent by the callback handler to the YarnFlinkResourceManager to notify it that a set of new containers is available.

ContainersAllocated(List<Container>) - Constructor for class org.apache.flink.yarn.messages.ContainersAllocated

ContainersComplete - Class in org.apache.flink.yarn.messages

Message sent by the callback handler to the YarnFlinkResourceManager to notify it that a set of new containers is complete.

ContainersComplete(List<ContainerStatus>) - Constructor for class org.apache.flink.yarn.messages.ContainersComplete

create(String[], Class<? extends YarnTaskManager>, Map<String, String>) - Static method in class org.apache.flink.yarn.YarnTaskManagerRunnerFactory

Creates a YarnTaskManagerRunnerFactory.Runner.

createActorProps(Class<? extends YarnFlinkResourceManager>, Configuration, YarnConfiguration, LeaderRetrievalService, String, String, ContaineredTaskManagerParameters, ContainerLaunchContext, int, Logger) - Static method in class org.apache.flink.yarn.YarnFlinkResourceManager

Creates the props needed to instantiate this actor.

createAndStartNodeManagerClient(YarnConfiguration) - Method in class org.apache.flink.yarn.YarnResourceManager

createAndStartResourceManagerClient(YarnConfiguration, int, String) - Method in class org.apache.flink.yarn.YarnResourceManager

createBlobStore() - Method in class org.apache.flink.yarn.highavailability.YarnHighAvailabilityServices

createClusterDescriptor(CommandLine) - Method in class org.apache.flink.yarn.cli.FlinkYarnSessionCli

createDispatcherResourceManagerComponentFactory(Configuration) - Method in class org.apache.flink.yarn.entrypoint.YarnJobClusterEntrypoint

createDispatcherResourceManagerComponentFactory(Configuration) - Method in class org.apache.flink.yarn.entrypoint.YarnSessionClusterEntrypoint

createResourceManager(Configuration, ResourceID, RpcService, HighAvailabilityServices, HeartbeatServices, MetricRegistry, FatalErrorHandler, ClusterInformation, String, JobManagerMetricGroup) - Method in enum org.apache.flink.yarn.entrypoint.YarnResourceManagerFactory

createYarnClusterClient(AbstractYarnClusterDescriptor, int, int, ApplicationReport, Configuration, boolean) - Method in class org.apache.flink.yarn.AbstractYarnClusterDescriptor

Creates a YarnClusterClient; may be overriden in tests.

createYarnClusterClient(AbstractYarnClusterDescriptor, int, int, ApplicationReport, Configuration, boolean) - Method in class org.apache.flink.yarn.LegacyYarnClusterDescriptor

createYarnClusterClient(AbstractYarnClusterDescriptor, int, int, ApplicationReport, Configuration, boolean) - Method in class org.apache.flink.yarn.YarnClusterDescriptor

D

deleteApplicationFiles(Map<String, String>) - Static method in class org.apache.flink.yarn.Utils

Deletes the YARN application files, e.g., Flink binaries, libraries, etc., from the remote filesystem.

deployInternal(ClusterSpecification, String, String, JobGraph, boolean) - Method in class org.apache.flink.yarn.AbstractYarnClusterDescriptor

This method will block until the ApplicationMaster/JobManager have been deployed on YARN.

deployJobCluster(ClusterSpecification, JobGraph, boolean) - Method in class org.apache.flink.yarn.LegacyYarnClusterDescriptor

deployJobCluster(ClusterSpecification, JobGraph, boolean) - Method in class org.apache.flink.yarn.YarnClusterDescriptor

deploySessionCluster(ClusterSpecification) - Method in class org.apache.flink.yarn.AbstractYarnClusterDescriptor

E

ENV_APP_ID - Static variable in class org.apache.flink.yarn.YarnConfigKeys

ENV_CLIENT_HOME_DIR - Static variable in class org.apache.flink.yarn.YarnConfigKeys

ENV_CLIENT_SHIP_FILES - Static variable in class org.apache.flink.yarn.YarnConfigKeys

ENV_DETACHED - Static variable in class org.apache.flink.yarn.YarnConfigKeys

ENV_DYNAMIC_PROPERTIES - Static variable in class org.apache.flink.yarn.YarnConfigKeys

ENV_FLINK_CLASSPATH - Static variable in class org.apache.flink.yarn.YarnConfigKeys

ENV_HADOOP_USER_NAME - Static variable in class org.apache.flink.yarn.YarnConfigKeys

ENV_KRB5_PATH - Static variable in class org.apache.flink.yarn.YarnConfigKeys

ENV_SLOTS - Static variable in class org.apache.flink.yarn.YarnConfigKeys

ENV_TM_COUNT - Static variable in class org.apache.flink.yarn.YarnConfigKeys

ENV_TM_MEMORY - Static variable in class org.apache.flink.yarn.YarnConfigKeys

ENV_YARN_SITE_XML_PATH - Static variable in class org.apache.flink.yarn.YarnConfigKeys

ENV_ZOOKEEPER_NAMESPACE - Static variable in class org.apache.flink.yarn.YarnConfigKeys

F

fatalError(String, Throwable) - Method in class org.apache.flink.yarn.YarnFlinkResourceManager

FLINK_JAR_PATH - Static variable in class org.apache.flink.yarn.YarnConfigKeys

FLINK_RECOVERY_DATA_DIR - Static variable in class org.apache.flink.yarn.highavailability.YarnHighAvailabilityServices

The name of the sub directory in which Flink stores the recovery data.

FLINK_YARN_FILES - Static variable in class org.apache.flink.yarn.YarnConfigKeys

flinkFileSystem - Variable in class org.apache.flink.yarn.highavailability.YarnHighAvailabilityServices

The Flink FileSystem object that represent the HDFS used by YARN.

FlinkYarnSessionCli - Class in org.apache.flink.yarn.cli

Class handling the command line interface to the YARN session.

FlinkYarnSessionCli(Configuration, String, String, String) - Constructor for class org.apache.flink.yarn.cli.FlinkYarnSessionCli

FlinkYarnSessionCli(Configuration, String, String, String, boolean) - Constructor for class org.apache.flink.yarn.cli.FlinkYarnSessionCli

forSingleJobAppMaster(Configuration, Configuration) - Static method in class org.apache.flink.yarn.highavailability.YarnHighAvailabilityServices

Creates the high-availability services for a single-job Flink YARN application, to be used in the Application Master that runs both ResourceManager and JobManager.

forYarnTaskManager(Configuration, Configuration) - Static method in class org.apache.flink.yarn.highavailability.YarnHighAvailabilityServices

Creates the high-availability services for the TaskManagers participating in a Flink YARN application.

G

getApplicationId() - Method in class org.apache.flink.yarn.YarnClusterClient

getApplicationStatusNow() - Method in class org.apache.flink.yarn.cli.YarnApplicationStatusMonitor

getArchivistClass() - Method in class org.apache.flink.yarn.YarnApplicationMasterRunner

getCheckpointRecoveryFactory() - Method in class org.apache.flink.yarn.highavailability.AbstractYarnNonHaServices

getClusterDescription() - Method in class org.apache.flink.yarn.AbstractYarnClusterDescriptor

getClusterId(CommandLine) - Method in class org.apache.flink.yarn.cli.FlinkYarnSessionCli

getClusterId() - Method in class org.apache.flink.yarn.YarnClusterClient

getClusterSpecification(CommandLine) - Method in class org.apache.flink.yarn.cli.FlinkYarnSessionCli

getClusterStatus() - Method in class org.apache.flink.yarn.YarnClusterClient

This method is only available if the cluster hasn't been started in detached mode.

getContainer() - Method in class org.apache.flink.yarn.YarnWorkerNode

getDispatcherLeaderElectionService() - Method in class org.apache.flink.yarn.highavailability.YarnIntraNonHaMasterServices

getDispatcherLeaderElectionService() - Method in class org.apache.flink.yarn.highavailability.YarnPreConfiguredMasterNonHaServices

getDispatcherLeaderRetriever() - Method in class org.apache.flink.yarn.highavailability.YarnIntraNonHaMasterServices

getDispatcherLeaderRetriever() - Method in class org.apache.flink.yarn.highavailability.YarnPreConfiguredMasterNonHaServices

getDynamicProperties(String) - Static method in class org.apache.flink.yarn.cli.FlinkYarnSessionCli

getDynamicPropertiesEncoded() - Method in class org.apache.flink.yarn.AbstractYarnClusterDescriptor

getEnvironmentVariables(String, Configuration) - Static method in class org.apache.flink.yarn.Utils

Method to extract environment variables from the flinkConfiguration based on the given prefix String.

getFlinkConfiguration() - Method in class org.apache.flink.yarn.AbstractYarnClusterDescriptor

getFlinkConfiguration() - Method in class org.apache.flink.yarn.YarnClusterClient

getId() - Method in class org.apache.flink.yarn.cli.FlinkYarnSessionCli

getJobManagerClass() - Method in class org.apache.flink.yarn.YarnApplicationMasterRunner

getJobManagerLeaderElectionService(JobID) - Method in class org.apache.flink.yarn.highavailability.YarnIntraNonHaMasterServices

getJobManagerLeaderElectionService(JobID) - Method in class org.apache.flink.yarn.highavailability.YarnPreConfiguredMasterNonHaServices

getJobManagerLeaderRetriever(JobID) - Method in class org.apache.flink.yarn.highavailability.YarnIntraNonHaMasterServices

getJobManagerLeaderRetriever(JobID, String) - Method in class org.apache.flink.yarn.highavailability.YarnIntraNonHaMasterServices

getJobManagerLeaderRetriever(JobID) - Method in class org.apache.flink.yarn.highavailability.YarnPreConfiguredMasterNonHaServices

getJobManagerLeaderRetriever(JobID, String) - Method in class org.apache.flink.yarn.highavailability.YarnPreConfiguredMasterNonHaServices

getMaxSlots() - Method in class org.apache.flink.yarn.YarnClusterClient

getNewMessages() - Method in class org.apache.flink.yarn.YarnClusterClient

getNodeLabel() - Method in class org.apache.flink.yarn.AbstractYarnClusterDescriptor

getNumWorkerRequestsPending() - Method in class org.apache.flink.yarn.YarnFlinkResourceManager

getNumWorkersPendingRegistration() - Method in class org.apache.flink.yarn.YarnFlinkResourceManager

getProgress() - Method in class org.apache.flink.yarn.YarnResourceManager

getProgress() - Method in class org.apache.flink.yarn.YarnResourceManagerCallbackHandler

getResourceID() - Method in class org.apache.flink.yarn.RegisteredYarnWorkerNode

getResourceID() - Method in class org.apache.flink.yarn.YarnContainerInLaunch

getResourceID() - Method in class org.apache.flink.yarn.YarnWorkerNode

getResourceManagerClass() - Method in class org.apache.flink.yarn.YarnApplicationMasterRunner

getResourceManagerLeaderElectionService() - Method in class org.apache.flink.yarn.highavailability.YarnIntraNonHaMasterServices

getResourceManagerLeaderElectionService() - Method in class org.apache.flink.yarn.highavailability.YarnPreConfiguredMasterNonHaServices

getResourceManagerLeaderRetriever() - Method in class org.apache.flink.yarn.highavailability.YarnIntraNonHaMasterServices

getResourceManagerLeaderRetriever() - Method in class org.apache.flink.yarn.highavailability.YarnPreConfiguredMasterNonHaServices

getRPCPortRange(Configuration) - Method in class org.apache.flink.yarn.entrypoint.YarnJobClusterEntrypoint

getRPCPortRange(Configuration) - Method in class org.apache.flink.yarn.entrypoint.YarnSessionClusterEntrypoint

getRunningJobsRegistry() - Method in class org.apache.flink.yarn.highavailability.AbstractYarnNonHaServices

getSubmittedJobGraphStore() - Method in class org.apache.flink.yarn.highavailability.AbstractYarnNonHaServices

getTaskManagerClass() - Method in class org.apache.flink.yarn.YarnApplicationMasterRunner

getWebInterfaceURL() - Method in class org.apache.flink.yarn.YarnClusterClient

getWebMonitorLeaderElectionService() - Method in class org.apache.flink.yarn.highavailability.YarnIntraNonHaMasterServices

getWebMonitorLeaderElectionService() - Method in class org.apache.flink.yarn.highavailability.YarnPreConfiguredMasterNonHaServices

getWebMonitorLeaderRetriever() - Method in class org.apache.flink.yarn.highavailability.YarnIntraNonHaMasterServices

getWebMonitorLeaderRetriever() - Method in class org.apache.flink.yarn.highavailability.YarnPreConfiguredMasterNonHaServices

getYarnClient() - Method in class org.apache.flink.yarn.AbstractYarnClusterDescriptor

getYarnJobClusterEntrypoint() - Method in class org.apache.flink.yarn.AbstractYarnClusterDescriptor

The class to start the application master with.

getYarnJobClusterEntrypoint() - Method in class org.apache.flink.yarn.LegacyYarnClusterDescriptor

getYarnJobClusterEntrypoint() - Method in class org.apache.flink.yarn.YarnClusterDescriptor

getYarnPropertiesLocation(String) - Static method in class org.apache.flink.yarn.cli.FlinkYarnSessionCli

getYarnSessionClusterEntrypoint() - Method in class org.apache.flink.yarn.AbstractYarnClusterDescriptor

The class to start the application master with.

getYarnSessionClusterEntrypoint() - Method in class org.apache.flink.yarn.LegacyYarnClusterDescriptor

getYarnSessionClusterEntrypoint() - Method in class org.apache.flink.yarn.YarnClusterDescriptor

getZookeeperNamespace() - Method in class org.apache.flink.yarn.AbstractYarnClusterDescriptor

H

haDataDirectory - Variable in class org.apache.flink.yarn.highavailability.YarnHighAvailabilityServices

The directory for HA persistent data.

hadoopFileSystem - Variable in class org.apache.flink.yarn.highavailability.YarnHighAvailabilityServices

The Hadoop FileSystem object that represent the HDFS used by YARN.

handleMessage(Object) - Method in class org.apache.flink.yarn.YarnFlinkResourceManager

hasUserJarFiles(List<URL>) - Method in class org.apache.flink.yarn.AbstractYarnClusterDescriptor

Returns true if the descriptor has the job jars to include in the classpath.

hasUserJarsInClassPath(List<URL>) - Method in class org.apache.flink.yarn.YarnClusterClient

HEARTBEAT_DELAY_SECONDS - Static variable in class org.apache.flink.yarn.configuration.YarnConfigOptions

The heartbeat interval between the Application Master and the YARN Resource Manager.

I

initialize() - Method in class org.apache.flink.yarn.YarnFlinkResourceManager

initialize() - Method in class org.apache.flink.yarn.YarnResourceManager

initialize(ActorRef) - Method in class org.apache.flink.yarn.YarnResourceManagerCallbackHandler

installSecurityContext(Configuration, String) - Static method in class org.apache.flink.yarn.entrypoint.YarnEntrypointUtils

installSecurityContext(Configuration) - Method in class org.apache.flink.yarn.entrypoint.YarnJobClusterEntrypoint

installSecurityContext(Configuration) - Method in class org.apache.flink.yarn.entrypoint.YarnSessionClusterEntrypoint

internalDeregisterApplication(ApplicationStatus, String) - Method in class org.apache.flink.yarn.YarnResourceManager

isActive(CommandLine) - Method in class org.apache.flink.yarn.cli.FlinkYarnSessionCli

isClosed() - Method in class org.apache.flink.yarn.highavailability.YarnHighAvailabilityServices

Checks whether these services have been shut down.

isDetached() - Method in class org.apache.flink.yarn.YarnClusterClient

isDetachedMode() - Method in class org.apache.flink.yarn.AbstractYarnClusterDescriptor

Deprecated.

The cluster descriptor should not know about this option.

K

KEYTAB_FILE_NAME - Static variable in class org.apache.flink.yarn.Utils

Keytab file name populated in YARN container.

KEYTAB_PATH - Static variable in class org.apache.flink.yarn.YarnConfigKeys

KEYTAB_PRINCIPAL - Static variable in class org.apache.flink.yarn.YarnConfigKeys

killCluster(ApplicationId) - Method in class org.apache.flink.yarn.AbstractYarnClusterDescriptor

KRB5_FILE_NAME - Static variable in class org.apache.flink.yarn.Utils

KRB5 file name populated in YARN container for secure IT run.

L

LegacyYarnClusterDescriptor - Class in org.apache.flink.yarn

Legacy implementation of AbstractYarnClusterDescriptor which starts an YarnApplicationMasterRunner.

LegacyYarnClusterDescriptor(Configuration, YarnConfiguration, String, YarnClient, boolean) - Constructor for class org.apache.flink.yarn.LegacyYarnClusterDescriptor

loadConfiguration(String, Map<String, String>, Logger) - Static method in class org.apache.flink.yarn.entrypoint.YarnEntrypointUtils

LOG - Static variable in class org.apache.flink.yarn.highavailability.YarnHighAvailabilityServices

Logger for these services, shared with subclasses.

LOG - Static variable in class org.apache.flink.yarn.YarnApplicationMasterRunner

LOG - Static variable in class org.apache.flink.yarn.YarnTaskExecutorRunner

logYarnEnvironmentInformation(Map<String, String>, Logger) - Static method in class org.apache.flink.yarn.entrypoint.YarnEntrypointUtils

M

main(String[]) - Static method in class org.apache.flink.yarn.cli.FlinkYarnSessionCli

main(String[]) - Static method in class org.apache.flink.yarn.entrypoint.YarnJobClusterEntrypoint

main(String[]) - Static method in class org.apache.flink.yarn.entrypoint.YarnSessionClusterEntrypoint

main(String[]) - Static method in class org.apache.flink.yarn.YarnApplicationMasterRunner

The entry point for the YARN application master.

main(String[]) - Static method in class org.apache.flink.yarn.YarnTaskExecutorRunner

The entry point for the YARN task executor runner.

MAX_FAILED_CONTAINERS - Static variable in class org.apache.flink.yarn.configuration.YarnConfigOptions

The maximum number of failed YARN containers before entirely stopping the YARN session / job on YARN.

O

onContainersAllocated(List<Container>) - Method in class org.apache.flink.yarn.YarnResourceManager

onContainersAllocated(List<Container>) - Method in class org.apache.flink.yarn.YarnResourceManagerCallbackHandler

onContainersCompleted(List<ContainerStatus>) - Method in class org.apache.flink.yarn.YarnResourceManager

onContainersCompleted(List<ContainerStatus>) - Method in class org.apache.flink.yarn.YarnResourceManagerCallbackHandler

onError(Throwable) - Method in class org.apache.flink.yarn.YarnResourceManager

onError(Throwable) - Method in class org.apache.flink.yarn.YarnResourceManagerCallbackHandler

onNodesUpdated(List<NodeReport>) - Method in class org.apache.flink.yarn.YarnResourceManager

onNodesUpdated(List<NodeReport>) - Method in class org.apache.flink.yarn.YarnResourceManagerCallbackHandler

onShutdownRequest() - Method in class org.apache.flink.yarn.YarnResourceManager

onShutdownRequest() - Method in class org.apache.flink.yarn.YarnResourceManagerCallbackHandler

org.apache.flink.yarn - package org.apache.flink.yarn

org.apache.flink.yarn.cli - package org.apache.flink.yarn.cli

org.apache.flink.yarn.configuration - package org.apache.flink.yarn.configuration

org.apache.flink.yarn.entrypoint - package org.apache.flink.yarn.entrypoint

org.apache.flink.yarn.highavailability - package org.apache.flink.yarn.highavailability

org.apache.flink.yarn.messages - package org.apache.flink.yarn.messages

P

postStop() - Method in class org.apache.flink.yarn.YarnResourceManager

PROPERTIES_FILE_LOCATION - Static variable in class org.apache.flink.yarn.configuration.YarnConfigOptions

When a Flink job is submitted to YARN, the JobManager's host and the number of available processing slots is written into a properties file, so that the Flink client is able to pick those details up.

R

reacceptRegisteredWorkers(Collection<ResourceID>) - Method in class org.apache.flink.yarn.YarnFlinkResourceManager

RegisteredYarnWorkerNode - Class in org.apache.flink.yarn

A representation of a registered Yarn container managed by the YarnFlinkResourceManager.

RegisteredYarnWorkerNode(Container) - Constructor for class org.apache.flink.yarn.RegisteredYarnWorkerNode

releasePendingWorker(ResourceID) - Method in class org.apache.flink.yarn.YarnFlinkResourceManager

releaseStartedWorker(RegisteredYarnWorkerNode) - Method in class org.apache.flink.yarn.YarnFlinkResourceManager

requestNewWorkers(int) - Method in class org.apache.flink.yarn.YarnFlinkResourceManager

retrieve(ApplicationId) - Method in class org.apache.flink.yarn.AbstractYarnClusterDescriptor

run(String[]) - Method in class org.apache.flink.yarn.cli.FlinkYarnSessionCli

run(String[]) - Method in class org.apache.flink.yarn.YarnApplicationMasterRunner

The instance entry point for the YARN application master.

runApplicationMaster(Configuration) - Method in class org.apache.flink.yarn.YarnApplicationMasterRunner

The main work method, must run as a privileged action.

S

setCurrentProgress(float) - Method in class org.apache.flink.yarn.YarnResourceManagerCallbackHandler

Sets the current progress.

setDetachedMode(boolean) - Method in class org.apache.flink.yarn.AbstractYarnClusterDescriptor

Deprecated.

The cluster descriptor should not know about this option.

setDynamicPropertiesEncoded(String) - Method in class org.apache.flink.yarn.AbstractYarnClusterDescriptor

setLocalJarPath(Path) - Method in class org.apache.flink.yarn.AbstractYarnClusterDescriptor

setName(String) - Method in class org.apache.flink.yarn.AbstractYarnClusterDescriptor

setNodeLabel(String) - Method in class org.apache.flink.yarn.AbstractYarnClusterDescriptor

setProvidedUserJarFiles(List<URL>) - Method in class org.apache.flink.yarn.AbstractYarnClusterDescriptor

Sets the user jar which is included in the system classloader of all nodes.

setQueue(String) - Method in class org.apache.flink.yarn.AbstractYarnClusterDescriptor

setTokensFor(ContainerLaunchContext, List<Path>, Configuration) - Static method in class org.apache.flink.yarn.Utils

setupApplicationMasterContainer(String, boolean, boolean, boolean, int) - Method in class org.apache.flink.yarn.AbstractYarnClusterDescriptor

setupYarnClassPath(Configuration, Map<String, String>) - Static method in class org.apache.flink.yarn.Utils

setZookeeperNamespace(String) - Method in class org.apache.flink.yarn.AbstractYarnClusterDescriptor

shipFiles - Variable in class org.apache.flink.yarn.AbstractYarnClusterDescriptor

Lazily initialized list of files to ship.

shutdownApplication(ApplicationStatus, String) - Method in class org.apache.flink.yarn.YarnFlinkResourceManager

shutDownCluster() - Method in class org.apache.flink.yarn.YarnClusterClient

startAppMaster(Configuration, String, String, JobGraph, YarnClient, YarnClientApplication, ClusterSpecification) - Method in class org.apache.flink.yarn.AbstractYarnClusterDescriptor

startNewWorker(ResourceProfile) - Method in class org.apache.flink.yarn.YarnResourceManager

stopWorker(YarnWorkerNode) - Method in class org.apache.flink.yarn.YarnResourceManager

submitJob(JobGraph, ClassLoader) - Method in class org.apache.flink.yarn.YarnClusterClient

T

timestamp() - Method in class org.apache.flink.yarn.YarnContainerInLaunch

toString() - Method in class org.apache.flink.yarn.messages.ContainersAllocated

toString() - Method in class org.apache.flink.yarn.messages.ContainersComplete

toString() - Method in class org.apache.flink.yarn.RegisteredYarnWorkerNode

toString() - Method in class org.apache.flink.yarn.YarnContainerInLaunch

U

Utils - Class in org.apache.flink.yarn

Utility class that provides helper methods to work with Apache Hadoop YARN.

V

validateClusterResources(ClusterSpecification, int, Resource, AbstractYarnClusterDescriptor.ClusterResourceDescription) - Method in class org.apache.flink.yarn.AbstractYarnClusterDescriptor

valueOf(String) - Static method in enum org.apache.flink.yarn.configuration.YarnConfigOptions.UserJarInclusion

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum org.apache.flink.yarn.entrypoint.YarnResourceManagerFactory

Returns the enum constant of this type with the specified name.

values() - Static method in enum org.apache.flink.yarn.configuration.YarnConfigOptions.UserJarInclusion

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum org.apache.flink.yarn.entrypoint.YarnResourceManagerFactory

Returns an array containing the constants of this enum type, in the order they are declared.

VCORES - Static variable in class org.apache.flink.yarn.configuration.YarnConfigOptions

The vcores exposed by YARN.

W

waitForClusterToBeReady() - Method in class org.apache.flink.yarn.YarnClusterClient

Blocks until all TaskManagers are connected to the JobManager.

workerStarted(ResourceID) - Method in class org.apache.flink.yarn.YarnFlinkResourceManager

workerStarted(ResourceID) - Method in class org.apache.flink.yarn.YarnResourceManager

workingDirectory - Variable in class org.apache.flink.yarn.highavailability.YarnHighAvailabilityServices

The working directory of this YARN application.

Y

YARN_SITE_FILE_NAME - Static variable in class org.apache.flink.yarn.Utils

Yarn site xml file name populated in YARN container for secure IT run.

YarnApplicationMasterRunner - Class in org.apache.flink.yarn

This class is the executable entry point for the YARN application master.

YarnApplicationMasterRunner() - Constructor for class org.apache.flink.yarn.YarnApplicationMasterRunner

YarnApplicationStatusMonitor - Class in org.apache.flink.yarn.cli

Utility class which monitors the specified yarn application status periodically.

YarnApplicationStatusMonitor(YarnClient, ApplicationId, ScheduledExecutor) - Constructor for class org.apache.flink.yarn.cli.YarnApplicationStatusMonitor

YarnClusterClient - Class in org.apache.flink.yarn

Java representation of a running Flink cluster within YARN.

YarnClusterClient(AbstractYarnClusterDescriptor, int, int, ApplicationReport, Configuration, boolean) - Constructor for class org.apache.flink.yarn.YarnClusterClient

Create a new Flink on YARN cluster.

YarnClusterDescriptor - Class in org.apache.flink.yarn

Implementation of AbstractYarnClusterDescriptor which is used to start the application master.

YarnClusterDescriptor(Configuration, YarnConfiguration, String, YarnClient, boolean) - Constructor for class org.apache.flink.yarn.YarnClusterDescriptor

YarnConfigKeys - Class in org.apache.flink.yarn

The Yarn environment variables used for settings of the containers.

YarnConfigOptions - Class in org.apache.flink.yarn.configuration

This class holds configuration constants used by Flink's YARN runners.

YarnConfigOptions.UserJarInclusion - Enum in org.apache.flink.yarn.configuration

yarnContainer() - Method in class org.apache.flink.yarn.RegisteredYarnWorkerNode

YarnContainerInLaunch - Class in org.apache.flink.yarn

This class describes a container in which a TaskManager is being launched (or has been launched) but where the TaskManager has not properly registered, yet.

YarnContainerInLaunch(Container) - Constructor for class org.apache.flink.yarn.YarnContainerInLaunch

YarnContainerInLaunch(Container, long) - Constructor for class org.apache.flink.yarn.YarnContainerInLaunch

YarnEntrypointUtils - Class in org.apache.flink.yarn.entrypoint

This class contains utility methods for the YarnSessionClusterEntrypoint and YarnJobClusterEntrypoint.

YarnEntrypointUtils() - Constructor for class org.apache.flink.yarn.entrypoint.YarnEntrypointUtils

YarnFlinkResourceManager - Class in org.apache.flink.yarn

Specialized Flink Resource Manager implementation for YARN clusters.

YarnFlinkResourceManager(Configuration, YarnConfiguration, LeaderRetrievalService, String, String, ContaineredTaskManagerParameters, ContainerLaunchContext, int, int, int) - Constructor for class org.apache.flink.yarn.YarnFlinkResourceManager

YarnFlinkResourceManager(Configuration, YarnConfiguration, LeaderRetrievalService, String, String, ContaineredTaskManagerParameters, ContainerLaunchContext, int, int, int, YarnResourceManagerCallbackHandler) - Constructor for class org.apache.flink.yarn.YarnFlinkResourceManager

YarnFlinkResourceManager(Configuration, YarnConfiguration, LeaderRetrievalService, String, String, ContaineredTaskManagerParameters, ContainerLaunchContext, int, int, int, YarnResourceManagerCallbackHandler, AMRMClientAsync<AMRMClient.ContainerRequest>, NMClient) - Constructor for class org.apache.flink.yarn.YarnFlinkResourceManager

YarnHighAvailabilityServices - Class in org.apache.flink.yarn.highavailability

The basis of HighAvailabilityServices for YARN setups.

YarnHighAvailabilityServices(Configuration, Configuration) - Constructor for class org.apache.flink.yarn.highavailability.YarnHighAvailabilityServices

Creates new YARN high-availability services, configuring the file system and recovery data directory based on the working directory in the given Hadoop configuration.

YarnIntraNonHaMasterServices - Class in org.apache.flink.yarn.highavailability

These YarnHighAvailabilityServices are for the Application Master in setups where there is one ResourceManager that is statically configured in the Flink configuration.

YarnIntraNonHaMasterServices(Configuration, Configuration) - Constructor for class org.apache.flink.yarn.highavailability.YarnIntraNonHaMasterServices

Creates new YarnIntraNonHaMasterServices for the given Flink and YARN configuration.

YarnJobClusterEntrypoint - Class in org.apache.flink.yarn.entrypoint

Entry point for Yarn per-job clusters.

YarnJobClusterEntrypoint(Configuration, String) - Constructor for class org.apache.flink.yarn.entrypoint.YarnJobClusterEntrypoint

YarnPreConfiguredMasterNonHaServices - Class in org.apache.flink.yarn.highavailability

These YarnHighAvailabilityServices are for use by the TaskManager in setups, where there is one ResourceManager that is statically configured in the Flink configuration.

YarnPreConfiguredMasterNonHaServices(Configuration, Configuration, HighAvailabilityServicesUtils.AddressResolution) - Constructor for class org.apache.flink.yarn.highavailability.YarnPreConfiguredMasterNonHaServices

Creates new YarnPreConfiguredMasterHaServices for the given Flink and YARN configuration.

YarnResourceManager - Class in org.apache.flink.yarn

The yarn implementation of the resource manager.

YarnResourceManager(RpcService, String, ResourceID, Configuration, Map<String, String>, HighAvailabilityServices, HeartbeatServices, SlotManager, MetricRegistry, JobLeaderIdService, ClusterInformation, FatalErrorHandler, String, JobManagerMetricGroup) - Constructor for class org.apache.flink.yarn.YarnResourceManager

YarnResourceManagerCallbackHandler - Class in org.apache.flink.yarn

This class reacts to callbacks from the YARN Resource Manager.

YarnResourceManagerCallbackHandler() - Constructor for class org.apache.flink.yarn.YarnResourceManagerCallbackHandler

YarnResourceManagerCallbackHandler(ActorRef) - Constructor for class org.apache.flink.yarn.YarnResourceManagerCallbackHandler

YarnResourceManagerFactory - Enum in org.apache.flink.yarn.entrypoint

ResourceManagerFactory implementation which creates a YarnResourceManager.

YarnSessionClusterEntrypoint - Class in org.apache.flink.yarn.entrypoint

Entry point for Yarn session clusters.

YarnSessionClusterEntrypoint(Configuration, String) - Constructor for class org.apache.flink.yarn.entrypoint.YarnSessionClusterEntrypoint

YarnTaskExecutorRunner - Class in org.apache.flink.yarn

This class is the executable entry point for running a TaskExecutor in a YARN container.

YarnTaskExecutorRunner() - Constructor for class org.apache.flink.yarn.YarnTaskExecutorRunner

YarnTaskManagerRunnerFactory - Class in org.apache.flink.yarn

The entry point for running a TaskManager in a YARN container.

YarnTaskManagerRunnerFactory() - Constructor for class org.apache.flink.yarn.YarnTaskManagerRunnerFactory

YarnTaskManagerRunnerFactory.Runner - Class in org.apache.flink.yarn

Runner for the YarnTaskManager.

YarnWorkerNode - Class in org.apache.flink.yarn

A stored YARN worker, which contains the YARN container.

YarnWorkerNode(Container) - Constructor for class org.apache.flink.yarn.YarnWorkerNode

A B C D E F G H I K L M O P R S T U V W Y