Hi, 这个需求在社区里面称之为 state bootstrapping, 以前在state processor API没有引入时,还有第三方的工具 bravo [1]。 我理解你的需求完全可以有state processor API完成,生成一个savepoint,由新作业消费。目前社区也在考虑支持生成native savepoint,用以加快生成速度 [2]
[1] https://github.com/king/bravo [2] https://issues.apache.org/jira/browse/FLINK-25528 Best Yun Tang ________________________________ From: Jiangang Liu <liujiangangp...@gmail.com> Sent: Thursday, February 24, 2022 10:00 To: user-zh <user-zh@flink.apache.org> Subject: Re: 状态初始化 作业在启动时可以使用 Processor API加载状态,可以参考 https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/libs/state_processor_api/ huangzhi...@iwgame.com <huangzhi...@iwgame.com> 于2022年2月23日周三 20:28写道: > > flink是否能够做到程序第一次启动还没有checkpoint的情况下,对状态进行初始化? > > > huangzhi...@iwgame.com >