com.zto.fire.flink.anno

注释类型 Checkpoint

@Inherited
 @Target(value=TYPE)
 @Retention(value=RUNTIME)
public @interface Checkpoint

基于注解flink checkpoint配置，优先级低于配置文件，高于@Config注解 注：@Checkpoint中相关时间单位均为秒

从以下版本开始:

2.2.2

作者:

ChengLong 2022-04-26 11:16:00

可选元素概要

可选元素

限定符和类型	可选元素和说明
org.apache.flink.streaming.api.environment.CheckpointConfig.ExternalizedCheckpointCleanup	cleanup 当任务停止时checkpoint的保持策略
int	concurrent checkpoint的并发度
int	failureNumber 运行checkpoint失败的总次数
int	interval checkpoint周期（s），同value
org.apache.flink.streaming.api.CheckpointingMode	mode checkpoint的模式
int	pauseBetween 两次checkpoint的最短时间间隔
int	timeout checkpoint超时时间（s）
boolean	unaligned 是否开启非对齐的checkpoint
int	value checkpoint周期（s）

元素详细资料

value

public abstract int value

checkpoint周期（s）

默认值:

-1

interval

public abstract int interval

checkpoint周期（s），同value

默认值:

-1

timeout

public abstract int timeout

checkpoint超时时间（s）

默认值:

-1

unaligned

public abstract boolean unaligned

是否开启非对齐的checkpoint

默认值:

true

concurrent

public abstract int concurrent

checkpoint的并发度

默认值:

-1

pauseBetween

public abstract int pauseBetween

两次checkpoint的最短时间间隔

默认值:

-1

failureNumber

public abstract int failureNumber

运行checkpoint失败的总次数

默认值:

-1

mode

public abstract org.apache.flink.streaming.api.CheckpointingMode mode

checkpoint的模式

默认值:

org.apache.flink.streaming.api.CheckpointingMode.EXACTLY_ONCE

cleanup

public abstract org.apache.flink.streaming.api.environment.CheckpointConfig.ExternalizedCheckpointCleanup cleanup

当任务停止时checkpoint的保持策略

默认值:

org.apache.flink.streaming.api.environment.CheckpointConfig.ExternalizedCheckpointCleanup.RETAIN_ON_CANCELLATION