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

[flink] branch master updated (ec9f68d -> 2569d1b)

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

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


    from ec9f68d  [FLINK-18319][notice] Lack LICENSE.protobuf in flink-sql-orc
     add eb57c49  [FLINK-17383] Do not use CollectionEnvironment in flink-planner tests
     add 2569d1b  Revert "[FLINK-17126][java] Introduce CollectionPipelineExecutor for CollectionEnvironment"

No new revisions were added by this update.

Summary of changes:
 .../flink/api/java/CollectionEnvironment.java      |  7 --
 .../api/java/utils/CollectionExecutorFactory.java  | 47 -----------
 .../api/java/utils/CollectionPipelineExecutor.java | 93 ----------------------
 ...he.flink.core.execution.PipelineExecutorFactory | 34 --------
 .../api/java/utils/CollectionExecutorTest.java     | 84 -------------------
 .../runtime/batch/sql/TableEnvironmentITCase.scala |  2 +-
 .../runtime/batch/table/TableSinkITCase.scala      | 13 ++-
 .../utils/TableProgramsCollectionTestBase.scala    |  6 +-
 .../flink/test/util/CollectionTestEnvironment.java |  4 -
 9 files changed, 15 insertions(+), 275 deletions(-)
 delete mode 100644 flink-java/src/main/java/org/apache/flink/api/java/utils/CollectionExecutorFactory.java
 delete mode 100644 flink-java/src/main/java/org/apache/flink/api/java/utils/CollectionPipelineExecutor.java
 delete mode 100644 flink-java/src/main/resources/META-INF/services/org.apache.flink.core.execution.PipelineExecutorFactory
 delete mode 100644 flink-java/src/test/java/org/apache/flink/api/java/utils/CollectionExecutorTest.java