Package org.apache.flink.configuration

Class AkkaOptions

java.lang.Object

org.apache.flink.configuration.AkkaOptions

@PublicEvolving
@Deprecated
public class AkkaOptions
extends Object

Deprecated.

Use RpcOptions instead.

RPC configuration options.

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor	Description
AkkaOptions()	Deprecated.

Method Summary

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

Methods inherited from class java.lang.Object

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

Field Detail

CAPTURE_ASK_CALLSTACK

public static final ConfigOption<Boolean> CAPTURE_ASK_CALLSTACK

Deprecated.

Flag whether to capture call stacks for RPC ask calls.

ASK_TIMEOUT_DURATION

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

Deprecated.

Timeout for Pekko ask calls.

ASK_TIMEOUT

@Deprecated
public static final ConfigOption<String> ASK_TIMEOUT

Deprecated.

Use RpcOptions.ASK_TIMEOUT_DURATION

TCP_TIMEOUT

public static final ConfigOption<String> TCP_TIMEOUT

Deprecated.

The Pekko tcp connection timeout.

STARTUP_TIMEOUT

public static final ConfigOption<String> STARTUP_TIMEOUT

Deprecated.

Timeout for the startup of the actor system.

SSL_ENABLED

public static final ConfigOption<Boolean> SSL_ENABLED

Deprecated.

Override SSL support for the Pekko transport.

FRAMESIZE

public static final ConfigOption<String> FRAMESIZE

Deprecated.

Maximum framesize of Pekko messages.

DISPATCHER_THROUGHPUT

public static final ConfigOption<Integer> DISPATCHER_THROUGHPUT

Deprecated.

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

LOG_LIFECYCLE_EVENTS

public static final ConfigOption<Boolean> LOG_LIFECYCLE_EVENTS

Deprecated.

Log lifecycle events.

LOOKUP_TIMEOUT_DURATION

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

Deprecated.

Timeout for all blocking calls that look up remote actors.

LOOKUP_TIMEOUT

@Deprecated
public static final ConfigOption<String> LOOKUP_TIMEOUT

Deprecated.

use RpcOptions.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

Deprecated.

Exit JVM on fatal Pekko errors.

RETRY_GATE_CLOSED_FOR

public static final ConfigOption<Long> RETRY_GATE_CLOSED_FOR

Deprecated.

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

Deprecated.

FORK_JOIN_EXECUTOR_PARALLELISM_MIN

public static final ConfigOption<Integer> FORK_JOIN_EXECUTOR_PARALLELISM_MIN

Deprecated.

FORK_JOIN_EXECUTOR_PARALLELISM_MAX

public static final ConfigOption<Integer> FORK_JOIN_EXECUTOR_PARALLELISM_MAX

Deprecated.

REMOTE_FORK_JOIN_EXECUTOR_PARALLELISM_FACTOR

public static final ConfigOption<Double> REMOTE_FORK_JOIN_EXECUTOR_PARALLELISM_FACTOR

Deprecated.

REMOTE_FORK_JOIN_EXECUTOR_PARALLELISM_MIN

public static final ConfigOption<Integer> REMOTE_FORK_JOIN_EXECUTOR_PARALLELISM_MIN

Deprecated.

REMOTE_FORK_JOIN_EXECUTOR_PARALLELISM_MAX

public static final ConfigOption<Integer> REMOTE_FORK_JOIN_EXECUTOR_PARALLELISM_MAX

Deprecated.

CLIENT_SOCKET_WORKER_POOL_SIZE_MIN

public static final ConfigOption<Integer> CLIENT_SOCKET_WORKER_POOL_SIZE_MIN

Deprecated.

CLIENT_SOCKET_WORKER_POOL_SIZE_MAX

public static final ConfigOption<Integer> CLIENT_SOCKET_WORKER_POOL_SIZE_MAX

Deprecated.

CLIENT_SOCKET_WORKER_POOL_SIZE_FACTOR

public static final ConfigOption<Double> CLIENT_SOCKET_WORKER_POOL_SIZE_FACTOR

Deprecated.

SERVER_SOCKET_WORKER_POOL_SIZE_MIN

public static final ConfigOption<Integer> SERVER_SOCKET_WORKER_POOL_SIZE_MIN

Deprecated.

SERVER_SOCKET_WORKER_POOL_SIZE_MAX

public static final ConfigOption<Integer> SERVER_SOCKET_WORKER_POOL_SIZE_MAX

Deprecated.

SERVER_SOCKET_WORKER_POOL_SIZE_FACTOR

public static final ConfigOption<Double> SERVER_SOCKET_WORKER_POOL_SIZE_FACTOR

Deprecated.

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()

Deprecated.

Method Detail

isForceRpcInvocationSerializationEnabled

public static boolean isForceRpcInvocationSerializationEnabled(Configuration config)

Deprecated.