public class TaskManagerConfiguration extends Object implements TaskManagerRuntimeInfo
TaskExecutor
.Constructor and Description |
---|
TaskManagerConfiguration(int numberSlots,
ResourceProfile defaultSlotResourceProfile,
ResourceProfile totalResourceProfile,
String[] tmpDirectories,
java.time.Duration rpcTimeout,
java.time.Duration slotTimeout,
java.time.Duration maxRegistrationDuration,
Configuration configuration,
boolean exitJvmOnOutOfMemory,
String taskManagerLogPath,
String taskManagerStdoutPath,
String taskManagerLogDir,
String taskManagerExternalAddress,
File tmpWorkingDirectory,
RetryingRegistrationConfiguration retryingRegistrationConfiguration) |
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() |
java.time.Duration |
getMaxRegistrationDuration() |
int |
getNumberSlots() |
RetryingRegistrationConfiguration |
getRetryingRegistrationConfiguration() |
java.time.Duration |
getRpcTimeout() |
java.time.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.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getTaskManagerBindAddress
public TaskManagerConfiguration(int numberSlots, ResourceProfile defaultSlotResourceProfile, ResourceProfile totalResourceProfile, String[] tmpDirectories, java.time.Duration rpcTimeout, java.time.Duration slotTimeout, @Nullable java.time.Duration maxRegistrationDuration, Configuration configuration, boolean exitJvmOnOutOfMemory, @Nullable String taskManagerLogPath, @Nullable String taskManagerStdoutPath, @Nullable String taskManagerLogDir, String taskManagerExternalAddress, File tmpWorkingDirectory, RetryingRegistrationConfiguration retryingRegistrationConfiguration)
public int getNumberSlots()
public ResourceProfile getDefaultSlotResourceProfile()
public ResourceProfile getTotalResourceProfile()
public java.time.Duration getRpcTimeout()
public java.time.Duration getSlotTimeout()
@Nullable public java.time.Duration getMaxRegistrationDuration()
public Configuration getConfiguration()
TaskManagerRuntimeInfo
getConfiguration
in interface TaskManagerRuntimeInfo
public String[] getTmpDirectories()
TaskManagerRuntimeInfo
getTmpDirectories
in interface TaskManagerRuntimeInfo
public boolean shouldExitJvmOnOutOfMemoryError()
TaskManagerRuntimeInfo
shouldExitJvmOnOutOfMemoryError
in interface TaskManagerRuntimeInfo
public String getTaskManagerExternalAddress()
TaskManagerRuntimeInfo
getTaskManagerExternalAddress
in interface TaskManagerRuntimeInfo
public File getTmpWorkingDirectory()
TaskManagerRuntimeInfo
getTmpWorkingDirectory
in interface TaskManagerRuntimeInfo
public RetryingRegistrationConfiguration getRetryingRegistrationConfiguration()
public static TaskManagerConfiguration fromConfiguration(Configuration configuration, TaskExecutorResourceSpec taskExecutorResourceSpec, String externalAddress, File tmpWorkingDirectory)
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.