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 2021/11/19 09:40:09 UTC

[flink] branch master updated (7bbe5f9 -> f925481)

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 7bbe5f9  [hotfix][table-planner][tests] Remove unnecessary `throws Exception`
     add f925481  [FLINK-23381][state] Back-pressure on reaching state change to upload limit

No new revisions were added by this update.

Summary of changes:
 .../changelog/fs/BatchingStateChangeUploader.java  | 120 ++++++++++++++-----
 .../changelog/fs/FsStateChangelogOptions.java      |  12 +-
 .../changelog/fs/FsStateChangelogStorage.java      |   6 +
 .../flink/changelog/fs/StateChangeUploader.java    |   5 +
 .../apache/flink/changelog/fs/UploadThrottle.java  |  61 ++++++++++
 .../fs/BatchingStateChangeUploaderTest.java        | 127 +++++++++++++++++----
 .../changelog/fs/TestingStateChangeUploader.java   |   6 +-
 .../api/runtime/SavepointTaskStateManager.java     |   2 +-
 .../state/changelog/StateChangelogStorage.java     |   5 +
 .../flink/streaming/runtime/tasks/StreamTask.java  |  33 +++++-
 .../streaming/runtime/tasks/StreamTaskTest.java    |   6 +-
 11 files changed, 318 insertions(+), 65 deletions(-)
 create mode 100644 flink-dstl/flink-dstl-dfs/src/main/java/org/apache/flink/changelog/fs/UploadThrottle.java