This is an automated email from the ASF dual-hosted git repository.
1996fanrui pushed a change to branch release-2.3
in repository https://gitbox.apache.org/repos/asf/flink.git
from 6034766bbbc [hotfix][ci] Use `includeOnlyProperties` only for JGit
new edf5916ce4e [FLINK-40904][runtime] Pass consumer parallelism to tasks
via ResultPartitionDeploymentDescriptor
new 3ccd4e92d7b [FLINK-40904][runtime] Detect FORWARD parallelism mismatch
with the actual consumer parallelism
new 2d1483bdc80 [FLINK-40780][runtime] Make FORWARD-to-REBALANCE downgrade
on parallelism mismatch configurable
new b120aa85a54 [FLINK-40780][tests] Add ITCases for forward edge
parallelism mismatch modes
The 4 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../generated/pipeline_configuration.html | 6 +
.../flink/configuration/PipelineOptions.java | 62 +++++
.../state/api/runtime/SavepointEnvironment.java | 5 +
.../ResultPartitionDeploymentDescriptor.java | 30 ++-
.../flink/runtime/execution/Environment.java | 8 +
.../flink/runtime/executiongraph/Execution.java | 5 +-
.../runtime/taskmanager/RuntimeEnvironment.java | 10 +
.../org/apache/flink/runtime/taskmanager/Task.java | 8 +
.../flink/streaming/runtime/tasks/StreamTask.java | 68 ++++-
.../ResultPartitionDeploymentDescriptorTest.java | 8 +-
.../runtime/deployment/ShuffleDescriptorTest.java | 3 +-
.../partition/AbstractPartitionTrackerTest.java | 1 +
.../io/network/partition/PartitionTestUtils.java | 3 +-
.../partition/ResultPartitionFactoryTest.java | 1 +
.../operators/testutils/DummyEnvironment.java | 5 +
.../operators/testutils/MockEnvironment.java | 6 +
.../runtime/shuffle/NettyShuffleUtilsTest.java | 3 +-
.../taskexecutor/TaskExecutorSubmissionTest.java | 5 +-
.../apache/flink/runtime/taskmanager/TaskTest.java | 3 +-
.../runtime/tasks/StreamMockEnvironment.java | 27 +-
.../streaming/runtime/tasks/StreamTaskITCase.java | 1 +
.../streaming/runtime/tasks/StreamTaskTest.java | 92 ++++++-
.../ForwardEdgeParallelismMismatchITCaseBase.java | 279 +++++++++++++++++++++
...wardEdgeParallelismMismatchOverridesITCase.java | 83 ++++++
...rdEdgeParallelismMismatchRestRescaleITCase.java | 175 +++++++++++++
25 files changed, 876 insertions(+), 21 deletions(-)
create mode 100644
flink-tests/src/test/java/org/apache/flink/test/scheduling/ForwardEdgeParallelismMismatchITCaseBase.java
create mode 100644
flink-tests/src/test/java/org/apache/flink/test/scheduling/ForwardEdgeParallelismMismatchOverridesITCase.java
create mode 100644
flink-tests/src/test/java/org/apache/flink/test/scheduling/ForwardEdgeParallelismMismatchRestRescaleITCase.java
