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 小昌同学 <cc...@163.com> on 2023/01/12 02:32:18 UTC

flink状态恢复

我有一个flink任务运行很久了，统计的指标是一些聚合值，但是现在业务想要增加字段，请问一下这个场景大家是怎么处理的啊


| |
小昌同学
|
|
ccc0606fighting@163.com
|

Re: flink状态恢复

Posted by Hangxiang Yu <ma...@gmail.com>.

Hi,
Flink目前仅支持DataStream作业对POJO类型加减字段，及符合AVRO规则的状态迁移恢复[1]；
如果是其他类型，或者是sql作业，目前社区版本还尚不支持从旧状态恢复，只能无状态启动；

[1]
https://nightlies.apache.org/flink/flink-docs-release-1.16/docs/dev/datastream/fault-tolerance/serialization/schema_evolution/#supported-data-types-for-schema-evolution

On Thu, Jan 12, 2023 at 10:32 AM 小昌同学 <cc...@163.com> wrote:

> 我有一个flink任务运行很久了，统计的指标是一些聚合值，但是现在业务想要增加字段，请问一下这个场景大家是怎么处理的啊
>
>
> | |
> 小昌同学
> |
> |
> ccc0606fighting@163.com
> |



-- 
Best,
Hangxiang.