You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by pt...@apache.org on 2014/10/02 01:07:37 UTC
[17/26] git commit: fix HBase configuration bug
fix HBase configuration bug
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/39797ac6
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/39797ac6
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/39797ac6
Branch: refs/heads/master
Commit: 39797ac6914d042051d6f4504edb6e01998bccf3
Parents: 20c4565
Author: P. Taylor Goetz <pt...@gmail.com>
Authored: Tue Jul 29 14:17:13 2014 -0400
Committer: P. Taylor Goetz <pt...@gmail.com>
Committed: Tue Jul 29 14:17:13 2014 -0400
----------------------------------------------------------------------
src/main/java/org/apache/storm/hbase/bolt/HBaseBolt.java | 2 +-
.../java/org/apache/storm/hbase/trident/state/HBaseMapState.java | 1 -
2 files changed, 1 insertion(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/39797ac6/src/main/java/org/apache/storm/hbase/bolt/HBaseBolt.java
----------------------------------------------------------------------
diff --git a/src/main/java/org/apache/storm/hbase/bolt/HBaseBolt.java b/src/main/java/org/apache/storm/hbase/bolt/HBaseBolt.java
index ceee25f..b6fc423 100644
--- a/src/main/java/org/apache/storm/hbase/bolt/HBaseBolt.java
+++ b/src/main/java/org/apache/storm/hbase/bolt/HBaseBolt.java
@@ -86,7 +86,7 @@ public class HBaseBolt extends BaseRichBolt {
LOG.warn("No 'hbase.rootdir' value found in configuration! Using HBase defaults.");
}
for(String key : conf.keySet()){
- hbConfig.set(key, String.valueOf(map.get(key)));
+ hbConfig.set(key, String.valueOf(conf.get(key)));
}
try{
http://git-wip-us.apache.org/repos/asf/storm/blob/39797ac6/src/main/java/org/apache/storm/hbase/trident/state/HBaseMapState.java
----------------------------------------------------------------------
diff --git a/src/main/java/org/apache/storm/hbase/trident/state/HBaseMapState.java b/src/main/java/org/apache/storm/hbase/trident/state/HBaseMapState.java
index 832b8df..c8b345a 100644
--- a/src/main/java/org/apache/storm/hbase/trident/state/HBaseMapState.java
+++ b/src/main/java/org/apache/storm/hbase/trident/state/HBaseMapState.java
@@ -86,7 +86,6 @@ public class HBaseMapState<T> implements IBackingMap<T> {
public String tableName;
public String columnFamily;
public String qualifier;
-
}