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 <wander4...@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 <m18814122...@163.com> 于2022年7月30日周六 14:21写道: > > > 当Flink作业在业务变更修改时,在用checkpoint或者savepoint进行状态恢复时,兼容性如何?有相关文档吗? > > > > 我在阿里云找到SQL修改和兼容性的文档https://help.aliyun.com/document_detail/403317.html。 > > 但不知道文档说明的是阿里云里的Flink版本还是开源版本。 >