org.apache.flink.mesos.entrypoint

Class MesosEntrypointUtils

java.lang.Object

org.apache.flink.mesos.entrypoint.MesosEntrypointUtils

public class MesosEntrypointUtils
extends Object

Utils for Mesos entrpoints.

Constructor Summary

Constructors

Constructor and Description
MesosEntrypointUtils()

Method Summary

Modifier and Type	Method and Description
static void	applyOverlays(Configuration configuration, ContainerSpecification containerSpec) Generate a container specification as a TaskManager template.
static ContainerSpecification	createContainerSpec(Configuration configuration, Configuration dynamicProperties)
static MesosConfiguration	createMesosSchedulerConfiguration(Configuration flinkConfig, String hostname) Loads and validates the Mesos scheduler configuration.
static MesosTaskManagerParameters	createTmParameters(Configuration configuration, org.slf4j.Logger log)

Methods inherited from class java.lang.Object

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

Constructor Detail

MesosEntrypointUtils

public MesosEntrypointUtils()

Method Detail

createMesosSchedulerConfiguration

public static MesosConfiguration createMesosSchedulerConfiguration(Configuration flinkConfig,
                                                                   String hostname)

Loads and validates the Mesos scheduler configuration.

Parameters:

flinkConfig - the global configuration.

hostname - the hostname to advertise to the Mesos master.

createTmParameters

public static MesosTaskManagerParameters createTmParameters(Configuration configuration,
                                                            org.slf4j.Logger log)

createContainerSpec

public static ContainerSpecification createContainerSpec(Configuration configuration,
                                                         Configuration dynamicProperties)
                                                  throws Exception

Throws:

Exception

applyOverlays

public static void applyOverlays(Configuration configuration,
                                 ContainerSpecification containerSpec)
                          throws IOException

Generate a container specification as a TaskManager template.

This code is extremely Mesos-specific and registers all the artifacts that the TaskManager needs (such as JAR file, config file, ...) and all environment variables into a container specification. The Mesos fetcher then ensures that those artifacts will be copied into the task's sandbox directory. A lightweight HTTP server serves the artifacts to the fetcher.

Throws:

IOException