You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tr...@apache.org on 2018/01/10 16:27:28 UTC
[4/5] flink git commit: [hotfix] [tests] Fix JavaProgramTestBase to
reset MiniClusterResource#TestEnvironment
[hotfix] [tests] Fix JavaProgramTestBase to reset MiniClusterResource#TestEnvironment
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/a6ee040c
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/a6ee040c
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/a6ee040c
Branch: refs/heads/master
Commit: a6ee040c5dbf8b93e94dcbf353e0db897ff8fb29
Parents: 244f03f
Author: Till Rohrmann <tr...@apache.org>
Authored: Fri Dec 1 19:20:04 2017 +0100
Committer: Till Rohrmann <tr...@apache.org>
Committed: Wed Jan 10 17:14:15 2018 +0100
----------------------------------------------------------------------
.../main/java/org/apache/flink/test/util/JavaProgramTestBase.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/a6ee040c/flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/test/util/JavaProgramTestBase.java
----------------------------------------------------------------------
diff --git a/flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/test/util/JavaProgramTestBase.java b/flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/test/util/JavaProgramTestBase.java
index de536d8..9262ae6 100644
--- a/flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/test/util/JavaProgramTestBase.java
+++ b/flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/test/util/JavaProgramTestBase.java
@@ -210,7 +210,7 @@ public abstract class JavaProgramTestBase extends AbstractTestBase {
e.printStackTrace();
Assert.fail("Error while calling the test program: " + e.getMessage());
} finally {
- CollectionTestEnvironment.unsetAsContext();
+ miniClusterResource.getTestEnvironment().setAsContext();
}
Assert.assertNotNull("The test program never triggered an execution.", this.latestExecutionResult);