老师 这个是jar版本的问题吗

来源:12-9 -Storm整合Kafka功能开发

啊大bug

2020-08-14

01:35:32.006 [Thread-36-KafkaSpout-executor[1, 1]] ERROR o.a.s.u.Utils - Async loop died!
java.lang.NoSuchMethodError: org.apache.storm.utils.Utils.getInt(Ljava/lang/Object;)Ljava/lang/Integer;
at org.apache.storm.kafka.ZkState.newCurator(ZkState.java:46) ~[storm-kafka-1.1.1.jar:1.1.1]
at org.apache.storm.kafka.ZkState.(ZkState.java:61) ~[storm-kafka-1.1.1.jar:1.1.1]
at org.apache.storm.kafka.KafkaSpout.open(KafkaSpout.java:76) ~[storm-kafka-1.1.1.jar:1.1.1]
at org.apache.storm.executor.spout.SpoutExecutor.init(SpoutExecutor.java:148) ~[storm-client-2.0.0.jar:2.0.0]
at org.apache.storm.executor.spout.SpoutExecutor.call(SpoutExecutor.java:158) ~[storm-client-2.0.0.jar:2.0.0]
at org.apache.storm.executor.spout.SpoutExecutor.call(SpoutExecutor.java:55) ~[storm-client-2.0.0.jar:2.0.0]
at org.apache.storm.utils.Utils$1.run(Utils.java:383) [storm-client-2.0.0.jar:2.0.0]
at java.lang.Thread.run(Thread.java:745) [?:1.8.0_101]
01:35:32.012 [Thread-36-KafkaSpout-executor[1, 1]] ERROR o.a.s.e.e.ReportError - Error
java.lang.RuntimeException: java.lang.NoSuchMethodError: org.apache.storm.utils.Utils.getInt(Ljava/lang/Object;)Ljava/lang/Integer;
at org.apache.storm.utils.Utils$1.run(Utils.java:403) ~[storm-client-2.0.0.jar:2.0.0]
at java.lang.Thread.run(Thread.java:745) [?:1.8.0_101]
Caused by: java.lang.NoSuchMethodError: org.apache.storm.utils.Utils.getInt(Ljava/lang/Object;)Ljava/lang/Integer;
at org.apache.storm.kafka.ZkState.newCurator(ZkState.java:46) ~[storm-kafka-1.1.1.jar:1.1.1]
at org.apache.storm.kafka.ZkState.(ZkState.java:61) ~[storm-kafka-1.1.1.jar:1.1.1]
at org.apache.storm.kafka.KafkaSpout.open(KafkaSpout.java:76) ~[storm-kafka-1.1.1.jar:1.1.1]
at org.apache.storm.executor.spout.SpoutExecutor.init(SpoutExecutor.java:148) ~[storm-client-2.0.0.jar:2.0.0]
at org.apache.storm.executor.spout.SpoutExecutor.call(SpoutExecutor.java:158) ~[storm-client-2.0.0.jar:2.0.0]
at org.apache.storm.executor.spout.SpoutExecutor.call(SpoutExecutor.java:55) ~[storm-client-2.0.0.jar:2.0.0]
at org.apache.storm.utils.Utils$1.run(Utils.java:383) ~[storm-client-2.0.0.jar:2.0.0]
… 1 more
01:35:32.017 [Thread-33-__system-executor[-1, -1]] WARN o.a.s.m.c.CGroupMetricsBase - CGroupMemoryLimit is disabled. cgroups do not appear to be enabled on this system
01:35:32.018 [Thread-33-__system-executor[-1, -1]] WARN o.a.s.m.c.CGroupMetricsBase - CGroupMemoryUsage is disabled. cgroups do not appear to be enabled on this system
01:35:32.019 [Thread-33-__system-executor[-1, -1]] WARN o.a.s.m.c.CGroupMetricsBase - CGroupCpu is disabled. cgroups do not appear to be enabled on this system
01:35:32.020 [Thread-33-__system-executor[-1, -1]] WARN o.a.s.m.c.CGroupMetricsBase - CGroupCpuGuarantee is disabled. cgroups do not appear to be enabled on this system
01:35:32.020 [Thread-33-__system-executor[-1, -1]] INFO o.a.s.e.b.BoltExecutor - Prepared bolt __system:[-1]
01:35:32.022 [SLOT_1027] INFO o.a.s.d.s.Slot - STATE waiting-for-worker-start msInState: 13 topo:StormKafkaTopo-1-1597340128 worker:e8e8c4ae-cd1f-4bbb-8a63-7eb9cbfe78d8 -> running msInState: 0 topo:StormKafkaTopo-1-1597340128 worker:e8e8c4ae-cd1f-4bbb-8a63-7eb9cbfe78d8
01:35:32.024 [Thread-36-KafkaSpout-executor[1, 1]] ERROR o.a.s.u.Utils - Halting process: Worker died
java.lang.RuntimeException: Halting process: Worker died
at org.apache.storm.utils.Utils.exitProcess(Utils.java:508) [storm-client-2.0.0.jar:2.0.0]
at org.apache.storm.utils.Utils$3.run(Utils.java:804) [storm-client-2.0.0.jar:2.0.0]
at org.apache.storm.executor.error.ReportErrorAndDie.uncaughtException(ReportErrorAndDie.java:41) [storm-client-2.0.0.jar:2.0.0]
at java.lang.Thread.dispatchUncaughtException(Thread.java:1952) [?:1.8.0_101]

Process finished with exit code 1

写回答

2回答

Michael_PK

2020-08-14

你代码util地方点进去看看是不是没有报错的方法名,或者是参数不匹配了,问题应该出在这里

0
0

Michael_PK

2020-08-14

java.lang.NoSuchMethodError: org.apache.storm.utils.Utils.getInt(Ljava/lang/Object;)Ljava/lang/Integer;
at org.apache.storm.kafka.ZkState.newCurator(ZkState.java:46) ~[storm-kafka-1.1.1.jar:1.1.1]这句话的nosuch....基本就是版本冲突

0
3
啊大bug
好的,谢谢老师
2020-08-14
共3条回复

Java大数据实战,巧用Storm快速切入实时流处理领域

深入Storm内部机制,logstash+kafka,快速切入大数据实时流处理

518 学习 · 143 问题

查看课程