热门标签
当前位置: 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
声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/我家自动化/article/detail/876338
推荐阅读
相关标签
