org.apache.flink.runtime.util

Class StandaloneUtils

java.lang.Object

org.apache.flink.runtime.util.StandaloneUtils

public final class StandaloneUtils
extends Object

Utility class to work with Flink standalone mode.

Method Summary

Modifier and Type	Method and Description
static StandaloneLeaderRetrievalService	createLeaderRetrievalService(Configuration configuration) Creates a StandaloneLeaderRetrievalService from the given configuration.
static StandaloneLeaderRetrievalService	createLeaderRetrievalService(Configuration configuration, boolean resolveInitialHostName, String jobManagerName) Creates a StandaloneLeaderRetrievalService form the given configuration and the JobManager name.

Methods inherited from class java.lang.Object

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

Method Detail

createLeaderRetrievalService

public static StandaloneLeaderRetrievalService createLeaderRetrievalService(Configuration configuration)
                                                                     throws ConfigurationException,
                                                                            UnknownHostException

Creates a StandaloneLeaderRetrievalService from the given configuration. The host and port for the remote Akka URL are retrieved from the provided configuration.

Parameters:

configuration - Configuration instance containing the host and port information

Returns:

StandaloneLeaderRetrievalService

Throws:

ConfigurationException

UnknownHostException

createLeaderRetrievalService

public static StandaloneLeaderRetrievalService createLeaderRetrievalService(Configuration configuration,
                                                                            boolean resolveInitialHostName,
                                                                            String jobManagerName)
                                                                     throws ConfigurationException,
                                                                            UnknownHostException

Creates a StandaloneLeaderRetrievalService form the given configuration and the JobManager name. The host and port for the remote Akka URL are retrieved from the provided configuration. Instead of using the standard JobManager Akka name, the provided one is used for the remote Akka URL.

Parameters:

configuration - Configuration instance containing hte host and port information

resolveInitialHostName - If true, resolves the hostname of the StandaloneLeaderRetrievalService

jobManagerName - Name of the JobManager actor

Returns:

StandaloneLeaderRetrievalService

Throws:

ConfigurationException - if the job manager address cannot be retrieved from the configuration

UnknownHostException - if the job manager address cannot be resolved