public class FlinkYarnClient extends FlinkYarnClientBase
FlinkYarnClientBase
which starts an ApplicationMaster
.FlinkYarnClientBase.YarnDeploymentException
ENV_APP_ID, ENV_CLIENT_HOME_DIR, ENV_CLIENT_SHIP_FILES, ENV_CLIENT_USERNAME, ENV_DETACHED, ENV_DYNAMIC_PROPERTIES, ENV_SLOTS, ENV_STREAMING_MODE, ENV_TM_COUNT, ENV_TM_MEMORY, FLINK_JAR_PATH
Constructor and Description |
---|
FlinkYarnClient() |
Modifier and Type | Method and Description |
---|---|
protected Class<?> |
getApplicationMasterClass() |
allocateResource, deploy, deployInternal, getClusterDescription, getDynamicPropertiesEncoded, getFlinkConfiguration, getFlinkLoggingConfigurationPath, getSessionFilesDir, getTaskManagerCount, getTaskManagerSlots, isDetached, isReadyForDeployment, setConfigurationDirectory, setConfigurationFilePath, setDetachedMode, setDynamicPropertiesEncoded, setFlinkConfiguration, setFlinkLoggingConfigurationPath, setJobManagerMemory, setLocalJarPath, setName, setQueue, setShipFiles, setTaskManagerCount, setTaskManagerMemory, setTaskManagerSlots
protected Class<?> getApplicationMasterClass()
getApplicationMasterClass
in class FlinkYarnClientBase
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.