diff --git a/project.clj b/project.clj index 06c08fa..e06c4cf 100644 --- a/project.clj +++ b/project.clj @@ -1,4 +1,4 @@ -(defproject com.twitter/maple "0.2.2" +(defproject com.twitter/maple "0.2.3-SNAPSHOT" :source-path "src/clj" :java-source-path "src/jvm" :description "All the Cascading taps we have to offer." diff --git a/src/jvm/com/twitter/maple/hbase/HBaseTap.java b/src/jvm/com/twitter/maple/hbase/HBaseTap.java index 15f4936..f001859 100644 --- a/src/jvm/com/twitter/maple/hbase/HBaseTap.java +++ b/src/jvm/com/twitter/maple/hbase/HBaseTap.java @@ -23,6 +23,7 @@ import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.fs.Path; import org.apache.hadoop.hbase.*; +import org.apache.hadoop.hbase.HConstants; import org.apache.hadoop.hbase.client.HBaseAdmin; import org.apache.hadoop.hbase.mapreduce.TableOutputFormat; import org.apache.hadoop.mapred.FileInputFormat; @@ -144,6 +145,11 @@ public void sinkConfInit(FlowProcess process, JobConf conf) { if(quorumNames != null) { conf.set("hbase.zookeeper.quorum", quorumNames); } + else { + Configuration hbaseConfig = HBaseConfiguration.create(conf); + conf.set(HConstants.ZOOKEEPER_QUORUM, hbaseConfig.get(HConstants.ZOOKEEPER_QUORUM)); + conf.set(HConstants.ZOOKEEPER_ZNODE_PARENT, hbaseConfig.get(HConstants.ZOOKEEPER_ZNODE_PARENT)); + } LOG.debug("sinking to table: {}", tableName);