luoyuxia opened a new issue, #1690: URL: https://github.com/apache/fluss/issues/1690
### Search before asking - [x] I searched in the [issues](https://github.com/apache/fluss/issues) and found nothing similar. ### Description Current LakeSourceSplit is not back-compatible.Assuming we have two version of Serializer v1 and v2. 1: flink use v1 Serializer, and do snapshot, it'll use the v1 Serializer to serialize it. 2: then, assuming we upgrade to v2 Serializer, flink restore from the state which used v1 Serializer 3: flink should use version 1 to deserialize the split. **But now, it always the version of the latest Serializer which is v2** That's the problem. We should use v1 to deserialize it. We need to store v1 into state, then restore from state, pass v1 to the deserializer to deserialize it. ### Willingness to contribute - [ ] I'm willing to submit a PR! -- 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. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
