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 3149c621671 [FLINK-29096][table] Update documentation for JSON_VALUE
special characters
add a38b852bbbd [hotfix][state] Extract PeriodicMaterializationManager
into state-backend-common
add aaa35607866 [hotfix][tests] Use negative changelog materialization
interval in tests
add 0e083c119b2 [hotfix][state] Fix logging in Materializer and make
FLINK-28976 more explicit
add 91e1291e942 [FLINK-28976][state] Don't add extra delay to the 1st
materialization
No new revisions were added by this update.
Summary of changes:
.../flink-statebackend-changelog/pom.xml | 6 ++
.../changelog/ChangelogKeyedStateBackend.java | 10 +-
.../state/changelog/ChangelogStateBackend.java | 2 +
.../changelog/ChangelogKeyedStateBackendTest.java | 2 +-
.../state/changelog/ChangelogMetricGroupTest.java | 8 +-
.../changelog/ChangelogStateBackendTestUtils.java | 2 +
.../state/changelog/ChangelogStateDiscardTest.java | 2 +-
.../pom.xml | 51 +++-------
.../ChangelogMaterializationMetricGroup.java | 14 +--
.../common}/PeriodicMaterializationManager.java | 104 +++++++++++++++++----
.../common/PeriodicMaterializationManagerTest.java | 67 +++++++++++++
flink-state-backends/pom.xml | 1 +
.../streaming/util/TestStreamEnvironment.java | 3 +-
.../test/state/ChangelogRecoveryCachingITCase.java | 2 +-
14 files changed, 198 insertions(+), 76 deletions(-)
copy flink-state-backends/{flink-statebackend-changelog =>
flink-statebackend-common}/pom.xml (63%)
rename
flink-state-backends/{flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog
=>
flink-statebackend-common/src/main/java/org/apache/flink/state/common}/ChangelogMaterializationMetricGroup.java
(79%)
rename
flink-state-backends/{flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog
=>
flink-statebackend-common/src/main/java/org/apache/flink/state/common}/PeriodicMaterializationManager.java
(79%)
create mode 100644
flink-state-backends/flink-statebackend-common/src/test/java/org/apache/flink/state/common/PeriodicMaterializationManagerTest.java
