java - 找不到Storm Hbase配置

因此，我建立了一个来自kafka的 Storm 喷口，并用 bolt 写入HDFS。这一切都很好。现在，我想添加一个写入Hbase的新 bolt 。由于某些原因，我的应用程序未获取hbase配置资料，并且出现以下错误:

            java.lang.IllegalArgumentException: HBase configuration not found using key 'null'
                    at org.apache.storm.hbase.bolt.AbstractHBaseBolt.prepare(AbstractHBaseBolt.java:58) ~[storm-hbase-0.9.3.2.2.0.0-2041.jar:0.9.3.2.2.0.0-2041]
                    at backtype.storm.daemon.executor$fn__5697$fn__5710.invoke(executor.clj:732) ~[storm-core-0.9.3.2.2.0.0-2041.jar:0.9.3.2.2.0.0-2041]
                    at backtype.storm.util$async_loop$fn__452.invoke(util.clj:463) ~[storm-core-0.9.3.2.2.0.0-2041.jar:0.9.3.2.2.0.0-2041]
                    at clojure.lang.AFn.run(AFn.java:24) [clojure-1.5.1.jar:na]
                    at java.lang.Thread.run(Thread.java:745) [na:1.7.0_71]
            2015-04-16 02:05:44 b.s.d.executor [ERROR]
            java.lang.IllegalArgumentException: HBase configuration not found using key 'null'
                    at org.apache.storm.hbase.bolt.AbstractHBaseBolt.prepare(AbstractHBaseBolt.java:58) ~[storm-hbase-0.9.3.2.2.0.0-2041.jar:0.9.3.2.2.0.0-2041]
                    at backtype.storm.daemon.executor$fn__5697$fn__5710.invoke(executor.clj:732) ~[storm-core-0.9.3.2.2.0.0-2041.jar:0.9.3.2.2.0.0-2041]
                    at backtype.storm.util$async_loop$fn__452.invoke(util.clj:463) ~[storm-core-0.9.3.2.2.0.0-2041.jar:0.9.3.2.2.0.0-2041]
                    at clojure.lang.AFn.run(AFn.java:24) [clojure-1.5.1.jar:na]
                    at java.lang.Thread.run(Thread.java:745) [na:1.7.0_71]
            2015-04-16 02:05:44 o.a.h.u.NativeCodeLoader [WARN] Unable to load native-hadoop library for your platform... using builtin-java classes where applicable
            2015-04-16 02:05:44 b.s.util [ERROR] Halting process: ("Worker died")
            java.lang.RuntimeException: ("Worker died")
                    at backtype.storm.util$exit_process_BANG_.doInvoke(util.clj:322) [storm-core-0.9.3.2.2.0.0-2041.jar:0.9.3.2.2.0.0-2041]
                    at clojure.lang.RestFn.invoke(RestFn.java:423) [clojure-1.5.1.jar:na]
                    at backtype.storm.daemon.worker$fn__6109$fn__6110.invoke(worker.clj:495) [storm-core-0.9.3.2.2.0.0-2041.jar:0.9.3.2.2.0.0-2041]
                    at backtype.storm.daemon.executor$mk_executor_data$fn__5530$fn__5531.invoke(executor.clj:245) [storm-core-0.9.3.2.2.0.0-2041.jar:0.9.3.2.2.0.0-2041]
                    at backtype.storm.util$async_loop$fn__452.invoke(util.clj:475) [storm-core-0.9.3.2.2.0.0-2041.jar:0.9.3.2.2.0.0-2041]
                    at clojure.lang.AFn.run(AFn.java:24) [clojure-1.5.1.jar:na]
                    at java.lang.Thread.run(Thread.java:745) [na:1.7.0_71]

当我查看代码时，它显示了发生错误的以下块:

           public void prepare(Map map, TopologyContext topologyContext, OutputCollector collector) {
                this.collector = collector;
                final Configuration hbConfig = HBaseConfiguration.create();

                Map<String, Object> conf = (Map<String, Object>)map.get(this.configKey);
                if(conf == null) {
                    throw new IllegalArgumentException("HBase configuration not found using key '" + this.configKey + "'");
                }

看起来configKey没被设置，所以我尝试将其设置为HBaseBolt方法，如下所示:

    SimpleHBaseMapper mapper = new SimpleHBaseMapper()
    .withRowKeyField("CustomerId")
    .withColumnFields(new Fields("CustomerId"))
    .withCounterFields(new Fields("Count"))
    .withColumnFamily("cf1");

    HBaseBolt hbase = new HBaseBolt("Customer", mapper).withConfigKey("/etc/hbase/conf/hbase-site.xml");
    builder.setBolt("HBASE_BOLT", hbase, 1)
    .fieldsGrouping("stormspout", new Fields("CustomerId"));

似乎没有执行任何操作，因为我仍然遇到相同的错误...。
有人有什么建议吗？感觉就像只是没有拿起我的hbase-site.xml文件，但我不确定为什么不...

最佳答案

经过大量的工作，我终于让它工作了!!

在您的拓扑createConfig方法中，添加

    Map<String, String> HBConfig = Maps.newHashMap();
    HBConfig.put("hbase.rootdir","hdfs://<IP Address>:8020/hbase");
    conf.put("HBCONFIG",HBConfig);

实例化HBaseBolt时，请使用
.withConfigKey(“HBCONFIG”)