org.apache.flink.runtime.resourcemanager

Class ResourceManagerRunner

java.lang.Object

org.apache.flink.runtime.resourcemanager.ResourceManagerRunner

All Implemented Interfaces:

FatalErrorHandler

public class ResourceManagerRunner
extends Object
implements FatalErrorHandler

Simple StandaloneResourceManager runner. It instantiates the resource manager's services and handles fatal errors by shutting the resource manager down.

Constructor Summary

Constructors

Constructor and Description
ResourceManagerRunner(ResourceID resourceId, String resourceManagerEndpointId, Configuration configuration, RpcService rpcService, HighAvailabilityServices highAvailabilityServices, HeartbeatServices heartbeatServices, MetricRegistry metricRegistry)

Method Summary

Modifier and Type	Method and Description
void	onFatalError(Throwable exception) Being called when a fatal error occurs.
void	shutDown()
void	start()

Methods inherited from class java.lang.Object

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

Constructor Detail

ResourceManagerRunner

public ResourceManagerRunner(ResourceID resourceId,
                             String resourceManagerEndpointId,
                             Configuration configuration,
                             RpcService rpcService,
                             HighAvailabilityServices highAvailabilityServices,
                             HeartbeatServices heartbeatServices,
                             MetricRegistry metricRegistry)
                      throws Exception

Throws:

Exception

Method Detail

start

public void start()
           throws Exception

Throws:

Exception

shutDown

public void shutDown()
              throws Exception

Throws:

Exception

onFatalError

public void onFatalError(Throwable exception)

Description copied from interface: FatalErrorHandler

Being called when a fatal error occurs.

IMPORTANT: This call should never be blocking since it might be called from within the main thread of an RpcEndpoint.

Specified by:

onFatalError in interface FatalErrorHandler

Parameters:

exception - cause