correct problem reading configuration data Project: http://git-wip-us.apache.org/repos/asf/storm/repo Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/6e046472 Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/6e046472 Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/6e046472
Branch: refs/heads/master Commit: 6e04647258d8f5147448bdd8fbc7d6be08fc3a16 Parents: d4b49e9 Author: Miracle (Jian) Zhou <[email protected]> Authored: Fri Jan 16 17:40:16 2015 -0500 Committer: Miracle (Jian) Zhou <[email protected]> Committed: Fri Jan 16 17:40:16 2015 -0500 ---------------------------------------------------------------------- .../main/java/org/apache/storm/hbase/trident/state/HBaseState.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/storm/blob/6e046472/external/storm-hbase/src/main/java/org/apache/storm/hbase/trident/state/HBaseState.java ---------------------------------------------------------------------- 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 20ff0d3..71ab7c4 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 @@ public class HBaseState implements State { 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))); } }
