写了个简单的类会在 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

回复