YarnFlinkResourceManager(org.apache.flink.configuration.Configuration flinkConfig,
org.apache.hadoop.yarn.conf.YarnConfiguration yarnConfig,
org.apache.flink.runtime.leaderretrieval.LeaderRetrievalService leaderRetrievalService,
String applicationMasterHostName,
String webInterfaceURL,
org.apache.flink.runtime.clusterframework.ContaineredTaskManagerParameters taskManagerParameters,
org.apache.hadoop.yarn.api.records.ContainerLaunchContext taskManagerLaunchContext,
int yarnHeartbeatIntervalMillis,
int maxFailedContainers,
int numInitialTaskManagers,
YarnResourceManagerCallbackHandler callbackHandler) |
YarnFlinkResourceManager(org.apache.flink.configuration.Configuration flinkConfig,
org.apache.hadoop.yarn.conf.YarnConfiguration yarnConfig,
org.apache.flink.runtime.leaderretrieval.LeaderRetrievalService leaderRetrievalService,
String applicationMasterHostName,
String webInterfaceURL,
org.apache.flink.runtime.clusterframework.ContaineredTaskManagerParameters taskManagerParameters,
org.apache.hadoop.yarn.api.records.ContainerLaunchContext taskManagerLaunchContext,
int yarnHeartbeatIntervalMillis,
int maxFailedContainers,
int numInitialTaskManagers,
YarnResourceManagerCallbackHandler callbackHandler,
org.apache.hadoop.yarn.client.api.async.AMRMClientAsync<org.apache.hadoop.yarn.client.api.AMRMClient.ContainerRequest> resourceManagerClient,
org.apache.hadoop.yarn.client.api.NMClient nodeManagerClient) |