org.apache.flink.runtime.taskexecutor

Class TaskManagerRunner

java.lang.Object

org.apache.flink.runtime.taskexecutor.TaskManagerRunner

All Implemented Interfaces:

AutoCloseable, FatalErrorHandler, AutoCloseableAsync

public class TaskManagerRunner
extends Object
implements FatalErrorHandler, AutoCloseableAsync

This class is the executable entry point for the task manager in yarn or standalone mode. It constructs the related components (network, I/O manager, memory manager, RPC service, HA service) and starts them.

Constructor Summary

Constructors

Constructor and Description
TaskManagerRunner(Configuration configuration, ResourceID resourceId)

Method Summary

Modifier and Type	Method and Description
CompletableFuture<Void>	closeAsync() Trigger the closing of the resource and return the corresponding close future.
static RpcService	createRpcService(Configuration configuration, HighAvailabilityServices haServices) Create a RPC service for the task manager.
CompletableFuture<Void>	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	start()
static TaskExecutor	startTaskManager(Configuration configuration, ResourceID resourceID, RpcService rpcService, HighAvailabilityServices highAvailabilityServices, HeartbeatServices heartbeatServices, MetricRegistry metricRegistry, BlobCacheService blobCacheService, boolean localCommunicationOnly, FatalErrorHandler fatalErrorHandler)
protected void	terminateJVM()

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.flink.util.AutoCloseableAsync

close

Constructor Detail

TaskManagerRunner

public TaskManagerRunner(Configuration configuration,
                         ResourceID resourceId)
                  throws Exception

Throws:

Exception

Method Detail

start

public void start()
           throws Exception

Throws:

Exception

closeAsync

public CompletableFuture<Void> closeAsync()

Description copied from interface: AutoCloseableAsync

Trigger the closing of the resource and return the corresponding close future.

Specified by:

closeAsync in interface AutoCloseableAsync

Returns:

Future which is completed once the resource has been closed

getTerminationFuture

public CompletableFuture<Void> getTerminationFuture()

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

terminateJVM

protected void terminateJVM()

main

public static void main(String[] args)
                 throws Exception

Throws:

Exception

runTaskManager

public static void runTaskManager(Configuration configuration,
                                  ResourceID resourceId)
                           throws Exception

Throws:

Exception

startTaskManager

public static TaskExecutor startTaskManager(Configuration configuration,
                                            ResourceID resourceID,
                                            RpcService rpcService,
                                            HighAvailabilityServices highAvailabilityServices,
                                            HeartbeatServices heartbeatServices,
                                            MetricRegistry metricRegistry,
                                            BlobCacheService blobCacheService,
                                            boolean localCommunicationOnly,
                                            FatalErrorHandler fatalErrorHandler)
                                     throws Exception

Throws:

Exception

createRpcService

public static RpcService createRpcService(Configuration configuration,
                                          HighAvailabilityServices haServices)
                                   throws Exception

Create a RPC service for the task manager.

Parameters:

configuration - The configuration for the TaskManager.

haServices - to use for the task manager hostname retrieval

Throws:

Exception