[STORM-627] Storm-hbase configuration error

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 0.9.3
• Fix Version/s: 0.10.0
• Component/s: storm-hbase
• Assignee: JIAN ZHOU
• Reporter: JIAN ZHOU
• Created: 14/Jan/15 23:48
• Updated: 01/Jun/15 21:40
• Resolved: 16/Jan/15 23:53

Description

The HBaseMapState and HBaseState classes are not reading the configuration entries properly. The code reads from the "map" entries instead of the "conf" entries in the code referenced below, which is incorrect.

Details and suggested fix:

org/apache/storm/hbase/trident/state/HBaseMapState.java
line 78:
– hbConfig.set(key, String.valueOf(map.get(key)));
++ hbConfig.set(key, String.valueOf(conf.get(key)));

org/apache/storm/hbase/trident/state/HBaseState.java
line 108:
– hbConfig.set(key, String.valueOf(map.get(key)));
++ hbConfig.set(key, String.valueOf(conf.get(key)));

Note: it seems that a similar bug was fixed in a different file in ptgoetz/storm-hbase (https://github.com/ptgoetz/storm-hbase/commit/39797ac6914d042051d6f4504edb6e01998bccf3), but these two java files still have it.