This is an automated email from the ASF dual-hosted git repository.
yuanmei pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 4d142b3 [FLINK-24489][CEP] The size of entryCache & eventsBufferCache
in the SharedBuffer should be defined with a threshold to limit the number of
the elements in the cache
add c8938b4 [FLINK-23170][state] write metadata after materialization
add 792d922 [hotfix] Change
ChangelogStateBackendTestUtils#testMaterializedRestore to single thread
add 98ec091 [FLINK-23170][state] add unit test for Timer Restore for
different statebackends
No new revisions were added by this update.
Summary of changes:
.../state/changelog/AbstractChangelogState.java | 5 +
.../state/changelog/AbstractStateChangeLogger.java | 5 +
.../ChangelogKeyGroupedPriorityQueue.java | 5 +
.../changelog/ChangelogKeyedStateBackend.java | 25 ++--
.../flink/state/changelog/ChangelogState.java | 3 +
.../changelog/PeriodicMaterializationManager.java | 13 +-
.../flink/state/changelog/StateChangeLogger.java | 3 +
...logDelegateEmbeddedRocksDBStateBackendTest.java | 8 ++
.../ChangelogDelegateFileStateBackendTest.java | 8 ++
.../changelog/ChangelogDelegateHashMapTest.java | 8 ++
.../ChangelogDelegateMemoryStateBackendTest.java | 8 ++
.../state/changelog/ChangelogPqStateTest.java | 3 +
.../changelog/ChangelogStateBackendTestUtils.java | 147 +++++++++++++++++----
.../flink/state/changelog/TestChangeLoggerKv.java | 3 +
14 files changed, 206 insertions(+), 38 deletions(-)
