You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by sr...@apache.org on 2015/01/17 00:50:48 UTC
[2/3] storm git commit: correct problem reading configuration data
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 <ms...@users.noreply.github.com>
Authored: Fri Jan 16 17:40:16 2015 -0500
Committer: Miracle (Jian) Zhou <ms...@users.noreply.github.com>
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)));
}
}