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 2019/06/25 11:55:14 UTC
[flink] branch master updated: [FLINK-12915][tests] Don't reuse
minicluster in AbstractOperatorRestoreTestBase
This is an automated email from the ASF dual-hosted git repository.
chesnay pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/master by this push:
new 08d8cf5 [FLINK-12915][tests] Don't reuse minicluster in AbstractOperatorRestoreTestBase
08d8cf5 is described below
commit 08d8cf5b8dff8193c69c5dd3657112ce862054ea
Author: Yun Tang <my...@live.com>
AuthorDate: Tue Jun 25 19:55:02 2019 +0800
[FLINK-12915][tests] Don't reuse minicluster in AbstractOperatorRestoreTestBase
---
.../state/operator/restore/AbstractOperatorRestoreTestBase.java | 7 +++----
1 file changed, 3 insertions(+), 4 deletions(-)
diff --git a/flink-tests/src/test/java/org/apache/flink/test/state/operator/restore/AbstractOperatorRestoreTestBase.java b/flink-tests/src/test/java/org/apache/flink/test/state/operator/restore/AbstractOperatorRestoreTestBase.java
index 0b79af5..c857421 100644
--- a/flink-tests/src/test/java/org/apache/flink/test/state/operator/restore/AbstractOperatorRestoreTestBase.java
+++ b/flink-tests/src/test/java/org/apache/flink/test/state/operator/restore/AbstractOperatorRestoreTestBase.java
@@ -39,7 +39,6 @@ import org.apache.flink.util.ExceptionUtils;
import org.apache.flink.util.TestLogger;
import org.junit.BeforeClass;
-import org.junit.ClassRule;
import org.junit.Rule;
import org.junit.Test;
import org.junit.rules.TemporaryFolder;
@@ -70,8 +69,8 @@ public abstract class AbstractOperatorRestoreTestBase extends TestLogger {
@Rule
public final TemporaryFolder tmpFolder = new TemporaryFolder();
- @ClassRule
- public static final MiniClusterWithClientResource MINI_CLUSTER_RESOURCE = new MiniClusterWithClientResource(
+ @Rule
+ public final MiniClusterWithClientResource cluster = new MiniClusterWithClientResource(
new MiniClusterResourceConfiguration.Builder()
.setNumberTaskManagers(NUM_TMS)
.setNumberSlotsPerTaskManager(NUM_SLOTS_PER_TM)
@@ -95,7 +94,7 @@ public abstract class AbstractOperatorRestoreTestBase extends TestLogger {
@Test
public void testMigrationAndRestore() throws Throwable {
ClassLoader classLoader = this.getClass().getClassLoader();
- ClusterClient<?> clusterClient = MINI_CLUSTER_RESOURCE.getClusterClient();
+ ClusterClient<?> clusterClient = cluster.getClusterClient();
clusterClient.setDetached(true);
final Deadline deadline = Deadline.now().plus(TEST_TIMEOUT);