public class TaskManagerConfiguration extends Object implements TaskManagerRuntimeInfo
TaskExecutor
.Constructor and Description |
---|
TaskManagerConfiguration(int numberSlots,
ResourceProfile defaultSlotResourceProfile,
ResourceProfile totalResourceProfile,
String[] tmpDirectories,
Time timeout,
Time maxRegistrationDuration,
Time initialRegistrationPause,
Time maxRegistrationPause,
Time refusedRegistrationPause,
Configuration configuration,
boolean exitJvmOnOutOfMemory,
FlinkUserCodeClassLoaders.ResolveOrder classLoaderResolveOrder,
String[] alwaysParentFirstLoaderPatterns,
String taskManagerLogPath,
String taskManagerStdoutPath,
RetryingRegistrationConfiguration retryingRegistrationConfiguration) |
public TaskManagerConfiguration(int numberSlots, ResourceProfile defaultSlotResourceProfile, ResourceProfile totalResourceProfile, String[] tmpDirectories, Time timeout, @Nullable Time maxRegistrationDuration, Time initialRegistrationPause, Time maxRegistrationPause, Time refusedRegistrationPause, Configuration configuration, boolean exitJvmOnOutOfMemory, FlinkUserCodeClassLoaders.ResolveOrder classLoaderResolveOrder, String[] alwaysParentFirstLoaderPatterns, @Nullable String taskManagerLogPath, @Nullable String taskManagerStdoutPath, RetryingRegistrationConfiguration retryingRegistrationConfiguration)
public int getNumberSlots()
public ResourceProfile getDefaultSlotResourceProfile()
public ResourceProfile getTotalResourceProfile()
public Time getTimeout()
public Time getInitialRegistrationPause()
public Time getRefusedRegistrationPause()
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 FlinkUserCodeClassLoaders.ResolveOrder getClassLoaderResolveOrder()
public String[] getAlwaysParentFirstLoaderPatterns()
public RetryingRegistrationConfiguration getRetryingRegistrationConfiguration()
public static TaskManagerConfiguration fromConfiguration(Configuration configuration, TaskExecutorResourceSpec taskExecutorResourceSpec)
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.