This is an automated email from the ASF dual-hosted git repository.
roman pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 4c4ba6c [FLINK-21646][table-planner-blink] Support
StreamExecWindowAggregate json serialization/deserialization
add d72fa2e [FLINK-21354] Introduce ChangelogStateBackend to delegate
state access
No new revisions were added by this update.
Summary of changes:
.../flink/configuration/CheckpointingOptions.java | 10 +
flink-libraries/flink-state-processing-api/pom.xml | 7 +
.../runtime/state/AbstractKeyedStateBackend.java | 37 ++-
.../runtime/state/CheckpointStorageLoader.java | 16 +-
.../flink/runtime/state/KeyedStateBackend.java | 5 +
.../flink/runtime/state/StateBackendLoader.java | 149 ++++++++-
.../runtime/state/TestableKeyedStateBackend.java | 27 ++
.../state/delegate/DelegatingStateBackend.java | 32 ++
.../runtime/state/heap/HeapKeyedStateBackend.java | 6 +-
.../flink/runtime/state/StateBackendTestBase.java | 208 ++++++++-----
.../state/StateSnapshotTransformerTest.java | 4 +-
.../state/ttl/mock/MockKeyedStateBackend.java | 6 -
.../flink-statebackend-changelog}/pom.xml | 55 ++--
.../state/changelog/AbstractChangelogState.java | 83 +++++
.../state/changelog/ChangelogAggregatingState.java | 84 ++++++
.../changelog/ChangelogKeyedStateBackend.java | 336 +++++++++++++++++++++
.../flink/state/changelog/ChangelogListState.java | 91 ++++++
.../flink/state/changelog/ChangelogMapState.java | 107 +++++++
.../state/changelog/ChangelogReducingState.java | 80 +++++
.../state/changelog/ChangelogStateBackend.java | 163 ++++++++++
.../flink/state/changelog/ChangelogValueState.java | 65 ++++
...logDelegateEmbeddedRocksDBStateBackendTest.java | 47 +++
.../ChangelogDelegateFileStateBackendTest.java | 46 +++
.../changelog/ChangelogDelegateHashMapTest.java | 45 +++
.../ChangelogDelegateMemoryStateBackendTest.java | 46 +++
.../changelog/ChangelogDelegateStateTest.java | 141 +++++++++
.../ChangelogStateBackendLoadingTest.java | 282 +++++++++++++++++
.../changelog/ChangelogStateBackendTestUtils.java | 65 ++++
.../src/test/resources/log4j2.properties | 28 ++
.../flink-statebackend-rocksdb/pom.xml | 1 +
.../state/EmbeddedRocksDBStateBackendTest.java | 11 +-
flink-state-backends/pom.xml | 1 +
.../operators/InternalTimeServiceManagerImpl.java | 6 +-
.../flink/table/runtime/util/StateConfigUtil.java | 11 +-
flink-tests/pom.xml | 7 +
35 files changed, 2137 insertions(+), 171 deletions(-)
create mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/state/TestableKeyedStateBackend.java
create mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/state/delegate/DelegatingStateBackend.java
copy {flink-libraries/flink-state-processing-api =>
flink-state-backends/flink-statebackend-changelog}/pom.xml (68%)
create mode 100644
flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/AbstractChangelogState.java
create mode 100644
flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/ChangelogAggregatingState.java
create mode 100644
flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/ChangelogKeyedStateBackend.java
create mode 100644
flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/ChangelogListState.java
create mode 100644
flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/ChangelogMapState.java
create mode 100644
flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/ChangelogReducingState.java
create mode 100644
flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/ChangelogStateBackend.java
create mode 100644
flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/ChangelogValueState.java
create mode 100644
flink-state-backends/flink-statebackend-changelog/src/test/java/org/apache/flink/state/changelog/ChangelogDelegateEmbeddedRocksDBStateBackendTest.java
create mode 100644
flink-state-backends/flink-statebackend-changelog/src/test/java/org/apache/flink/state/changelog/ChangelogDelegateFileStateBackendTest.java
create mode 100644
flink-state-backends/flink-statebackend-changelog/src/test/java/org/apache/flink/state/changelog/ChangelogDelegateHashMapTest.java
create mode 100644
flink-state-backends/flink-statebackend-changelog/src/test/java/org/apache/flink/state/changelog/ChangelogDelegateMemoryStateBackendTest.java
create mode 100644
flink-state-backends/flink-statebackend-changelog/src/test/java/org/apache/flink/state/changelog/ChangelogDelegateStateTest.java
create mode 100644
flink-state-backends/flink-statebackend-changelog/src/test/java/org/apache/flink/state/changelog/ChangelogStateBackendLoadingTest.java
create mode 100644
flink-state-backends/flink-statebackend-changelog/src/test/java/org/apache/flink/state/changelog/ChangelogStateBackendTestUtils.java
create mode 100644
flink-state-backends/flink-statebackend-changelog/src/test/resources/log4j2.properties
