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