This is an automated email from the ASF dual-hosted git repository.
sjwiesman pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from d081d9a [FLINK-22545][tests] Fix delayed split assignment in
OperatorEventSendingCheckpointITCase
new 65ec2a2 [hotfix][state-processor-api] test state reader with modern
state backend stack
new 993289d [hotfix][docs] replace references to MemoryStateBackend with
HashMapStateBackend
new 7c3e742 [hotfix] support setting additional configuration on
WritableSavepoint
new 80bd85d [FLINK-23728][state-processor-api] State bootstrapping fails
on new state backend factory stack
The 4 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
docs/content.zh/docs/libs/state_processor_api.md | 8 +++---
docs/content/docs/libs/state_processor_api.md | 8 +++---
.../flink/state/api/BootstrapTransformation.java | 19 +++++++++++--
.../apache/flink/state/api/WritableSavepoint.java | 27 +++++++++++++++++--
.../flink/state/api/output/SnapshotUtils.java | 31 ++++++++++++++++++----
.../operators/BroadcastStateBootstrapOperator.java | 2 +-
.../operators/KeyedStateBootstrapOperator.java | 2 +-
.../output/operators/StateBootstrapOperator.java | 2 +-
.../operators/StateBootstrapWrapperOperator.java | 2 +-
.../state/api/BootstrapTransformationTest.java | 6 ++++-
...RocksDBStateBackendReaderKeyedStateITCase.java} | 12 ++++-----
...> EmbeddedRocksDBStateBackendWindowITCase.java} | 10 +++----
...HashMapStateBackendReaderKeyedStateITCase.java} | 10 +++----
...e.java => HashMapStateBackendWindowITCase.java} | 10 +++----
.../flink/state/api/SavepointDeepCopyTest.java | 21 ++++++++++-----
.../flink/state/api/SavepointWriterITCase.java | 13 +++++++++
.../state/api/SavepointWriterWindowITCase.java | 6 ++++-
.../flink/state/api/output/SnapshotUtilsTest.java | 9 ++-----
18 files changed, 141 insertions(+), 57 deletions(-)
copy
flink-libraries/flink-state-processing-api/src/test/java/org/apache/flink/state/api/{MemoryStateBackendReaderKeyedStateITCase.java
=> EmbeddedRocksDBStateBackendReaderKeyedStateITCase.java} (68%)
copy
flink-libraries/flink-state-processing-api/src/test/java/org/apache/flink/state/api/{MemoryStateBackendWindowITCase.java
=> EmbeddedRocksDBStateBackendWindowITCase.java} (74%)
copy
flink-libraries/flink-state-processing-api/src/test/java/org/apache/flink/state/api/{MemoryStateBackendReaderKeyedStateITCase.java
=> HashMapStateBackendReaderKeyedStateITCase.java} (76%)
copy
flink-libraries/flink-state-processing-api/src/test/java/org/apache/flink/state/api/{MemoryStateBackendWindowITCase.java
=> HashMapStateBackendWindowITCase.java} (77%)
