Flink 1.8.2状态演化引发异常

问题描述 投票:0回答:1

我正在尝试更改一个具有大约240个变量的case类,其中一些是我定义的其他pojos示例:Signal(案例类)具有变量PowerPojoFeature,UserFeature。当我更改任何pojo添加新变量时,它将抛出以下异常rg.apache.flink.util.StateMigrationException:用于操作员状态的新状态typeSerializer一定不能不兼容。在org.apache.flink.runtime.state.DefaultOperatorStateBackend.getListState(DefaultOperatorStateBackend.java:323)

是否有任何示例可以为此或任何其他解决方案编写自定义序列化

apache-flink flink-streaming
1个回答
0
投票
© www.soinside.com 2019 - 2024. All rights reserved.