[flink] branch release-1.11 updated: [FLINK-18411][tests] Fix CollectionExecutorTest failed to compiled in release-1.11

[jark]

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 <j...@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);