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

Posted to commits@flink.apache.org by wa...@apache.org on 2023/01/16 09:13:59 UTC

[flink] branch master updated (8e50e24797f -> c0c7dc47905)

This is an automated email from the ASF dual-hosted git repository.

wanglijie pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git


    from 8e50e24797f [FLINK-30332][network] HsFileDataIndex supports caching index entry and introduce config option to configure cache size.
     add df29023d8be [FLINK-30670][runtime] Ignore broadcast bytes when computing parallelism and input infos
     add c0c7dc47905 [FLINK-30631][runtime] Limit the max number of subpartitons consumed by each downstream task

No new revisions were added by this update.

Summary of changes:
 ...faultVertexParallelismAndInputInfosDecider.java | 173 +++++++++++----------
 ...tVertexParallelismAndInputInfosDeciderTest.java |  81 +++++++---
 2 files changed, 154 insertions(+), 100 deletions(-)