org.apache.flink.configuration

Class AkkaOptions

java.lang.Object

org.apache.flink.configuration.AkkaOptions

@PublicEvolving
public class AkkaOptions
extends Object

Akka configuration options.

Field Summary

Fields

Modifier and Type	Field and Description
static ConfigOption<String>	ASK_TIMEOUT Deprecated. Use ASK_TIMEOUT_DURATION
static ConfigOption<java.time.Duration>	ASK_TIMEOUT_DURATION Timeout for Pekko ask calls.
static ConfigOption<Boolean>	CAPTURE_ASK_CALLSTACK Flag whether to capture call stacks for RPC ask calls.
static ConfigOption<Double>	CLIENT_SOCKET_WORKER_POOL_SIZE_FACTOR
static ConfigOption<Integer>	CLIENT_SOCKET_WORKER_POOL_SIZE_MAX
static ConfigOption<Integer>	CLIENT_SOCKET_WORKER_POOL_SIZE_MIN
static ConfigOption<String>	CLIENT_TIMEOUT Deprecated. Use the ClientOptions.CLIENT_TIMEOUT instead.
static ConfigOption<Integer>	DISPATCHER_THROUGHPUT Maximum number of messages until another actor is executed by the same thread.
static ConfigOption<Boolean>	FORCE_RPC_INVOCATION_SERIALIZATION
static ConfigOption<Double>	FORK_JOIN_EXECUTOR_PARALLELISM_FACTOR
static ConfigOption<Integer>	FORK_JOIN_EXECUTOR_PARALLELISM_MAX
static ConfigOption<Integer>	FORK_JOIN_EXECUTOR_PARALLELISM_MIN
static ConfigOption<String>	FRAMESIZE Maximum framesize of Pekko messages.
static ConfigOption<Boolean>	JVM_EXIT_ON_FATAL_ERROR Exit JVM on fatal Pekko errors.
static ConfigOption<Boolean>	LOG_LIFECYCLE_EVENTS Log lifecycle events.
static ConfigOption<String>	LOOKUP_TIMEOUT Deprecated. use LOOKUP_TIMEOUT_DURATION
static ConfigOption<java.time.Duration>	LOOKUP_TIMEOUT_DURATION Timeout for all blocking calls that look up remote actors.
static ConfigOption<Double>	REMOTE_FORK_JOIN_EXECUTOR_PARALLELISM_FACTOR
static ConfigOption<Integer>	REMOTE_FORK_JOIN_EXECUTOR_PARALLELISM_MAX
static ConfigOption<Integer>	REMOTE_FORK_JOIN_EXECUTOR_PARALLELISM_MIN
static ConfigOption<Long>	RETRY_GATE_CLOSED_FOR Milliseconds a gate should be closed for after a remote connection was disconnected.
static ConfigOption<Double>	SERVER_SOCKET_WORKER_POOL_SIZE_FACTOR
static ConfigOption<Integer>	SERVER_SOCKET_WORKER_POOL_SIZE_MAX
static ConfigOption<Integer>	SERVER_SOCKET_WORKER_POOL_SIZE_MIN
static ConfigOption<Boolean>	SSL_ENABLED Override SSL support for the Pekko transport.
static ConfigOption<String>	STARTUP_TIMEOUT Timeout for the startup of the actor system.
static ConfigOption<String>	TCP_TIMEOUT The Pekko tcp connection timeout.
static ConfigOption<String>	WATCH_HEARTBEAT_INTERVAL Deprecated. Don't use this option anymore. It has no effect on Flink.
static ConfigOption<String>	WATCH_HEARTBEAT_PAUSE Deprecated. Don't use this option anymore. It has no effect on Flink.
static ConfigOption<Integer>	WATCH_THRESHOLD Deprecated. Don't use this option anymore. It has no effect on Flink.

Constructor Summary

Constructors

Constructor and Description
AkkaOptions()

Method Summary

Modifier and Type	Method and Description
static boolean	isForceRpcInvocationSerializationEnabled(Configuration config)

Methods inherited from class java.lang.Object

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

Field Detail

FORCE_RPC_INVOCATION_SERIALIZATION

@Internal
public static final ConfigOption<Boolean> FORCE_RPC_INVOCATION_SERIALIZATION

CAPTURE_ASK_CALLSTACK

public static final ConfigOption<Boolean> CAPTURE_ASK_CALLSTACK

Flag whether to capture call stacks for RPC ask calls.

ASK_TIMEOUT_DURATION

public static final ConfigOption<java.time.Duration> ASK_TIMEOUT_DURATION

Timeout for Pekko ask calls.

ASK_TIMEOUT

@Deprecated
public static final ConfigOption<String> ASK_TIMEOUT

Deprecated. Use ASK_TIMEOUT_DURATION

TCP_TIMEOUT

public static final ConfigOption<String> TCP_TIMEOUT

The Pekko tcp connection timeout.

STARTUP_TIMEOUT

public static final ConfigOption<String> STARTUP_TIMEOUT

Timeout for the startup of the actor system.

SSL_ENABLED

public static final ConfigOption<Boolean> SSL_ENABLED

Override SSL support for the Pekko transport.

FRAMESIZE

public static final ConfigOption<String> FRAMESIZE

Maximum framesize of Pekko messages.

DISPATCHER_THROUGHPUT

public static final ConfigOption<Integer> DISPATCHER_THROUGHPUT

Maximum number of messages until another actor is executed by the same thread.

LOG_LIFECYCLE_EVENTS

public static final ConfigOption<Boolean> LOG_LIFECYCLE_EVENTS

Log lifecycle events.

LOOKUP_TIMEOUT_DURATION

public static final ConfigOption<java.time.Duration> LOOKUP_TIMEOUT_DURATION

Timeout for all blocking calls that look up remote actors.

LOOKUP_TIMEOUT

@Deprecated
public static final ConfigOption<String> LOOKUP_TIMEOUT

Deprecated. use LOOKUP_TIMEOUT_DURATION

CLIENT_TIMEOUT

@Deprecated
public static final ConfigOption<String> CLIENT_TIMEOUT

Deprecated. Use the ClientOptions.CLIENT_TIMEOUT instead.

Timeout for all blocking calls on the client side.

JVM_EXIT_ON_FATAL_ERROR

public static final ConfigOption<Boolean> JVM_EXIT_ON_FATAL_ERROR

Exit JVM on fatal Pekko errors.

RETRY_GATE_CLOSED_FOR

public static final ConfigOption<Long> RETRY_GATE_CLOSED_FOR

Milliseconds a gate should be closed for after a remote connection was disconnected.

FORK_JOIN_EXECUTOR_PARALLELISM_FACTOR

public static final ConfigOption<Double> FORK_JOIN_EXECUTOR_PARALLELISM_FACTOR

FORK_JOIN_EXECUTOR_PARALLELISM_MIN

public static final ConfigOption<Integer> FORK_JOIN_EXECUTOR_PARALLELISM_MIN

FORK_JOIN_EXECUTOR_PARALLELISM_MAX

public static final ConfigOption<Integer> FORK_JOIN_EXECUTOR_PARALLELISM_MAX

REMOTE_FORK_JOIN_EXECUTOR_PARALLELISM_FACTOR

public static final ConfigOption<Double> REMOTE_FORK_JOIN_EXECUTOR_PARALLELISM_FACTOR

REMOTE_FORK_JOIN_EXECUTOR_PARALLELISM_MIN

public static final ConfigOption<Integer> REMOTE_FORK_JOIN_EXECUTOR_PARALLELISM_MIN

REMOTE_FORK_JOIN_EXECUTOR_PARALLELISM_MAX

public static final ConfigOption<Integer> REMOTE_FORK_JOIN_EXECUTOR_PARALLELISM_MAX

CLIENT_SOCKET_WORKER_POOL_SIZE_MIN

public static final ConfigOption<Integer> CLIENT_SOCKET_WORKER_POOL_SIZE_MIN

CLIENT_SOCKET_WORKER_POOL_SIZE_MAX

public static final ConfigOption<Integer> CLIENT_SOCKET_WORKER_POOL_SIZE_MAX

CLIENT_SOCKET_WORKER_POOL_SIZE_FACTOR

public static final ConfigOption<Double> CLIENT_SOCKET_WORKER_POOL_SIZE_FACTOR

SERVER_SOCKET_WORKER_POOL_SIZE_MIN

public static final ConfigOption<Integer> SERVER_SOCKET_WORKER_POOL_SIZE_MIN

SERVER_SOCKET_WORKER_POOL_SIZE_MAX

public static final ConfigOption<Integer> SERVER_SOCKET_WORKER_POOL_SIZE_MAX

SERVER_SOCKET_WORKER_POOL_SIZE_FACTOR

public static final ConfigOption<Double> SERVER_SOCKET_WORKER_POOL_SIZE_FACTOR

WATCH_HEARTBEAT_INTERVAL

@Deprecated
public static final ConfigOption<String> WATCH_HEARTBEAT_INTERVAL

Deprecated. Don't use this option anymore. It has no effect on Flink.

The Akka death watch heartbeat interval.

WATCH_HEARTBEAT_PAUSE

@Deprecated
public static final ConfigOption<String> WATCH_HEARTBEAT_PAUSE

Deprecated. Don't use this option anymore. It has no effect on Flink.

The maximum acceptable Akka death watch heartbeat pause.

WATCH_THRESHOLD

@Deprecated
public static final ConfigOption<Integer> WATCH_THRESHOLD

Deprecated. Don't use this option anymore. It has no effect on Flink.

Detection threshold for the phi accrual watch failure detector.

Constructor Detail

AkkaOptions

public AkkaOptions()

Method Detail

isForceRpcInvocationSerializationEnabled

public static boolean isForceRpcInvocationSerializationEnabled(Configuration config)