[hotfix][tests] Properly pass jarfiles/classpaths to EnvironmentFactory

Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/491aceb0
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/491aceb0
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/491aceb0

Branch: refs/heads/release-1.5
Commit: 491aceb0514f31bf47efb889413b781a22340bd8
Parents: fc1244e
Author: zentol <ches...@apache.org>
Authored: Mon Mar 26 12:58:43 2018 +0200
Committer: zentol <ches...@apache.org>
Committed: Wed Apr 4 14:26:47 2018 +0200

----------------------------------------------------------------------
 .../src/main/java/org/apache/flink/test/util/TestEnvironment.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/flink/blob/491aceb0/flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/test/util/TestEnvironment.java
----------------------------------------------------------------------
diff --git 
a/flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/test/util/TestEnvironment.java
 
b/flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/test/util/TestEnvironment.java
index 1d82f87..948755b 100644
--- 
a/flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/test/util/TestEnvironment.java
+++ 
b/flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/test/util/TestEnvironment.java
@@ -140,7 +140,7 @@ public class TestEnvironment extends ExecutionEnvironment {
                ExecutionEnvironmentFactory factory = new 
ExecutionEnvironmentFactory() {
                        @Override
                        public ExecutionEnvironment 
createExecutionEnvironment() {
-                               lastEnv = new TestEnvironment(jobExecutor, 
getParallelism(), getConfig().isObjectReuseEnabled());
+                               lastEnv = new TestEnvironment(jobExecutor, 
getParallelism(), getConfig().isObjectReuseEnabled(), jarFiles, classPaths);
                                return lastEnv;
                        }
                };

Reply via email to