关于flink1.7.2checkpoint本地文件存储,设置文件个数的问题

classic Classic list List threaded Threaded
3 messages Options
Reply | Threaded
Open this post in threaded view
|

关于flink1.7.2checkpoint本地文件存储,设置文件个数的问题

?青春狂-^
Hi
   关于flink的checkpoint存储的设置有几种方式,mem,hdfs,rocksdb,本地文件
    我选择并配置了本地文件的方式,官方文档中写明了有checkpoint个数的相关配置,但没有找到文件个数的配置,请问这块有文件个数的相关配置么?
Reply | Threaded
Open this post in threaded view
|

Re: 关于flink1.7.2checkpoint本地文件存储,设置文件个数的问题

Godfrey Johnson
不太明白你说的是什么文件个数。

如果是CKP的保留个数,可以参考:https://ci.apache.org/projects/flink/flink-docs-stable/dev/stream/state/checkpointing.html#state-checkpoints-num-retained

> 2019年11月21日 下午10:41,?青春狂-^ <[hidden email]> 写道:
>
> Hi
> &nbsp;&nbsp; 关于flink的checkpoint存储的设置有几种方式,mem,hdfs,rocksdb,本地文件
> &nbsp;&nbsp;&nbsp; 我选择并配置了本地文件的方式,官方文档中写明了有checkpoint个数的相关配置,但没有找到文件个数的配置,请问这块有文件个数的相关配置么?

Reply | Threaded
Open this post in threaded view
|

Re: 关于flink1.7.2checkpoint本地文件存储,设置文件个数的问题

Congxian Qiu
Hi

每个 Checkpoint 生成多少文件,由作业决定,这个不需要用户自己手动设置。

Best,
Congxian


Godfrey Johnson <[hidden email]> 于2019年11月22日周五 上午9:26写道:

> 不太明白你说的是什么文件个数。
>
> 如果是CKP的保留个数,可以参考:
> https://ci.apache.org/projects/flink/flink-docs-stable/dev/stream/state/checkpointing.html#state-checkpoints-num-retained
>
> > 2019年11月21日 下午10:41,?青春狂-^ <[hidden email]> 写道:
> >
> > Hi
> > &nbsp;&nbsp; 关于flink的checkpoint存储的设置有几种方式,mem,hdfs,rocksdb,本地文件
> > &nbsp;&nbsp;&nbsp;
> 我选择并配置了本地文件的方式,官方文档中写明了有checkpoint个数的相关配置,但没有找到文件个数的配置,请问这块有文件个数的相关配置么?
>
>