weiqingy commented on PR #28881: URL: https://github.com/apache/flink/pull/28881#issuecomment-5406006893
@gyfora @RocMarshal this one is now ready for review whenever either of you has bandwidth. It is the direct consumer of the hook that just merged in FLINK-40296 / #28880. It wires TTL-aware value migration through `TypeSerializerSnapshot#migrate`: unwrap the value, migrate, re-wrap preserving the TTL timestamp, and thread the persisted prior snapshot down from the backend so migration sees the schema the bytes were actually written with rather than one re-derived from the restored serializer. Behaviour is unchanged for every existing serializer, since the hook defaults to identity. The first override arrives in #28973. -- 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]
