org.apache.flink.runtime.taskexecutor

Class TaskManagerConfiguration

java.lang.Object

org.apache.flink.runtime.taskexecutor.TaskManagerConfiguration

All Implemented Interfaces:

TaskManagerRuntimeInfo

public class TaskManagerConfiguration
extends Object
implements TaskManagerRuntimeInfo

Configuration object for TaskExecutor.

Constructor Summary

Constructors

Constructor and Description

TaskManagerConfiguration(int numberSlots, ResourceProfile defaultSlotResourceProfile, ResourceProfile totalResourceProfile, String[] tmpDirectories, Duration rpcTimeout, Duration slotTimeout, Duration maxRegistrationDuration, Configuration configuration, boolean exitJvmOnOutOfMemory, String taskManagerLogPath, String taskManagerStdoutPath, String taskManagerLogDir, String taskManagerExternalAddress, File tmpWorkingDirectory, RetryingRegistrationConfiguration retryingRegistrationConfiguration)

Method Summary

Modifier and Type	Method and Description
static TaskManagerConfiguration	fromConfiguration(Configuration configuration, TaskExecutorResourceSpec taskExecutorResourceSpec, String externalAddress, File tmpWorkingDirectory)
Configuration	getConfiguration() Gets the configuration that the TaskManager was started with.
ResourceProfile	getDefaultSlotResourceProfile()
Duration	getMaxRegistrationDuration()
int	getNumberSlots()
RetryingRegistrationConfiguration	getRetryingRegistrationConfiguration()
Duration	getRpcTimeout()
Duration	getSlotTimeout()
String	getTaskManagerExternalAddress() Gets the external address of the TaskManager.
String	getTaskManagerLogDir()
String	getTaskManagerLogPath()
String	getTaskManagerStdoutPath()
String[]	getTmpDirectories() Gets the list of temporary file directories.
File	getTmpWorkingDirectory() Gets the temporary working directory of the TaskManager instance.
ResourceProfile	getTotalResourceProfile()
boolean	shouldExitJvmOnOutOfMemoryError() Checks whether the TaskManager should exit the JVM when the task thread throws an OutOfMemoryError.

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.runtime.taskmanager.TaskManagerRuntimeInfo

getTaskManagerBindAddress

Constructor Detail

TaskManagerConfiguration

public TaskManagerConfiguration(int numberSlots,
                                ResourceProfile defaultSlotResourceProfile,
                                ResourceProfile totalResourceProfile,
                                String[] tmpDirectories,
                                Duration rpcTimeout,
                                Duration slotTimeout,
                                @Nullable
                                Duration maxRegistrationDuration,
                                Configuration configuration,
                                boolean exitJvmOnOutOfMemory,
                                @Nullable
                                String taskManagerLogPath,
                                @Nullable
                                String taskManagerStdoutPath,
                                @Nullable
                                String taskManagerLogDir,
                                String taskManagerExternalAddress,
                                File tmpWorkingDirectory,
                                RetryingRegistrationConfiguration retryingRegistrationConfiguration)

Method Detail

getNumberSlots

public int getNumberSlots()

getDefaultSlotResourceProfile

public ResourceProfile getDefaultSlotResourceProfile()

getTotalResourceProfile

public ResourceProfile getTotalResourceProfile()

getRpcTimeout

public Duration getRpcTimeout()

getSlotTimeout

public Duration getSlotTimeout()

getMaxRegistrationDuration

@Nullable
public Duration getMaxRegistrationDuration()

getConfiguration

public Configuration getConfiguration()

Description copied from interface: TaskManagerRuntimeInfo

Gets the configuration that the TaskManager was started with.

Specified by:

getConfiguration in interface TaskManagerRuntimeInfo

Returns:

The configuration that the TaskManager was started with.

getTmpDirectories

public String[] getTmpDirectories()

Description copied from interface: TaskManagerRuntimeInfo

Gets the list of temporary file directories.

Specified by:

getTmpDirectories in interface TaskManagerRuntimeInfo

Returns:

The list of temporary file directories.

shouldExitJvmOnOutOfMemoryError

public boolean shouldExitJvmOnOutOfMemoryError()

Description copied from interface: TaskManagerRuntimeInfo

Checks whether the TaskManager should exit the JVM when the task thread throws an OutOfMemoryError.

Specified by:

shouldExitJvmOnOutOfMemoryError in interface TaskManagerRuntimeInfo

Returns:

True to terminate the JVM on an OutOfMemoryError, false otherwise.

getTaskManagerLogPath

@Nullable
public String getTaskManagerLogPath()

getTaskManagerStdoutPath

@Nullable
public String getTaskManagerStdoutPath()

getTaskManagerLogDir

@Nullable
public String getTaskManagerLogDir()

getTaskManagerExternalAddress

public String getTaskManagerExternalAddress()

Description copied from interface: TaskManagerRuntimeInfo

Gets the external address of the TaskManager.

Specified by:

getTaskManagerExternalAddress in interface TaskManagerRuntimeInfo

Returns:

The external address of the TaskManager.

getTmpWorkingDirectory

public File getTmpWorkingDirectory()

Description copied from interface: TaskManagerRuntimeInfo

Gets the temporary working directory of the TaskManager instance.

Specified by:

getTmpWorkingDirectory in interface TaskManagerRuntimeInfo

Returns:

The temporary working directory of the TaskManager.

getRetryingRegistrationConfiguration

public RetryingRegistrationConfiguration getRetryingRegistrationConfiguration()

fromConfiguration

public static TaskManagerConfiguration fromConfiguration(Configuration configuration,
                                                         TaskExecutorResourceSpec taskExecutorResourceSpec,
                                                         String externalAddress,
                                                         File tmpWorkingDirectory)