From 9a40160aa1030380d0454ed777c0b208d3b3e236 Mon Sep 17 00:00:00 2001 From: Mike Drob Date: Tue, 5 Dec 2017 14:25:37 -0600 Subject: [PATCH] HBASE-19289 Make DFS Cluster available when we need flush/sync --- .../hbase/regionserver/MiniDFSClusterResource.java | 26 ++++++++++++++++++++++ .../hadoop/hbase/regionserver/TestHStore.java | 2 ++ 2 files changed, 28 insertions(+) create mode 100644 hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/MiniDFSClusterResource.java diff --git a/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/MiniDFSClusterResource.java b/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/MiniDFSClusterResource.java new file mode 100644 index 0000000000..5a2a284d3f --- /dev/null +++ b/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/MiniDFSClusterResource.java @@ -0,0 +1,26 @@ +package org.apache.hadoop.hbase.regionserver; + +import org.apache.hadoop.hbase.HBaseTestingUtility; +import org.junit.rules.ExternalResource; + +public class MiniDFSClusterResource extends ExternalResource { + private final HBaseTestingUtility util; + + public MiniDFSClusterResource(HBaseTestingUtility util) { + this.util = util; + } + + @Override + protected void before() throws Throwable { + util.startMiniDFSCluster(1); + } + + @Override + protected void after() { + try { + util.shutdownMiniDFSCluster(); + } catch (Exception e) { + throw new RuntimeException(e); + } + } +} diff --git a/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestHStore.java b/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestHStore.java index 39ed9dfa5b..0dd6873b8a 100644 --- a/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestHStore.java +++ b/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestHStore.java @@ -150,6 +150,8 @@ public class TestHStore { private static final HBaseTestingUtility TEST_UTIL = new HBaseTestingUtility(); private static final String DIR = TEST_UTIL.getDataTestDir("TestStore").toString(); + @org.junit.ClassRule + public static final MiniDFSClusterResource r = new MiniDFSClusterResource(TEST_UTIL); /** * Setup -- 2.15.0