You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ja...@apache.org on 2020/06/23 06:45:34 UTC
[flink] branch release-1.11 updated: [FLINK-18411][tests] Fix
CollectionExecutorTest failed to compiled in release-1.11
This is an automated email from the ASF dual-hosted git repository.
jark pushed a commit to branch release-1.11
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/release-1.11 by this push:
new 83d7813 [FLINK-18411][tests] Fix CollectionExecutorTest failed to compiled in release-1.11
83d7813 is described below
commit 83d78134d2497266f8d864b2667c10a955384b94
Author: Jark Wu <ja...@apache.org>
AuthorDate: Tue Jun 23 14:44:25 2020 +0800
[FLINK-18411][tests] Fix CollectionExecutorTest failed to compiled in release-1.11
This closes #12749
---
.../java/org/apache/flink/api/java/utils/CollectionExecutorTest.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
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
index dd4048e..37d9213 100644
--- 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
@@ -51,7 +51,7 @@ public class CollectionExecutorTest {
config.set(DeploymentOptions.TARGET, CollectionPipelineExecutor.NAME);
config.set(DeploymentOptions.ATTACHED, true);
- PipelineExecutorFactory factory = DefaultExecutorServiceLoader.INSTANCE.getExecutorFactory(config);
+ PipelineExecutorFactory factory = new DefaultExecutorServiceLoader().getExecutorFactory(config);
assertTrue(factory instanceof CollectionExecutorFactory);
PipelineExecutor executor = factory.getExecutor(config);