org.apache.flink.mesos.runtime.clusterframework

Class MesosApplicationMasterRunner

java.lang.Object

org.apache.flink.mesos.runtime.clusterframework.MesosApplicationMasterRunner

public class MesosApplicationMasterRunner
extends Object

This class is the executable entry point for the Mesos Application Master. It starts actor system and the actors for JobManager and MesosFlinkResourceManager.

The JobManager handles Flink job execution, while the MesosFlinkResourceManager handles container allocation and failure detection.

Field Summary

Fields

Modifier and Type	Field and Description
protected static org.slf4j.Logger	LOG

Constructor Summary

Constructors

Constructor and Description
MesosApplicationMasterRunner()

Method Summary

Modifier and Type	Method and Description
protected Class<? extends org.apache.flink.runtime.jobmanager.MemoryArchivist>	getArchivistClass()
protected Class<? extends org.apache.flink.runtime.jobmanager.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(org.apache.flink.configuration.Configuration config, org.apache.flink.configuration.Configuration dynamicProperties) The main work method, must run as a privileged action.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

LOG

protected static final org.slf4j.Logger LOG

Constructor Detail

MesosApplicationMasterRunner

public MesosApplicationMasterRunner()

Method Detail

main

public static void main(String[] args)

The entry point for the Mesos AppMaster.

Parameters:

args - The command line arguments.

run

protected int run(String[] args)

The instance entry point for the Mesos AppMaster. Obtains user group information and calls the main work method runPrivileged(Configuration, Configuration) as a privileged action.

Parameters:

args - The command line arguments.

Returns:

The process exit code.

runPrivileged

protected int runPrivileged(org.apache.flink.configuration.Configuration config,
                            org.apache.flink.configuration.Configuration dynamicProperties)

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

Returns:

The return code for the Java process.

getResourceManagerClass

protected Class<? extends MesosFlinkResourceManager> getResourceManagerClass()

getJobManagerClass

protected Class<? extends org.apache.flink.runtime.jobmanager.JobManager> getJobManagerClass()

getArchivistClass

protected Class<? extends org.apache.flink.runtime.jobmanager.MemoryArchivist> getArchivistClass()