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 d0b3390ffb9 [FLINK-27185][connector] Convert connector-jdbc module to
assertj
add 24780c839a2 [FLINK-27902][network] Remove unnecessary attribute
hasBackPressure in ResultPartitionType.
add 588ef596916 [FLINK-27902][network] Add ConsumingConstraint and
releaseBy in ResultPartitionType to decoupling scheduling and partition release.
add e0b971c22fd [FLINK-27902][network] Using mustBePipelinedConsumed
method to compute pipelined regions.
add 85681559ad7 [FLINK-27902][network] Introduce canBePipelinedConsumed to
replace some previous isPipelined calls that actually judge whether the
downstream can consume data when upstream is not finish.
add e7c1196b378 [FLINK-27902][network] Using isReleaseByScheduler and
isReleaseByUpstrem to replace some previous isPipelined,isBlocking and
isReconnectable calls that actually refer to partition release logical.
add 24a75047fab [FLINK-27902][network] Introduce
isPipelinedOrPipelinedBoundedResultPartition to replace some previous
isPipelined calls that actually judge whether the resultPartitionType is
Pipelined or PipelinedBounded.
add ac870f925ac [FLINK-27902][network] Introduce
isBlockingOrBlockingPersistentResultPartition and replace all remaining
isBlocking calls.
add 98d4cd659bc [FLINK-27902][network] remove useless isPipelined,
isBlocking and isReconnectable in ResultPartitionType.
No new revisions were added by this update.
Summary of changes:
.../dataexchange/UnionClosedBranchingTest.java | 4 +-
.../TaskDeploymentDescriptorFactory.java | 2 +-
.../flink/runtime/executiongraph/Execution.java | 2 +-
.../runtime/executiongraph/ExecutionVertex.java | 2 +-
.../IntermediateResultPartition.java | 4 +-
.../flip1/LogicalPipelinedRegionComputeUtil.java | 13 ++-
.../failover/flip1/PipelinedRegionComputeUtil.java | 11 +--
.../SchedulingPipelinedRegionComputeUtil.java | 14 +--
.../RegionPartitionGroupReleaseStrategy.java | 4 +-
.../partition/JobMasterPartitionTrackerImpl.java | 6 +-
.../network/partition/ResultPartitionFactory.java | 3 +-
.../io/network/partition/ResultPartitionType.java | 105 ++++++++++++++-------
.../partition/consumer/SingleInputGateFactory.java | 3 +-
.../adapter/DefaultExecutionTopology.java | 6 +-
.../adapter/DefaultSchedulingPipelinedRegion.java | 29 ++++--
.../scheduler/adaptive/AdaptiveScheduler.java | 4 +-
.../AdaptiveBatchSchedulerFactory.java | 2 +-
.../strategy/SchedulingPipelinedRegion.java | 7 ++
.../flink/runtime/shuffle/NettyShuffleUtils.java | 10 +-
.../flink/runtime/taskexecutor/TaskExecutor.java | 4 +-
.../JobMasterPartitionTrackerImplTest.java | 2 +-
.../SsgNetworkMemoryCalculationUtilsTest.java | 2 +-
.../strategy/TestingSchedulingPipelinedRegion.java | 5 +
.../runtime/shuffle/NettyShuffleUtilsTest.java | 2 +-
.../api/graph/StreamingJobGraphGenerator.java | 6 +-
25 files changed, 161 insertions(+), 91 deletions(-)
