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/03/02 07:54:41 UTC
[09/12] flink git commit: [hotfix] Let
AbstractEventTimeWindowCheckpointingITCase shutdown ZooKeeper after
MiniCluster
[hotfix] Let AbstractEventTimeWindowCheckpointingITCase shutdown ZooKeeper after MiniCluster
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/8485912f
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/8485912f
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/8485912f
Branch: refs/heads/release-1.5
Commit: 8485912f807b8bc43c46fe785ec16a56d9253b5a
Parents: ea920ef
Author: Till Rohrmann <tr...@apache.org>
Authored: Thu Mar 1 19:03:35 2018 +0100
Committer: Till Rohrmann <tr...@apache.org>
Committed: Fri Mar 2 08:53:51 2018 +0100
----------------------------------------------------------------------
...AbstractEventTimeWindowCheckpointingITCase.java | 17 ++++++++++++++---
1 file changed, 14 insertions(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/8485912f/flink-tests/src/test/java/org/apache/flink/test/checkpointing/AbstractEventTimeWindowCheckpointingITCase.java
----------------------------------------------------------------------
diff --git a/flink-tests/src/test/java/org/apache/flink/test/checkpointing/AbstractEventTimeWindowCheckpointingITCase.java b/flink-tests/src/test/java/org/apache/flink/test/checkpointing/AbstractEventTimeWindowCheckpointingITCase.java
index f37ba0d..61baefa 100644
--- a/flink-tests/src/test/java/org/apache/flink/test/checkpointing/AbstractEventTimeWindowCheckpointingITCase.java
+++ b/flink-tests/src/test/java/org/apache/flink/test/checkpointing/AbstractEventTimeWindowCheckpointingITCase.java
@@ -51,6 +51,7 @@ import org.apache.flink.util.TestLogger;
import org.apache.curator.test.TestingServer;
import org.junit.After;
+import org.junit.Before;
import org.junit.ClassRule;
import org.junit.Rule;
import org.junit.Test;
@@ -87,6 +88,8 @@ public abstract class AbstractEventTimeWindowCheckpointingITCase extends TestLog
private TestingServer zkServer;
+ public MiniClusterResource miniClusterResource;
+
@ClassRule
public static TemporaryFolder tempFolder = new TemporaryFolder();
@@ -95,9 +98,6 @@ public abstract class AbstractEventTimeWindowCheckpointingITCase extends TestLog
private AbstractStateBackend stateBackend;
- @Rule
- public final MiniClusterResource miniClusterResource = getMiniClusterResource();
-
enum StateBackendEnum {
MEM, FILE, ROCKSDB_FULLY_ASYNC, ROCKSDB_INCREMENTAL, ROCKSDB_INCREMENTAL_ZK, MEM_ASYNC, FILE_ASYNC
}
@@ -201,8 +201,19 @@ public abstract class AbstractEventTimeWindowCheckpointingITCase extends TestLog
return config;
}
+ @Before
+ public void setupTestCluster() throws Exception {
+ miniClusterResource = getMiniClusterResource();
+ miniClusterResource.before();
+ }
+
@After
public void stopTestCluster() throws IOException {
+ if (miniClusterResource != null) {
+ miniClusterResource.after();
+ miniClusterResource = null;
+ }
+
if (zkServer != null) {
zkServer.stop();
zkServer = null;