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 69e1031 [hotfix]: Fix broken javaDoc inline link.
new d0846bb [hotfix][core] Fix typo in the Builder of ResourceSpec
new bc5f36d [hotfix][core] Check the cpu and heap memory to be positive
when building ResourceSpec
new 0544ddd [FLINK-21925][core] Introduce public SlotSharingGroup
new 7871a58 [FLINK-21925][core] Introduce SlotSharingGroupUtils which
contains utility for SlotSharingGroup
new 2e86133 [FLINK-21925][core] Introduce
#slotSharingGroup(SlotSharingGroup) for configuring slot sharing group with its
resource
new 3f36bbf [FLINK-21925][core] Introduce
StreamExecutionEnvironment#registerSlotSharingGroup
new 25fdf54 [FLINK-21925][core] Introduce
fine-grained.shuffle-mode.all-blocking to avoid resource deadlock in batch jobs
that apply fine-grained resource management
The 7 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:
.../flink/api/common/operators/ResourceSpec.java | 17 +-
.../api/common/operators/SlotSharingGroup.java | 235 +++++++++++++++++++++
.../operators/util/SlotSharingGroupUtils.java | 54 +++++
.../org/apache/flink/api/dag/Transformation.java | 31 ++-
.../apache/flink/configuration/ClusterOptions.java | 8 +
.../api/common/operators/SlotSharingGroupTest.java | 84 ++++++++
.../operators/util/SlotSharingGroupUtilsTest.java | 56 +++++
...st_stream_execution_environment_completeness.py | 3 +-
.../apache/flink/python/util/PythonConfigUtil.java | 4 +-
.../flink/runtime/dispatcher/DispatcherTest.java | 2 +-
.../streaming/api/datastream/DataStreamSink.java | 19 ++
.../api/datastream/SingleOutputStreamOperator.java | 19 ++
.../environment/StreamExecutionEnvironment.java | 58 ++++-
.../flink/streaming/api/graph/StreamGraph.java | 5 +
.../streaming/api/graph/StreamGraphGenerator.java | 46 +++-
.../api/StreamExecutionEnvironmentTest.java | 44 ++++
.../api/graph/StreamGraphGeneratorTest.java | 57 +++++
.../api/scala/StreamExecutionEnvironment.scala | 17 ++
18 files changed, 741 insertions(+), 18 deletions(-)
create mode 100644
flink-core/src/main/java/org/apache/flink/api/common/operators/SlotSharingGroup.java
create mode 100644
flink-core/src/main/java/org/apache/flink/api/common/operators/util/SlotSharingGroupUtils.java
create mode 100644
flink-core/src/test/java/org/apache/flink/api/common/operators/SlotSharingGroupTest.java
create mode 100644
flink-core/src/test/java/org/apache/flink/api/common/operators/util/SlotSharingGroupUtilsTest.java
