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

Posted to commits@flink.apache.org by xt...@apache.org on 2022/06/13 06:23:11 UTC

[flink] branch master updated (65fda6e15a1 -> aa693b5076f)

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

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


    from 65fda6e15a1 [FLINK-27921][Runtime] Introduce the checkResourceRequirementsWithDelay in DeclarativeSlotManager
     add 0ce3b77ede5 [hotfix] fix typo in StreamingJobGraphGenerator.
     add 5585b9619c7 [FLINK-27903][network] Introduce HYBRID result partition type.
     add ed10a78b294 [FLINK-27903][streaming] Make StreamGraph supports hybrid result partition type.
     add aa693b5076f [FLINK-27903][runtime] Make pipelinedRegionSchedulingStrategyTest also support testing for hybrid resultPartitionType.

No new revisions were added by this update.

Summary of changes:
 .../apache/flink/api/common/BatchShuffleMode.java  |  15 ++-
 .../flink/configuration/ExecutionOptions.java      |   2 +
 .../io/network/partition/ResultPartitionType.java  |  10 +-
 .../PipelinedRegionSchedulingStrategyTest.java     | 150 ++++++++++++++++++---
 .../strategy/TestingSchedulingPipelinedRegion.java |  19 ++-
 .../api/graph/GlobalStreamExchangeMode.java        |   5 +-
 .../streaming/api/graph/StreamGraphGenerator.java  |   2 +
 .../api/graph/StreamingJobGraphGenerator.java      |  17 ++-
 .../api/transformations/StreamExchangeMode.java    |   5 +
 .../StreamGraphGeneratorBatchExecutionTest.java    |   5 +
 .../api/graph/StreamingJobGraphGeneratorTest.java  |  63 +++++++++
 11 files changed, 267 insertions(+), 26 deletions(-)