@PublicEvolving public class ClusterOptions extends Object
Modifier and Type | Class and Description |
---|---|
static class |
ClusterOptions.UncaughtExceptionHandleMode |
static class |
ClusterOptions.UserSystemExitMode
The mode of how to handle user code attempting to exit JVM.
|
Constructor and Description |
---|
ClusterOptions() |
Modifier and Type | Method and Description |
---|---|
static JobManagerOptions.SchedulerType |
getSchedulerType(Configuration configuration) |
static boolean |
isAdaptiveSchedulerEnabled(Configuration configuration) |
static boolean |
isReactiveModeEnabled(Configuration configuration) |
public static final ConfigOption<Long> INITIAL_REGISTRATION_TIMEOUT
public static final ConfigOption<Long> MAX_REGISTRATION_TIMEOUT
public static final ConfigOption<Long> ERROR_REGISTRATION_DELAY
public static final ConfigOption<Long> REFUSED_REGISTRATION_DELAY
public static final ConfigOption<Long> CLUSTER_SERVICES_SHUTDOWN_TIMEOUT
public static final ConfigOption<Integer> CLUSTER_IO_EXECUTOR_POOL_SIZE
public static final ConfigOption<Boolean> EVENLY_SPREAD_OUT_SLOTS_STRATEGY
public static final ConfigOption<Boolean> HALT_ON_FATAL_ERROR
public static final ConfigOption<ClusterOptions.UserSystemExitMode> INTERCEPT_USER_SYSTEM_EXIT
public static final ConfigOption<Integer> THREAD_DUMP_STACKTRACE_MAX_DEPTH
@Deprecated public static final ConfigOption<Boolean> ENABLE_FINE_GRAINED_RESOURCE_MANAGEMENT
public static final ConfigOption<Boolean> FINE_GRAINED_SHUFFLE_MODE_ALL_BLOCKING
public static final ConfigOption<ClusterOptions.UncaughtExceptionHandleMode> UNCAUGHT_EXCEPTION_HANDLING
public static final ConfigOption<String> PROCESS_WORKING_DIR_BASE
public static final ConfigOption<String> JOB_MANAGER_PROCESS_WORKING_DIR_BASE
public static final ConfigOption<String> TASK_MANAGER_PROCESS_WORKING_DIR_BASE
public static JobManagerOptions.SchedulerType getSchedulerType(Configuration configuration)
public static boolean isReactiveModeEnabled(Configuration configuration)
public static boolean isAdaptiveSchedulerEnabled(Configuration configuration)
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.