289c30e8cdb54d2504ee47a57858a1d179f9a540 - flink-statefun

commit	289c30e8cdb54d2504ee47a57858a1d179f9a540	[log] [tgz]
author	Tzu-Li (Gordon) Tai <tzulitai@apache.org>	Fri Jun 05 01:15:13 2020 +0800
committer	Tzu-Li (Gordon) Tai <tzulitai@apache.org>	Mon Jul 13 12:39:05 2020 +0800
tree	f52c860bf3f53e2e1568c5a0b4207575d152c3fc
parent	48dc47441f204d568fa9a568c690d794f10709ec [diff]

[FLINK-17954] [core] Demux legacy remote function state on restore

This commit adds backwards compatibility for versions 2.1.x, by
performing state migration to demultiplex the PersistedTable used for
remote function states into PersistedValues.

We intend to only have this backwards compatibility for one version
only. Therefore, the plan is to revert these changes for 2.3.x.
This means if a user intends to upgrade from 2.1.x to 2.3.x, they need
to first upgrade to 2.2.x.

This closes #126.
This closes #125.

statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/StatefulFunctionsConfig.java[diff]
statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/functions/FunctionGroupOperator.java[diff]
statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/functions/RemoteFunctionStateMigrator.java[Added - diff]
statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/httpfn/HttpFunctionProvider.java[diff]
statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/state/FlinkState.java[diff]

5 files changed

tree: f52c860bf3f53e2e1568c5a0b4207575d152c3fc