You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user-zh@flink.apache.org by gimlee <gi...@163.com> on 2021/01/22 04:07:17 UTC

不同程序间checkpoint迁移

程序A：jar  source: kafka
程序B：Flink SQL  source: kafka
使用同一个topic, group id
如果需要把A停掉，使用B替换A，需要把A的checkpoint中的数据、kafka的分区和offset信息改成程序B的checkpoint，请问有办法或者有工具实现嘛？



--
Sent from: http://apache-flink.147419.n8.nabble.com/

Re: 不同程序间checkpoint迁移

Posted by Yun Tang <my...@live.com>.

Hi,

Flink state processor[1] 应该可以满足你的需求。

[1] https://ci.apache.org/projects/flink/flink-docs-stable/dev/libs/state_processor_api.html

祝好
唐云
________________________________
From: gimlee <gi...@163.com>
Sent: Friday, January 22, 2021 12:07
To: user-zh@flink.apache.org <us...@flink.apache.org>
Subject: 不同程序间checkpoint迁移

程序A：jar  source: kafka
程序B：Flink SQL  source: kafka
使用同一个topic, group id
如果需要把A停掉，使用B替换A，需要把A的checkpoint中的数据、kafka的分区和offset信息改成程序B的checkpoint，请问有办法或者有工具实现嘛？



--
Sent from: http://apache-flink.147419.n8.nabble.com/