From d4b49e91e0e6662bf42532814c4b564f124c338a Mon Sep 17 00:00:00 2001 From: "Miracle (Jian) Zhou" Date: Fri, 16 Jan 2015 17:39:42 -0500 Subject: [PATCH 1/2] correct problem reading configuration data --- .../org/apache/storm/hbase/trident/state/HBaseMapState.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/external/storm-hbase/src/main/java/org/apache/storm/hbase/trident/state/HBaseMapState.java b/external/storm-hbase/src/main/java/org/apache/storm/hbase/trident/state/HBaseMapState.java index 742206ba400..82cc3f818d8 100644 --- a/external/storm-hbase/src/main/java/org/apache/storm/hbase/trident/state/HBaseMapState.java +++ b/external/storm-hbase/src/main/java/org/apache/storm/hbase/trident/state/HBaseMapState.java @@ -75,7 +75,7 @@ public HBaseMapState(final Options options, Map map, int partitionNum) { 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))); } } From 6e04647258d8f5147448bdd8fbc7d6be08fc3a16 Mon Sep 17 00:00:00 2001 From: "Miracle (Jian) Zhou" Date: Fri, 16 Jan 2015 17:40:16 -0500 Subject: [PATCH 2/2] correct problem reading configuration data --- .../java/org/apache/storm/hbase/trident/state/HBaseState.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/external/storm-hbase/src/main/java/org/apache/storm/hbase/trident/state/HBaseState.java b/external/storm-hbase/src/main/java/org/apache/storm/hbase/trident/state/HBaseState.java index 20ff0d3d931..71ab7c44abb 100644 --- a/external/storm-hbase/src/main/java/org/apache/storm/hbase/trident/state/HBaseState.java +++ b/external/storm-hbase/src/main/java/org/apache/storm/hbase/trident/state/HBaseState.java @@ -107,7 +107,7 @@ protected void prepare() { 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))); } }