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 杨浩 <ya...@163.com> on 2021/11/17 09:58:40 UTC

回复:如何添加source保障程序状态不丢

试了下,可以直接加source,有办法加source后,删掉老的source么?
















在 2021-11-17 14:56:37,"杨浩" <ya...@163.com> 写道:

请问下,我们程序在运行后需要添加一个kafka source(和老的协议一致,后面加工逻辑一样),程序开启了checkpoint,如何保障之前程序的状态不丢啊





 

Re: 如何添加source保障程序状态不丢

Posted by Shengkai Fang <fs...@gmail.com>.
不太理解,直接删掉老source 有什么影响吗?

Best,
Shengkai

杨浩 <ya...@163.com> 于2021年11月17日周三 下午6:00写道:

> 试了下,可以直接加source,有办法加source后,删掉老的source么?
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
> 在 2021-11-17 14:56:37,"杨浩" <ya...@163.com> 写道:
>
> 请问下,我们程序在运行后需要添加一个kafka
> source(和老的协议一致,后面加工逻辑一样),程序开启了checkpoint,如何保障之前程序的状态不丢啊
>
>
>
>
>
>