好奇为什么要把 State 定期写到外存呢?是外部系统需要使用这些 State 吗?那为什么不把 State 以 sink 的方式写出去呢?

Best,
Congxian


Jun Zhang <[email protected]> 于2019年10月31日周四 上午10:36写道:

> 是否可以注册一个定时器?
>
>
> 你看看这个文章,是否对你有帮助
>
>
> https://mp.weixin.qq.com/s/VUEvvoHoupZMpxWQsEeHEA
>      在2019年10月31日 10:16,[email protected]<[email protected]&gt;
> 写道:
>
>
> 消息驱动,QPS 很高, 每一条消息来都会更改 state 值,如果每一条消息来都写外部存储下游撑不住。
> 有没有什么方式可以定期读 state 写到外部存储?
> 我现在用的是 Flink1.7.2 版本。
>
>
>
>
>
> [email protected]

回复