1. flink 1.13以前savepoint数据格式应该和checkpoint格式一样.
你的作业是否开启了增量checkpoint, 如果作业开启增量checkpoint的话, checkpoint会快(只上传增量部分),
 savepoint会慢(需要上传全量数据)。

2. flink 1.13
中统一了所有stateBackend的savepoint格式,因为savepoint时需要逐个遍历出state中的key-value数据,所以速度相比checkpoint也会慢很多。

3. flink 1.15中引入了native模式的savepoint[1],
放开了savepoint格式限制,其速度应该类似于一次全量checkpoint。

[1]
https://nightlies.apache.org/flink/flink-docs-master/docs/ops/state/savepoints/
[2]
https://nightlies.apache.org/flink/flink-docs-release-1.15/docs/ops/state/checkpoints_vs_savepoints/

Best,
Jinzhong Li

Howie Yang <haoyuyan...@126.com> 于2022年8月3日周三 17:54写道:

> hello,
>
>
> 版本:flink1.9
> 问题:作业每次手动停止做savepoint要5min,自动化checkpoint只需要秒级,
> 请问:
> 1. savepoint是要比checkpoint多存一些内容吗?
> 2. savepoint为什么这么耗时?(在不保存savepoint的情况下,也是秒级停止)
>
>
>
>
>
>
>
> --
>
> Best,
> Howie

回复