Merge pull request #8 from huafengw/update

fix #6 update HBaseSink
gearpump · Jan 28, 2016 · 9dc8efd · 9dc8efd
2 parents 39c90f5 + ebbe35a
commit 9dc8efd
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/pom.xml b/pom.xml
@@ -8,7 +8,7 @@
     <artifactId>streaming-java-template</artifactId>
     <version>1.2-SNAPSHOT</version>
     <properties>
-        <gearpumpVersion>0.6.2-SNAPSHOT</gearpumpVersion>
+        <gearpumpVersion>0.7.5</gearpumpVersion>
     </properties>
 
 

diff --git a/src/main/java/kafka/HBaseSinkTask.java b/src/main/java/kafka/HBaseSinkTask.java
@@ -50,7 +50,7 @@ public HBaseSinkTask(TaskContext taskContext, UserConfig userConf) {
     hbaseConf.set(ZOOKEEPER_QUORUM, zkQuorum);
 
 
-    sink = new HBaseSink(tableName, hbaseConf);
+    sink = new HBaseSink(userConf, tableName, hbaseConf);
   }
 
   @Override