public class TaskManagerRunner extends Object implements FatalErrorHandler
Constructor and Description |
---|
TaskManagerRunner(Configuration configuration,
ResourceID resourceID,
RpcService rpcService,
HighAvailabilityServices highAvailabilityServices,
HeartbeatServices heartbeatServices,
MetricRegistry metricRegistry) |
TaskManagerRunner(Configuration configuration,
ResourceID resourceID,
RpcService rpcService,
HighAvailabilityServices highAvailabilityServices,
HeartbeatServices heartbeatServices,
MetricRegistry metricRegistry,
boolean localCommunicationOnly) |
Modifier and Type | Method and Description |
---|---|
static RpcService |
createRpcService(Configuration configuration,
HighAvailabilityServices haServices)
Create a RPC service for the task manager.
|
Future<Void> |
getTerminationFuture() |
void |
onFatalError(Throwable exception) |
void |
shutDown(Throwable cause) |
protected void |
shutDownInternally() |
void |
start() |
public TaskManagerRunner(Configuration configuration, ResourceID resourceID, RpcService rpcService, HighAvailabilityServices highAvailabilityServices, HeartbeatServices heartbeatServices, MetricRegistry metricRegistry) throws Exception
Exception
public TaskManagerRunner(Configuration configuration, ResourceID resourceID, RpcService rpcService, HighAvailabilityServices highAvailabilityServices, HeartbeatServices heartbeatServices, MetricRegistry metricRegistry, boolean localCommunicationOnly) throws Exception
Exception
public void shutDown(Throwable cause)
protected void shutDownInternally()
public void onFatalError(Throwable exception)
onFatalError
in interface FatalErrorHandler
public static RpcService createRpcService(Configuration configuration, HighAvailabilityServices haServices) throws Exception
configuration
- The configuration for the TaskManager.haServices
- to use for the task manager hostname retrievalException
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.