You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@flink.apache.org by ro...@apache.org on 2022/03/21 11:39:09 UTC

[flink] branch master updated (32c2ca7 -> db4d05a)

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 32c2ca7  [FLINK-26279] Add mailbox metrics
     add db4d05a  [FLINK-26592][state/changelog] Use mailbox in FsStateChangelogWriter instead of a lock

No new revisions were added by this update.

Summary of changes:
 .../changelog/fs/FsStateChangelogStorage.java      |   6 +-
 .../flink/changelog/fs/FsStateChangelogWriter.java | 146 ++++++++++-----------
 .../fs/BatchingStateChangeUploadSchedulerTest.java |   4 +-
 .../changelog/fs/ChangelogStorageMetricsTest.java  |  19 ++-
 .../changelog/fs/FsStateChangelogStorageTest.java  |  68 ++++++++++
 .../fs/FsStateChangelogWriterSqnTest.java          |   4 +-
 .../changelog/fs/FsStateChangelogWriterTest.java   |   4 +-
 .../state/changelog/StateChangelogStorage.java     |   4 +-
 .../inmemory/InMemoryStateChangelogStorage.java    |   3 +-
 ...kExecutorStateChangelogStoragesManagerTest.java |   3 +-
 .../inmemory/StateChangelogStorageLoaderTest.java  |   3 +-
 .../inmemory/StateChangelogStorageTest.java        |  10 +-
 .../state/changelog/ChangelogStateBackend.java     |   4 +-
 .../changelog/ChangelogKeyedStateBackendTest.java  |   2 +-
 14 files changed, 185 insertions(+), 95 deletions(-)