是不是静态内部类的问题？ Rules for POJO types Flink recognizes a data type as a POJO type (and allows “by-name” field referencing) if the following conditions are fulfilled:
The class is public and standalone (no non-static inner class) The class has a public no-argument constructor All non-static, non-transient fields in the class (and all superclasses) are either public (and non-final) or have a public getter- and a setter- method that follows the Java beans naming conventions for getters and setters. Note that when a user-defined data type can’t be recognized as a POJO type, it must be processed as GenericType and serialized with Kryo. | | 邵红晓 | | 邮箱：[email protected] | 签名由网易邮箱大师定制 在2020年4月30日 09:40，shx<[email protected]> 写道： 能发一下写入状态的代码看一下吗，还有一个问题，键值状态访问，你的代码里是读出了所有key关键的mapstate吗，谢谢 | | 邵红晓 | | 邮箱：[email protected] | 签名由 网易邮箱大师 定制 在2020年04月30日 09:04，guanyq 写道： 代码中没特别指定Serializer。都是默认的序列化。 在 2020-04-29 18:20:22，"Congxian Qiu" <[email protected]> 写道： Hi 从错误日志看，是 StateMigration 相关的问题。 你需要确认下，你的代码中的 Serializer 和 savepoint 中 state 相关的 serializer 是一样的或者是兼容的，你可以参考下这个文档[1] [1] https://ci.apache.org/projects/flink/flink-docs-release-1.10/dev/stream/state/schema_evolution.html Best, Congxian guanyq <[email protected]> 于2020年4月29日周三 下午6:09写道： 附件是代码和错误日志。目前不知道如何调查。麻烦帮忙看下 谢谢。
