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 小昌同学 <ccc0606fight...@163.com> wrote: > 我有一个flink任务运行很久了,统计的指标是一些聚合值,但是现在业务想要增加字段,请问一下这个场景大家是怎么处理的啊 > > > | | > 小昌同学 > | > | > ccc0606fight...@163.com > | -- Best, Hangxiang.