org.apache.flink.configuration

Class AkkaOptions

java.lang.Object

org.apache.flink.configuration.AkkaOptions

Deprecated.

Use RpcOptions instead.

@PublicEvolving
 @Deprecated
public class AkkaOptions
extends Object

RPC configuration options.

Field Summary

Fields

Modifier and Type	Field and Description
static ConfigOption<String>	ASK_TIMEOUT Deprecated. Use RpcOptions.ASK_TIMEOUT_DURATION
static ConfigOption<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<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<Duration>	STARTUP_TIMEOUT Deprecated. Timeout for the startup of the actor system.
static ConfigOption<Duration>	TCP_TIMEOUT Deprecated. 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() Deprecated.

Method Summary

Modifier and Type	Method and 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<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<Duration> TCP_TIMEOUT

Deprecated.

The Pekko tcp connection timeout.

STARTUP_TIMEOUT

public static final ConfigOption<Duration> 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<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.