Package org.apache.flink.configuration

Class AkkaOptions

  • @PublicEvolving
public class AkkaOptions
extends Object
    Akka configuration options.

    • 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.

      • 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.

      • 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

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