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(-)
