static akka.actor.Props |
YarnFlinkResourceManager.createActorProps(Class<? extends YarnFlinkResourceManager> actorClass,
org.apache.flink.configuration.Configuration flinkConfig,
org.apache.hadoop.yarn.conf.YarnConfiguration yarnConfig,
org.apache.flink.runtime.leaderretrieval.LeaderRetrievalService leaderRetrievalService,
String applicationMasterHostName,
String webFrontendURL,
org.apache.flink.runtime.clusterframework.ContaineredTaskManagerParameters taskManagerParameters,
org.apache.hadoop.yarn.api.records.ContainerLaunchContext taskManagerLaunchContext,
int numInitialTaskManagers,
org.slf4j.Logger log)
Creates the props needed to instantiate this actor.
|