开发者社区> 问答> 正文

通过storm消费loghub日志的测试用例运行报错

ERROR|2017-05-27 16:41:17,941|10|11|1.2.3|com.aliyun.openservices.loghub.stormspout.LogHubSpout|activate(117)|failed to start the client to fetch data com.aliyun.openservices.loghub.client.exceptions.LogHubClientWorkerException: error occour when create consumer group, errorCode: Unauthorized, errorMessage: denied by sts or ram, action: log:CreateConsumerGroup, resource: acs:log:cn-beijing:1654109041909600:project/jike-test/logstore/log_teacher/consumergroup/conumser_group_1

at com.aliyun.openservices.loghub.client.ClientFetcher.<init>(ClientFetcher.java:83) ~[loghub-client-lib-0.6.7.jar:?]
at com.aliyun.openservices.loghub.stormspout.LogHubSpout.activate(LogHubSpout.java:109) [loghub-storm-1.0-spout-0.1.1.jar:?]
at org.apache.storm.daemon.executor$fn__4905$fn__4920$fn__4951.invoke(executor.clj:639) [storm-core-1.0.3.jar:1.0.3]
at org.apache.storm.util$async_loop$fn__557.invoke(util.clj:484) [storm-core-1.0.3.jar:1.0.3]
at clojure.lang.AFn.run(AFn.java:22) [clojure-1.7.0.jar:?]
at java.lang.Thread.run(Thread.java:745) [?:1.8.0_121]

ERROR|2017-05-27 16:41:30,674|10|11|1.2.3|org.apache.storm.shade.clojure.tools.logging$eval1$fn__7|invoke(0)|Async loop died! java.lang.NullPointerException

at com.aliyun.openservices.loghub.stormspout.LogHubSpout.nextTuple(LogHubSpout.java:142) ~[loghub-storm-1.0-spout-0.1.1.jar:?]
at org.apache.storm.daemon.executor$fn__4905$fn__4920$fn__4951.invoke(executor.clj:644) ~[storm-core-1.0.3.jar:1.0.3]
at org.apache.storm.util$async_loop$fn__557.invoke(util.clj:484) [storm-core-1.0.3.jar:1.0.3]
at clojure.lang.AFn.run(AFn.java:22) [clojure-1.7.0.jar:?]
at java.lang.Thread.run(Thread.java:745) [?:1.8.0_121]

ERROR|2017-05-27 16:41:30,677|10|11|1.2.3|org.apache.storm.shade.clojure.tools.logging$eval1$fn__7|invoke(0)| java.lang.NullPointerException

at com.aliyun.openservices.loghub.stormspout.LogHubSpout.nextTuple(LogHubSpout.java:142) ~[loghub-storm-1.0-spout-0.1.1.jar:?]
at org.apache.storm.daemon.executor$fn__4905$fn__4920$fn__4951.invoke(executor.clj:644) ~[storm-core-1.0.3.jar:1.0.3]
at org.apache.storm.util$async_loop$fn__557.invoke(util.clj:484) [storm-core-1.0.3.jar:1.0.3]
at clojure.lang.AFn.run(AFn.java:22) [clojure-1.7.0.jar:?]
at java.lang.Thread.run(Thread.java:745) [?:1.8.0_121]

ERROR|2017-05-27 16:41:30,788|10|11|1.2.3|org.apache.storm.shade.clojure.tools.logging$eval1$fn__7|invoke(0)|Halting process: ("Worker died") java.lang.RuntimeException: ("Worker died")

at org.apache.storm.util$exit_process_BANG_.doInvoke(util.clj:341) [storm-core-1.0.3.jar:1.0.3]
at clojure.lang.RestFn.invoke(RestFn.java:423) [clojure-1.7.0.jar:?]
at org.apache.storm.daemon.worker$fn__5571$fn__5572.invoke(worker.clj:759) [storm-core-1.0.3.jar:1.0.3]
at org.apache.storm.daemon.executor$mk_executor_data$fn__4792$fn__4793.invoke(executor.clj:274) [storm-core-1.0.3.jar:1.0.3]
at org.apache.storm.util$async_loop$fn__557.invoke(util.clj:494) [storm-core-1.0.3.jar:1.0.3]
at clojure.lang.AFn.run(AFn.java:22) [clojure-1.7.0.jar:?]
at java.lang.Thread.run(Thread.java:745) [?:1.8.0_121]

展开
收起
大饼小不小 2017-05-27 14:09:26 5964 0
1 条回答
写回答
取消 提交回答
  • 请问这是什么问题呢,刚学习使用,请拍砖


    添加日志信息后,显示
    failed to start the client to fetch data com.aliyun.openservices.loghub.client.exceptions.LogHubClientWorkerException: error occour when create consumer group,这是什么原因呢

    2019-07-17 21:13:38
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

更多
PostgresChina2018_赖思超_PostgreSQL10_hash索引的WAL日志修改版final 立即下载
Kubernetes下日志实时采集、存储与计算实践 立即下载
日志数据采集与分析对接 立即下载