flink sql 支持checkpoints吗?-问答-阿里云开发者社区-阿里云

开发者社区> 问答> 正文

flink sql 支持checkpoints吗?

2019-07-10 17:46:37 125632 8

使用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是不是没有像代码那些完全开放。如果想实现这个功能是不是要进行二次开发。感谢

取消 提交回答
全部回答(8)
滑动查看更多
相关问答

4

回答

请教一个范围查询的问题

小文文文 2019-06-14 14:37:01 116360浏览量 回答数 4

5

回答

Spark 【问答合集】

社区小助手 2019-05-29 14:13:40 129446浏览量 回答数 5

10

回答

【精品问答合集】Hbase热门问答

hbase小能手 2019-05-29 14:37:26 122999浏览量 回答数 10

1

回答

通过spark-thriftserver读取hive表执行sql时,tasks 数量怎么设置

游客iwhrjhvjoyqts 2019-07-05 15:30:22 114888浏览量 回答数 1

38

回答

[@饭娱咖啡][¥20]对于慢sql有没有什么比较实用的诊断和处理方法?

江小白太白 2018-10-30 18:47:38 143780浏览量 回答数 38

1

回答

在flink集群模式下,能不能指定某个节点的solt来执行一个task?

孙goku 2019-07-01 15:19:09 116610浏览量 回答数 1

2

回答

mySQL数据库报错You have an error in your SQL syntax

落地花开啦 2016-02-14 16:09:24 133102浏览量 回答数 2

10

回答

[@墨玖tao][¥20]为什么流式处理框架都是 java 写成的,JVM 是不是在流和批存在着特殊优势。还有分布式资源调度,感觉Mesos 的成长速度跟不上 Yarn。这是为什么?

管理贝贝 2018-10-23 13:18:03 137367浏览量 回答数 10

54

回答

Flink Forward Asia 2021 有奖问答

阿里云实时计算Flink 2021-12-29 17:30:44 466197浏览量 回答数 54

78

回答

【2013.9.5修正版图文】新手如何使用阿里云(linux)服务器建站(搬站)

姑苏公子 2013-04-11 00:39:13 108645浏览量 回答数 78
0
文章
2
问答
问答排行榜
最热
最新
相关电子书
更多
OceanBase 入门到实战教程
立即下载
阿里云图数据库GDB,加速开启“图智”未来.ppt
立即下载
实时数仓Hologres技术实战一本通2.0版(下)
立即下载