flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From xts...@apache.org
Subject [flink] branch master updated (69e1031 -> 25fdf54)
Date Mon, 05 Jul 2021 03:04:10 GMT
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

Mime
View raw message