Re: Flink作业修改时State的兼容性

[Hangxiang Yu <ma...@gmail.com>]

hello，目前开源版本仅支持DataStream作业有限的更改，如DS作业加减字段等[1]；
阿里云的Flink版本支持了SQL作业修改后的兼容性判断、大部分SQL算子修改的兼容性、比社区更快的状态迁移速度（几乎不阻塞作业启动）；

Best,
Hangxiang.

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

On Sat, Jul 30, 2022 at 2:30 PM tison <wa...@gmail.com> wrote:

> 这个同样可以看两份材料
>
> *
>
> https://nightlies.apache.org/flink/flink-docs-release-1.15/docs/dev/datastream/fault-tolerance/serialization/schema_evolution/
> * https://zhuanlan.zhihu.com/p/119305376
>
> 简单说来只是改并发的话 Key state 比较好迁移，operator state 各有各的特性。如果明显改了逻辑就需要手动跑出新状态。
>
> Best,
> tison.
>
>
> m18814122325 <m1...@163.com> 于2022年7月30日周六 14:21写道：
>
> > 当Flink作业在业务变更修改时，在用checkpoint或者savepoint进行状态恢复时，兼容性如何?有相关文档吗？
> >
> > 我在阿里云找到SQL修改和兼容性的文档https://help.aliyun.com/document_detail/403317.html。
> > 但不知道文档说明的是阿里云里的Flink版本还是开源版本。
>