flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From twal...@apache.org
Subject [flink] branch master updated (48526e4 -> de7a00b)
Date Wed, 04 Aug 2021 14:31:34 GMT
This is an automated email from the ASF dual-hosted git repository.

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


    from 48526e4  [FLINK-23487][s3] Update aws and presto-hive dependencies
     add de7a00b  [FLINK-23402][streaming-java] Simplify shuffle mode for batch execution

No new revisions were added by this update.

Summary of changes:
 .../generated/execution_configuration.html         | 12 +++---
 .../{ShuffleMode.java => BatchShuffleMode.java}    | 47 +++++++---------------
 .../flink/configuration/ExecutionOptions.java      | 35 ++++++++--------
 .../environment/StreamExecutionEnvironment.java    |  5 ++-
 .../streaming/api/graph/StreamGraphGenerator.java  | 23 +++--------
 .../StreamGraphGeneratorBatchExecutionTest.java    | 33 +++------------
 .../table/api/config/ExecutionConfigOptions.java   |  2 +-
 .../flink/table/planner/utils/ExecutorUtils.java   |  8 ++--
 .../planner/utils/StreamExchangeModeUtils.java     |  6 +--
 .../planner/utils/StreamExchangeModeUtilsTest.java | 16 +++++---
 .../plan/batch/sql/MultipleInputCreationTest.scala | 10 ++---
 .../runtime/batch/sql/MultipleInputITCase.scala    | 10 ++---
 .../planner/runtime/utils/BatchTestBase.scala      |  5 ++-
 .../flink/table/planner/utils/TableTestBase.scala  | 28 +++++++------
 14 files changed, 99 insertions(+), 141 deletions(-)
 rename flink-core/src/main/java/org/apache/flink/api/common/{ShuffleMode.java => BatchShuffleMode.java}
(52%)

Mime
View raw message