org.apache.flink.configuration

Class HeartbeatManagerOptions

java.lang.Object

org.apache.flink.configuration.HeartbeatManagerOptions

@PublicEvolving
public class HeartbeatManagerOptions
extends Object

The set of configuration options relating to heartbeat manager settings.

Field Summary

Fields

Modifier and Type	Field and Description
static int	FAILED_RPC_DETECTION_DISABLED
static ConfigOption<Duration>	HEARTBEAT_INTERVAL Time interval for requesting heartbeat from sender side.
static ConfigOption<Integer>	HEARTBEAT_RPC_FAILURE_THRESHOLD
static ConfigOption<Duration>	HEARTBEAT_TIMEOUT Timeout for requesting and receiving heartbeat for both sender and receiver sides.

Method Summary

Methods inherited from class java.lang.Object

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

Field Detail

HEARTBEAT_INTERVAL

public static final ConfigOption<Duration> HEARTBEAT_INTERVAL

Time interval for requesting heartbeat from sender side.

HEARTBEAT_TIMEOUT

public static final ConfigOption<Duration> HEARTBEAT_TIMEOUT

Timeout for requesting and receiving heartbeat for both sender and receiver sides.

FAILED_RPC_DETECTION_DISABLED

public static final int FAILED_RPC_DETECTION_DISABLED

See Also:

Constant Field Values

HEARTBEAT_RPC_FAILURE_THRESHOLD

public static final ConfigOption<Integer> HEARTBEAT_RPC_FAILURE_THRESHOLD