开发者社区> 问答> 正文

flink sql 支持checkpoints吗?

游客izljdlkgbdwfc 2019-07-10 17:46:37 18755

使用flink sql进行实时计算(部署模式是on yarn)。想用到checkpoint,在flink-conf.yaml配置了:

state.backend: filesystem
state.checkpoints.dir: hdfs:///flink/flink-checkpoints
state.savepoints.dir: hdfs:///flink/flink-savepoints
state.checkpoints.num-retained: 10

现在有两个问题:
1.checkpoint在hdfs只在初始的时候生成了一个文件夹
2.使用savepoint无法记录数据状态:
如:简单的wordcount无法记录累加值。

想请问大神sqlclient的checkpoints是不是没有像代码那些完全开放。如果想实现这个功能是不是要进行二次开发。感谢

SQL 资源调度 流计算
分享到
取消 提交回答
全部回答(3)
添加回答
+ 订阅

分享数据库前沿,解构实战干货,推动数据库技术变革

推荐文章
相似问题
推荐课程