Revert "[FLINK-17126][java] Introduce CollectionPipelineExecutor for …

…CollectionEnvironment" This reverts commit c983ac9.
deepfield · Jun 18, 2020 · 2569d1b · 2569d1b
1 parent eb57c49
commit 2569d1b
Show file tree

Hide file tree

Showing 6 changed files with 0 additions and 269 deletions.
diff --git a/flink-java/src/main/java/org/apache/flink/api/java/CollectionEnvironment.java b/flink-java/src/main/java/org/apache/flink/api/java/CollectionEnvironment.java
@@ -22,20 +22,13 @@
 import org.apache.flink.api.common.JobExecutionResult;
 import org.apache.flink.api.common.Plan;
 import org.apache.flink.api.common.operators.CollectionExecutor;
-import org.apache.flink.api.java.utils.CollectionPipelineExecutor;
-import org.apache.flink.configuration.DeploymentOptions;
 
 /**
  * Version of {@link ExecutionEnvironment} that allows serial, local, collection-based executions of Flink programs.
  */
 @PublicEvolving
 public class CollectionEnvironment extends ExecutionEnvironment {
 
- public CollectionEnvironment() {
- getConfiguration().set(DeploymentOptions.TARGET, CollectionPipelineExecutor.NAME);
- getConfiguration().set(DeploymentOptions.ATTACHED, true);
- }
-
  @Override
  public JobExecutionResult execute(String jobName) throws Exception {
  Plan p = createProgramPlan(jobName);

diff --git a/flink-java/src/main/java/org/apache/flink/api/java/utils/CollectionExecutorFactory.java b/flink-java/src/main/java/org/apache/flink/api/java/utils/CollectionExecutorFactory.java
diff --git a/flink-java/src/main/java/org/apache/flink/api/java/utils/CollectionPipelineExecutor.java b/flink-java/src/main/java/org/apache/flink/api/java/utils/CollectionPipelineExecutor.java
diff --git a/.../main/resources/META-INF/services/org.apache.flink.core.execution.PipelineExecutorFactory b/.../main/resources/META-INF/services/org.apache.flink.core.execution.PipelineExecutorFactory
diff --git a/flink-java/src/test/java/org/apache/flink/api/java/utils/CollectionExecutorTest.java b/flink-java/src/test/java/org/apache/flink/api/java/utils/CollectionExecutorTest.java
diff --git a/.../flink-test-utils/src/main/java/org/apache/flink/test/util/CollectionTestEnvironment.java b/.../flink-test-utils/src/main/java/org/apache/flink/test/util/CollectionTestEnvironment.java
@@ -30,10 +30,6 @@
  */
 public class CollectionTestEnvironment extends CollectionEnvironment {
 
- public CollectionTestEnvironment() {
- super();
- }
-
  private CollectionTestEnvironment lastEnv = null;
 
  @Override