org.apache.flink.mesos.entrypoint

Class MesosSessionClusterEntrypoint

java.lang.Object

org.apache.flink.runtime.entrypoint.ClusterEntrypoint

org.apache.flink.runtime.entrypoint.SessionClusterEntrypoint

org.apache.flink.mesos.entrypoint.MesosSessionClusterEntrypoint

All Implemented Interfaces:

AutoCloseable, FatalErrorHandler, AutoCloseableAsync

Deprecated.

Apache Mesos support was deprecated in Flink 1.13 and is subject to removal in the future (see FLINK-22352 for further details).

@Deprecated
public class MesosSessionClusterEntrypoint
extends SessionClusterEntrypoint

Entry point for Mesos session 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

INTERNAL_CLUSTER_EXECUTION_MODE, LOG, RUNTIME_FAILURE_RETURN_CODE, STARTUP_FAILURE_RETURN_CODE

Constructor Summary

Constructors

Constructor and Description
MesosSessionClusterEntrypoint(Configuration config) Deprecated.

Method Summary

Modifier and Type	Method and Description
protected DefaultDispatcherResourceManagerComponentFactory	createDispatcherResourceManagerComponentFactory(Configuration configuration) Deprecated.
protected void	initializeServices(Configuration config, PluginManager pluginManager) Deprecated.
static void	main(String[] args) Deprecated.
protected CompletableFuture<Void>	stopClusterServices(boolean cleanupHaData) Deprecated.

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

createSerializableExecutionGraphStore

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

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

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

MesosSessionClusterEntrypoint

public MesosSessionClusterEntrypoint(Configuration config)

Deprecated.

Method Detail

initializeServices

protected void initializeServices(Configuration config,
                                  PluginManager pluginManager)
                           throws Exception

Deprecated.

Overrides:

initializeServices in class ClusterEntrypoint

Throws:

Exception

stopClusterServices

protected CompletableFuture<Void> stopClusterServices(boolean cleanupHaData)

Deprecated.

Overrides:

stopClusterServices in class ClusterEntrypoint

createDispatcherResourceManagerComponentFactory

protected DefaultDispatcherResourceManagerComponentFactory createDispatcherResourceManagerComponentFactory(Configuration configuration)

Deprecated.

Specified by:

createDispatcherResourceManagerComponentFactory in class ClusterEntrypoint

main

public static void main(String[] args)

Deprecated.