org.apache.flink.streaming.configuration

Class TimerServiceOptions

java.lang.Object

org.apache.flink.streaming.configuration.TimerServiceOptions

@PublicEvolving
public class TimerServiceOptions
extends Object

Timer service configuration options.

Field Summary

Fields

Modifier and Type	Field and Description
static ConfigOption<Long>	TIMER_SERVICE_TERMINATION_AWAIT_MS This configures how long we wait for the ProcessingTimeService to finish all pending timer threads when the stream task performs a failover shutdown.

Constructor Summary

Constructors

Constructor and Description
TimerServiceOptions()

Method Summary

Methods inherited from class java.lang.Object

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

Field Detail

TIMER_SERVICE_TERMINATION_AWAIT_MS

public static final ConfigOption<Long> TIMER_SERVICE_TERMINATION_AWAIT_MS

This configures how long we wait for the ProcessingTimeService to finish all pending timer threads when the stream task performs a failover shutdown. See FLINK-5465.

Constructor Detail

TimerServiceOptions

public TimerServiceOptions()