org.apache.flink.mesos.entrypoint

Class MesosJobClusterEntrypoint

java.lang.Object

org.apache.flink.runtime.entrypoint.ClusterEntrypoint

org.apache.flink.runtime.entrypoint.JobClusterEntrypoint

org.apache.flink.mesos.entrypoint.MesosJobClusterEntrypoint

All Implemented Interfaces:

FatalErrorHandler

public class MesosJobClusterEntrypoint
extends JobClusterEntrypoint

Entry point for Mesos per-job clusters.

Field Summary

Fields

Modifier and Type	Field and Description
static String	JOB_GRAPH_FILE_PATH

Fields inherited from class org.apache.flink.runtime.entrypoint.ClusterEntrypoint

LOG, RUNTIME_FAILURE_RETURN_CODE, STARTUP_FAILURE_RETURN_CODE, SUCCESS_RETURN_CODE

Constructor Summary

Constructors

Constructor and Description
MesosJobClusterEntrypoint(Configuration config, Configuration dynamicProperties)

Method Summary

Modifier and Type	Method and Description
protected ResourceManager<?>	createResourceManager(Configuration configuration, ResourceID resourceId, RpcService rpcService, HighAvailabilityServices highAvailabilityServices, HeartbeatServices heartbeatServices, MetricRegistry metricRegistry, FatalErrorHandler fatalErrorHandler)
protected void	initializeServices(Configuration config)
static void	main(String[] args)
protected JobGraph	retrieveJobGraph(Configuration configuration)
protected void	startClusterComponents(Configuration configuration, RpcService rpcService, HighAvailabilityServices highAvailabilityServices, BlobServer blobServer, HeartbeatServices heartbeatServices, MetricRegistry metricRegistry)
protected void	stopClusterComponents(boolean cleanupHaData)

Methods inherited from class org.apache.flink.runtime.entrypoint.JobClusterEntrypoint

createJobManagerRunner

Methods inherited from class org.apache.flink.runtime.entrypoint.ClusterEntrypoint

configureFileSystems, createHaServices, createHeartbeatServices, createMetricRegistry, createRpcService, getTerminationFuture, installSecurityContext, loadConfiguration, onFatalError, parseArguments, runCluster, shutDown, startCluster

Methods inherited from class java.lang.Object

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

Field Detail

JOB_GRAPH_FILE_PATH

public static final String JOB_GRAPH_FILE_PATH

See Also:

Constant Field Values

Constructor Detail

MesosJobClusterEntrypoint

public MesosJobClusterEntrypoint(Configuration config,
                                 Configuration dynamicProperties)

Method Detail

initializeServices

protected void initializeServices(Configuration config)
                           throws Exception

Overrides:

initializeServices in class ClusterEntrypoint

Throws:

Exception

startClusterComponents

protected void startClusterComponents(Configuration configuration,
                                      RpcService rpcService,
                                      HighAvailabilityServices highAvailabilityServices,
                                      BlobServer blobServer,
                                      HeartbeatServices heartbeatServices,
                                      MetricRegistry metricRegistry)
                               throws Exception

Overrides:

startClusterComponents in class JobClusterEntrypoint

Throws:

Exception

createResourceManager

protected ResourceManager<?> createResourceManager(Configuration configuration,
                                                   ResourceID resourceId,
                                                   RpcService rpcService,
                                                   HighAvailabilityServices highAvailabilityServices,
                                                   HeartbeatServices heartbeatServices,
                                                   MetricRegistry metricRegistry,
                                                   FatalErrorHandler fatalErrorHandler)
                                            throws Exception

Specified by:

createResourceManager in class JobClusterEntrypoint

Throws:

Exception

retrieveJobGraph

protected JobGraph retrieveJobGraph(Configuration configuration)
                             throws FlinkException

Specified by:

retrieveJobGraph in class JobClusterEntrypoint

Throws:

FlinkException

stopClusterComponents

protected void stopClusterComponents(boolean cleanupHaData)
                              throws Exception

Overrides:

stopClusterComponents in class JobClusterEntrypoint

Throws:

Exception

main

public static void main(String[] args)