Blog of YHR

Ch14_FaultTorlance

4/8/2021 FlinkJavaBigData

# Fault Torlance

image-20220528201655550

image-20220528201704106

image-20220528201716943

image-20220528201732880

image-20220528201742555

image-20220528201757247

image-20220528201805417

image-20220528201821143

可以设置检查点，第一个参数为多久保存一次检查点，第二个参数为检查点的模式，一般为exactly-once【状态一致性的级别】

env.enableCheckpointing(5000, CheckpointingMode.AT_LEAST_ONCE);//每个5秒执行一次
1

image-20220528201854176

Last Updated: 11/19/2024, 1:54:38 PM