public class MesosApplicationMasterRunner extends Object
JobManager
and MesosFlinkResourceManager
.
The JobManager handles Flink job execution, while the MesosFlinkResourceManager handles container
allocation and failure detection.Modifier and Type | Field and Description |
---|---|
protected static org.slf4j.Logger |
LOG
Logger
|
Constructor and Description |
---|
MesosApplicationMasterRunner() |
Modifier and Type | Method and Description |
---|---|
static MesosConfiguration |
createMesosConfig(Configuration flinkConfig,
String hostname)
Loads and validates the ResourceManager Mesos configuration from the given Flink configuration.
|
protected Class<? extends MemoryArchivist> |
getArchivistClass() |
protected Class<? extends JobManager> |
getJobManagerClass() |
protected Class<? extends MesosFlinkResourceManager> |
getResourceManagerClass() |
static void |
main(String[] args)
The entry point for the Mesos AppMaster.
|
protected int |
run(String[] args)
The instance entry point for the Mesos AppMaster.
|
protected int |
runPrivileged(Configuration config,
Configuration dynamicProperties)
The main work method, must run as a privileged action.
|
public static void main(String[] args)
args
- The command line arguments.protected int run(String[] args)
runPrivileged(Configuration,Configuration)
as a
privileged action.args
- The command line arguments.protected int runPrivileged(Configuration config, Configuration dynamicProperties)
protected Class<? extends MesosFlinkResourceManager> getResourceManagerClass()
protected Class<? extends JobManager> getJobManagerClass()
protected Class<? extends MemoryArchivist> getArchivistClass()
public static MesosConfiguration createMesosConfig(Configuration flinkConfig, String hostname)
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.