This is an automated email from the ASF dual-hosted git repository.
fanrui pushed a change to branch release-2.1
in repository https://gitbox.apache.org/repos/asf/flink.git
from 1e6f431462f [FLINK-34094][docs] Adds documentation for
AsyncScalarFunction
new 9faac10f84f [FLINK-38137][state] RocksDB and ForSt state backend are
compatible with the case where the user value of the map state is null
new d2a88f6b0e8 [FLINK-38137][state] Disable testMapStateWithNullValue for
change log state backend temporarily
The 2 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:
.../apache/flink/api/common/state/MapState.java | 3 +
.../apache/flink/api/common/state/v2/MapState.java | 3 +
.../flink/runtime/state/StateBackendTestBase.java | 93 +++++++
...logDelegateEmbeddedRocksDBStateBackendTest.java | 8 +
.../changelog/ChangelogDelegateHashMapTest.java | 9 +
.../state/forst/sync/AbstractForStSyncState.java | 5 +-
.../flink/state/rocksdb/AbstractRocksDBState.java | 5 +-
.../MapStateNullValueCheckpointingITCase.java | 266 +++++++++++++++++++++
8 files changed, 390 insertions(+), 2 deletions(-)
create mode 100644
flink-tests/src/test/java/org/apache/flink/test/checkpointing/MapStateNullValueCheckpointingITCase.java
