Repository: storm Updated Branches: refs/heads/master 49553518d -> c7feb1845
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/d4b49e91 Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/d4b49e91 Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/d4b49e91 Branch: refs/heads/master Commit: d4b49e91e0e6662bf42532814c4b564f124c338a Parents: 4955351 Author: Miracle (Jian) Zhou <[email protected]> Authored: Fri Jan 16 17:39:42 2015 -0500 Committer: Miracle (Jian) Zhou <[email protected]> Committed: Fri Jan 16 17:39:42 2015 -0500 ---------------------------------------------------------------------- .../java/org/apache/storm/hbase/trident/state/HBaseMapState.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/storm/blob/d4b49e91/external/storm-hbase/src/main/java/org/apache/storm/hbase/trident/state/HBaseMapState.java ---------------------------------------------------------------------- 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 742206b..82cc3f8 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 class HBaseMapState<T> implements IBackingMap<T> { 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))); } }
