Hi
Flink 支持 state 的 schema evolution 的，具体的文档可以参考 [1]
[1]
https://ci.apache.org/projects/flink/flink-docs-master/zh/dev/stream/state/schema_evolution.html
Best,
Congxian
1048262223 <1048262...@qq.com> 于2020年6月9日周二 下午6:30写道：
> Hi
>
>
> 我在官网找到了文档或许可以解答，参考[1]
>
>
> [1]
> https://ci.apache.org/projects/flink/flink-docs-master/zh/dev/stream/state/schema_evolution.html#pojo-%E7%B1%BB%E5%9E%8B
>
>
> Best,
> Yichao Yang
>
>
>
>
> --原始邮件--
> 发件人:"wangl...@geekplus.com.cn" 发送时间:2020年6月9日(星期二) 晚上6:03
> 收件人:"user-zh"
> 主题:Flink State 增加字段后 state 还能识别吗？
>
>
>
>
> 写了个简单的类会在 Flink State 中使用：
>
> public class OrderState {
> private Integer warehouseId;
> private String orderNo;
> private String ownerCode;
> private Long inputDate;
> private int orderType;
> private int amount = 0;
> private int status = 0;
> .
> }
>
>
> 现在程序要升级，这个类还要增加一个新的字段。从state 能正常恢复吗？
> 也就是 flink run -s savepointdir 后能正常识别旧的代码保存的 state
> 吗？
>
> 谢谢，
> 王磊
>
>
>
> wangl...@geekplus.com.cn
