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

Posted to commits@flink.apache.org by zh...@apache.org on 2022/01/15 03:55:25 UTC

[flink] branch master updated (546ee9a -> 56ba36d)

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

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


    from 546ee9a  [FLINK-25570][streaming] Add topology extension points to Sink V2.
     add 8566524  [FLINK-25034][runtime] Support flexible number of subpartitions in IntermediateResultPartition.
     add 56ba36d  [FLINK-25034][runtime] Let InputGateDeploymentDescriptor supports subpartition range.

No new revisions were added by this update.

Summary of changes:
 .../optimizer/plantranslate/JobGraphGenerator.java |   1 +
 .../deployment/InputGateDeploymentDescriptor.java  |  30 +++--
 .../runtime/deployment/SubpartitionIndexRange.java |  34 +++--
 .../TaskDeploymentDescriptorFactory.java           |  45 ++++++-
 .../executiongraph/DefaultExecutionGraph.java      |   5 +
 .../flink/runtime/executiongraph/Execution.java    |  16 +--
 .../runtime/executiongraph/ExecutionJobVertex.java |   2 +-
 .../runtime/executiongraph/IntermediateResult.java |  32 ++++-
 .../IntermediateResultPartition.java               |  61 +++++++++
 .../InternalExecutionGraphAccessor.java            |   5 +
 .../org/apache/flink/runtime/jobgraph/JobEdge.java |  12 ++
 .../flink/runtime/shuffle/PartitionDescriptor.java |  11 +-
 .../TaskDeploymentDescriptorFactoryTest.java       |  88 +++++++++++++
 .../executiongraph/ExecutionJobVertexTest.java     |   2 +-
 .../IntermediateResultPartitionTest.java           | 137 +++++++++++++++++++++
 .../runtime/scheduler/adaptive/ExecutingTest.java  |  13 ++
 .../api/graph/StreamingJobGraphGenerator.java      |   1 +
 17 files changed, 445 insertions(+), 50 deletions(-)
 copy flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/metrics/MinWatermarkGauge.java => flink-runtime/src/main/java/org/apache/flink/runtime/deployment/SubpartitionIndexRange.java (55%)