org.apache.flink.mesos.entrypoint

Class MesosEntrypointUtils

java.lang.Object

org.apache.flink.mesos.entrypoint.MesosEntrypointUtils

public class MesosEntrypointUtils
extends Object

Utils for Mesos entry points.

Constructor Summary

Constructors

Constructor and Description
MesosEntrypointUtils()

Method Summary

Modifier and Type	Method and Description
static void	applyOverlays(org.apache.flink.configuration.Configuration configuration, org.apache.flink.runtime.clusterframework.ContainerSpecification containerSpec) Generate a container specification as a TaskManager template.
static org.apache.flink.runtime.clusterframework.ContainerSpecification	createContainerSpec(org.apache.flink.configuration.Configuration configuration, org.apache.flink.configuration.Configuration dynamicProperties)
static MesosConfiguration	createMesosSchedulerConfiguration(org.apache.flink.configuration.Configuration flinkConfig, String hostname) Loads and validates the Mesos scheduler configuration.
static MesosTaskManagerParameters	createTmParameters(org.apache.flink.configuration.Configuration configuration, org.slf4j.Logger log)
static org.apache.flink.configuration.Configuration	loadConfiguration(org.apache.flink.configuration.Configuration dynamicProperties, org.slf4j.Logger log) Loads the global configuration, adds the given dynamic properties configuration, and sets the temp directory paths.

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(org.apache.flink.configuration.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(org.apache.flink.configuration.Configuration configuration,
                                                            org.slf4j.Logger log)

createContainerSpec

public static org.apache.flink.runtime.clusterframework.ContainerSpecification createContainerSpec(org.apache.flink.configuration.Configuration configuration,
                                                                                                   org.apache.flink.configuration.Configuration dynamicProperties)
                                                                                            throws Exception

Throws:

Exception

applyOverlays

public static void applyOverlays(org.apache.flink.configuration.Configuration configuration,
                                 org.apache.flink.runtime.clusterframework.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

loadConfiguration

public static org.apache.flink.configuration.Configuration loadConfiguration(org.apache.flink.configuration.Configuration dynamicProperties,
                                                                             org.slf4j.Logger log)

Loads the global configuration, adds the given dynamic properties configuration, and sets the temp directory paths.

Parameters:

dynamicProperties - dynamic properties to integrate

log - logger instance

Returns:

the loaded and adapted global configuration