chenjunjiedada commented on issue #1438: URL: https://github.com/apache/iceberg/issues/1438#issuecomment-691793978
This can happen when restoring from checkpoint/savepoint state. This can also happen when Flink cluster upgraded with existing user applications as pointed out by @JingsongLi [here](https://github.com/apache/iceberg/pull/1346#discussion_r476981455) and might happen when user wants to try out newly released iceberg-flink-runtime on the Flink cluster. Flink is using Kryo for state serialization according to [this](https://ci.apache.org/projects/flink/flink-docs-stable/dev/types_serialization.html#general-class-types). But, Flink uses java serialization to transport messages and programs through RPC according to [doc](https://flink.apache.org/contributing/code-style-and-quality-java.html#java-serialization). So I guess serializable classes in operator would be serialized and transfer to tasks via Java serialization and as a consequence, we have to define `serialVersionUID`. @openinx @JingsongLi, Any comment? ---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: [email protected] --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
