You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by al...@apache.org on 2020/10/06 07:08:37 UTC

[flink] branch master updated (6c7b195 -> 47ca19a)

This is an automated email from the ASF dual-hosted git repository.

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


    from 6c7b195  [FLINK-19295][yarn][tests] Exclude more meaningless akka shutdown errors (#13439)
     add 443a959  [FLINK-19123] Move PerJobMiniClusterJobClient to top level
     add b336c72  [FLINK-19123] Move PerJobMiniClusterJobClient to runtime.minicluster package
     add a842b68  [FLINK-19123] Make MiniClusterJobClient shutdown behaviour configurable
     add f9fc140  [FLINK-19123] Don't override execute()/executeAsync() in TestStreamEnvironment
     add 47ca19a  [FLINK-19123] Remove unused JobExecutor interfaces

No new revisions were added by this update.

Summary of changes:
 .../client/program/PerJobMiniClusterFactory.java   |  93 +-----------
 .../org/apache/flink/orc/OrcFileSystemITCase.java  |   5 +-
 .../flink/runtime/minicluster/JobExecutor.java     |  38 -----
 .../runtime/minicluster/JobExecutorService.java    |  27 ----
 .../flink/runtime/minicluster/MiniCluster.java     |   3 +-
 .../runtime/minicluster/MiniClusterJobClient.java  | 165 +++++++++++++++++++++
 .../streaming/util/TestStreamEnvironment.java      |  78 +++-------
 .../MiniClusterPipelineExecutorServiceLoader.java  | 149 +++++++++++++++++++
 .../apache/flink/test/util/TestEnvironment.java    | 127 +++++-----------
 9 files changed, 386 insertions(+), 299 deletions(-)
 delete mode 100644 flink-runtime/src/main/java/org/apache/flink/runtime/minicluster/JobExecutor.java
 delete mode 100644 flink-runtime/src/main/java/org/apache/flink/runtime/minicluster/JobExecutorService.java
 create mode 100644 flink-runtime/src/main/java/org/apache/flink/runtime/minicluster/MiniClusterJobClient.java
 create mode 100644 flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/test/util/MiniClusterPipelineExecutorServiceLoader.java