You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ch...@apache.org on 2018/04/04 13:31:09 UTC
[11/19] flink git commit: [hotfix][tests] Properly pass
jarfiles/classpaths to EnvironmentFactory
[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 <ch...@apache.org>
Authored: Mon Mar 26 12:58:43 2018 +0200
Committer: zentol <ch...@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;
}
};