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:

AutoCloseable, FatalErrorHandler, AutoCloseableAsync

public class MesosJobClusterEntrypoint
extends JobClusterEntrypoint

Entry point for Mesos per-job clusters.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.flink.runtime.entrypoint.ClusterEntrypoint

ClusterEntrypoint.ExecutionMode

Field Summary

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

EXECUTION_MODE, LOG, RUNTIME_FAILURE_RETURN_CODE, STARTUP_FAILURE_RETURN_CODE

Constructor Summary

Constructors

Constructor and Description
MesosJobClusterEntrypoint(Configuration config, Configuration dynamicProperties)

Method Summary

Modifier and Type	Method and Description
protected DispatcherResourceManagerComponentFactory<?>	createDispatcherResourceManagerComponentFactory(Configuration configuration)
protected void	initializeServices(Configuration config)
static void	main(String[] args)
protected CompletableFuture<Void>	stopClusterServices(boolean cleanupHaData)

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

createSerializableExecutionGraphStore

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

closeAsync, createHaServices, createHeartbeatServices, createMetricRegistry, getRPCPortRange, getTerminationFuture, installSecurityContext, loadConfiguration, onFatalError, parseArguments, runClusterEntrypoint, startCluster

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.flink.util.AutoCloseableAsync

close

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

stopClusterServices

protected CompletableFuture<Void> stopClusterServices(boolean cleanupHaData)

Overrides:

stopClusterServices in class ClusterEntrypoint

createDispatcherResourceManagerComponentFactory

protected DispatcherResourceManagerComponentFactory<?> createDispatcherResourceManagerComponentFactory(Configuration configuration)

Specified by:

createDispatcherResourceManagerComponentFactory in class ClusterEntrypoint

main

public static void main(String[] args)