correction hdfs pour hbase

jetoile · Jan 17, 2016 · 6bf2e19 · 6bf2e19
1 parent 21dc708
commit 6bf2e19
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 1 deletion.
diff --git a/src/main/java/fr/jetoile/sample/component/HBaseBootstrap.java b/src/main/java/fr/jetoile/sample/component/HBaseBootstrap.java
@@ -46,6 +46,10 @@ private void init() {
     }
 
     private void build() {
+        org.apache.hadoop.conf.Configuration hbaseConfiguration = new org.apache.hadoop.conf.Configuration();
+        hbaseConfiguration.setBoolean("hbase.table.sanity.checks", false);
+        hbaseConfiguration.set("fs.default.name", "hdfs://127.0.0.1:" + configuration.getString(ConfigVars.HDFS_NAMENODE_PORT_KEY));
+
         hbaseLocalCluster = new HbaseLocalCluster.Builder()
                 .setHbaseMasterPort(port)
                 .setHbaseMasterInfoPort(infoPort)
@@ -55,7 +59,7 @@ private void build() {
                 .setZookeeperConnectionString(zookeeperConnectionString)
                 .setZookeeperZnodeParent(zookeeperZnodeParent)
                 .setHbaseWalReplicationEnabled(enableWalReplication)
-                .setHbaseConfiguration(new org.apache.hadoop.conf.Configuration())
+                .setHbaseConfiguration(hbaseConfiguration)
                 .build();
     }
 

diff --git a/src/test/java/fr/jetoile/sample/component/HBaseBootstrapTest.java b/src/test/java/fr/jetoile/sample/component/HBaseBootstrapTest.java
@@ -24,6 +24,7 @@ public class HBaseBootstrapTest {
 
     static private Bootstrap zookeeper;
     static private Bootstrap hbase;
+    static private Bootstrap hdfs;
     static private Configuration configuration;
 
 
@@ -36,12 +37,14 @@ public static void setup() throws Exception {
         }
 
         zookeeper = ZookeeperBootstrap.INSTANCE.start();
+        hdfs = HdfsBootstrap.INSTANCE.start();
         hbase = HBaseBootstrap.INSTANCE.start();
     }
 
     @AfterClass
     public static void tearDown() throws Exception {
         hbase.stop();
+        hdfs.stop();
         zookeeper.stop();
     }