热门标签
热门文章
- 1Redis 高负载排查记录
- 2冒泡排序详解（C语言）_冒泡排序c语言
- 3LangChain系列使用指南：LangChain快速入门_llm.invoke
- 42024年最全最新golang语言面试题总结（三）_golang多态面试题，Golang社招面经分享_golang面试题2024
- 5testbench仿真赋值时，为符合真实情况，时序逻辑应延迟一拍_用vivado进行仿真时候,输出波形慢一个时钟周期
- 6bert模型蒸馏实战
- 7h5点击电话号跳转手机拨号_android h5页面跳转手机拨号
- 8【iOS 开发】父视图外部子视图点击响应 - hitTest
- 9Py之lightgbm：lightgbm的简介、安装、使用方法之详细攻略_win7 无法运行lightgbm lgbmclassifier
- 10【Android开发高手笔记】Dagger2和它在SystemUI上的应用_android contextcomponentresolver
当前位置: article > 正文
Flink Stream sql之checkpointing 设置方法_flink sql checkpoint
作者：我家自动化 | 2024-07-24 19:08:59
赞
踩
flink sql checkpoint
在flink Stream SQL模式下，一定要设置checkpoint ，否则数据就不会sink到相关表中，并且长时间运行可能报错。
设置checkpoint 有很多种方法。
- 在flink-conf.yaml，这种是全局设置
- 在sql-client.sh通过set命令设置
- 在代码中设置
代码设置方法一：StreamExecutionEnvironment 中设置
final StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
env.setStreamTimeCharacteristic(TimeCharacteristic.EventTim- 1
推荐阅读
相关标签
