[1/2] beam git commit: Make HBaseIO tests faster by only using the core daemons needed by HBase

[iemejia]

Repository: beam
Updated Branches:
  refs/heads/master b400f4a6f -> c6c8d9ee6


Make HBaseIO tests faster by only using the core daemons needed by HBase


Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/6d272825
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/6d272825
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/6d272825

Branch: refs/heads/master
Commit: 6d27282562911179ea3ff19fd7eae54e8b89425d
Parents: b400f4a
Author: Ismaël Mejía <ieme...@apache.org>
Authored: Mon Jun 19 16:43:28 2017 +0200
Committer: Ismaël Mejía <ieme...@apache.org>
Committed: Mon Jun 19 23:22:52 2017 +0200

----------------------------------------------------------------------
 .../java/org/apache/beam/sdk/io/hbase/HBaseIOTest.java   | 11 +++++++++--
 1 file changed, 9 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/beam/blob/6d272825/sdks/java/io/hbase/src/test/java/org/apache/beam/sdk/io/hbase/HBaseIOTest.java
----------------------------------------------------------------------
diff --git 
a/sdks/java/io/hbase/src/test/java/org/apache/beam/sdk/io/hbase/HBaseIOTest.java
 
b/sdks/java/io/hbase/src/test/java/org/apache/beam/sdk/io/hbase/HBaseIOTest.java
index 4a06789..005770d 100644
--- 
a/sdks/java/io/hbase/src/test/java/org/apache/beam/sdk/io/hbase/HBaseIOTest.java
+++ 
b/sdks/java/io/hbase/src/test/java/org/apache/beam/sdk/io/hbase/HBaseIOTest.java
@@ -47,6 +47,7 @@ import org.apache.hadoop.hbase.HBaseTestingUtility;
 import org.apache.hadoop.hbase.HColumnDescriptor;
 import org.apache.hadoop.hbase.HConstants;
 import org.apache.hadoop.hbase.HTableDescriptor;
+import org.apache.hadoop.hbase.MiniHBaseCluster;
 import org.apache.hadoop.hbase.TableName;
 import org.apache.hadoop.hbase.client.BufferedMutator;
 import org.apache.hadoop.hbase.client.Connection;
@@ -96,7 +97,12 @@ public class HBaseIOTest {
         conf.setStrings("hbase.master.hostname", "localhost");
         conf.setStrings("hbase.regionserver.hostname", "localhost");
         htu = new HBaseTestingUtility(conf);
-        htu.startMiniCluster(1, 4);
+
+        // We don't use the full htu.startMiniCluster() to avoid starting 
unneeded HDFS/MR daemons
+        htu.startMiniZKCluster();
+        MiniHBaseCluster hbm = htu.startMiniHBaseCluster(1, 4);
+        hbm.waitForActiveAndReadyMaster();
+
         admin = htu.getHBaseAdmin();
     }
 
@@ -107,7 +113,8 @@ public class HBaseIOTest {
             admin = null;
         }
         if (htu != null) {
-            htu.shutdownMiniCluster();
+            htu.shutdownMiniHBaseCluster();
+            htu.shutdownMiniZKCluster();
             htu = null;
         }
     }