tzulitai opened a new pull request #126: URL: https://github.com/apache/flink-statefun/pull/126
This PR sits on top of #125, to make use of the new `PersistedStateRegistry` primitive. Only the last 3 commits are relevant. It de-multiplexes the `PersistedTable` used to hold all state values of remote functions, into separate `PersistedValue`s. This opens up each declared remote state to have their own configuration, such as state expiration. This PR also provides a backwards compatibility path for users migrating from <= 2.1.x. The migration path is not enabled by default; users would have to explicitly enable it themselves on the first restore by setting `statefun.remote.migrate-legacy-state` to true. ## Brief change log - 414e446 Adds a new abstraction `PersistedRemoteFunctionValues` that encapsulates operations around `PersistedValue`s of remote functions. - 48dc474 Uses `PersistedRemoteFunctionValues` inside the `RequestReplyFunction`. This demultiplexes the state. - ee3eb3c Provides a migration path to de-multiplex legacy state on restore from versions <= 2.1.0. ## Verifying I've manually verified this by manually restoring from savepoint of the Python greeter example, taken with version 2.1.0. There is also existing unit test coverage in the `RequestReplyFunctionTest`. ---------------------------------------------------------------- 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]
