public class TaskManagerRunner extends Object implements FatalErrorHandler
Constructor and Description |
---|
TaskManagerRunner(Configuration configuration,
ResourceID resourceId) |
Modifier and Type | Method and Description |
---|---|
static RpcService |
createRpcService(Configuration configuration,
HighAvailabilityServices haServices)
Create a RPC service for the task manager.
|
CompletableFuture<Boolean> |
getTerminationFuture() |
static void |
main(String[] args) |
void |
onFatalError(Throwable exception)
Being called when a fatal error occurs.
|
static void |
runTaskManager(Configuration configuration,
ResourceID resourceId) |
void |
shutDown() |
protected void |
shutDownInternally() |
void |
start() |
static TaskExecutor |
startTaskManager(Configuration configuration,
ResourceID resourceID,
RpcService rpcService,
HighAvailabilityServices highAvailabilityServices,
HeartbeatServices heartbeatServices,
MetricRegistry metricRegistry,
boolean localCommunicationOnly,
FatalErrorHandler fatalErrorHandler) |
public TaskManagerRunner(Configuration configuration, ResourceID resourceId) throws Exception
Exception
public CompletableFuture<Boolean> getTerminationFuture()
public void onFatalError(Throwable exception)
FatalErrorHandler
IMPORTANT: This call should never be blocking since it might be called from within
the main thread of an RpcEndpoint
.
onFatalError
in interface FatalErrorHandler
exception
- causepublic static void runTaskManager(Configuration configuration, ResourceID resourceId) throws Exception
Exception
public static TaskExecutor startTaskManager(Configuration configuration, ResourceID resourceID, RpcService rpcService, HighAvailabilityServices highAvailabilityServices, HeartbeatServices heartbeatServices, MetricRegistry metricRegistry, boolean localCommunicationOnly, FatalErrorHandler fatalErrorHandler) throws Exception
Exception
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.