开发者社区> 问答> 正文

Java编写storm程序报错,放在本地正常运行,放到集群中运行报错,ambar?400报错

spout端报错:

java.lang.NoClassDefFoundError: org/json/simple/JSONValue

at torm.kafka.DynamicBrokersReader.getLeaderFo(DynamicBrokersReader.java:117

at-storm.kafka.DynamicBrokersReader.getBrokerInfo(DynamicBrokersReader.java:68)

at storm.kafka.trident.ZkBrokerReader.<init>(ZkBrokerReader.java:42)

at storm.kafka.KafkaUtils.makeBrokerReader(KafkaUtils.java:57)
at storm.kafka.KafkaSpout.open(KafkaSpout.java:87)
at org.apache.storm.daemon.executor$fn__6505$fn__6520.invoke(executor.clj:607)
at org.apache.storm.util$async_loop$fn__554.invoke(util.clj:482)
at clojure.lang.AFn.run(AFn.java:22)

at java.lang.Thread.run(Thread.java:748)
Caused by: java.lang.ClassNotFoundException: org.json.simple.JSONValue

at java.net.URLClassLoader.findClass(URLClassLoader.java:381)

at java.lang.ClassLoader.loadClass(ClassLoader.java:424)

at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:335)
at java.lang.ClassLoader.loadClass(ClassLoader.java:357) ... 9 more

bolt:
java.lang.ExceptionInInitializerError

at kafka.metrics.KafkaMetricsGroup$class.newMeter(KafkaMetricsGroup.scala:79)

at kafka.producer.ProducerStats.newMeter(ProducerStats.scala:23)

at kafka.producer.ProducerStats.<init>(ProducerStats.scala:25)

at kafka.producer.ProducerStatsRegistry$$anonfun$1.apply(ProducerStats.scala:34) at kafka.producer.ProducerStatsRegistry$$anonfun$1.apply(ProducerStats.scala:34) at kafka.utils.Pool.getAndMaybePut(Pool.scala:61)

at kafka.producer.ProducerStatsRegistry$.getProducerStats(ProducerStats.scala:38) at kafka.producer.async.DefaultEventHandler.<init>(DefaultEventHandler.scala:48) at kafka.producer.Producer.<init>(Producer.scala:60)

at kafka.javaapi.producer.Producer.<init>(Producer.scala:26)

at storm.kafka.bolt.KafkaBolt.prepare(KafkaBolt.java:86)

at org.apache.storm.daemon.executor$fn__6573$fn__6586.invoke(executor.clj:798) at org.apache.storm.util$async_loop$fn__554.invoke(util.clj:482)

at clojure.lang.AFn.run(AFn.java:22)

at java.lang.Thread.run(Thread.java:748)

Caused by: java.lang.IllegalStateException: Shutdown in progress

at java.lang.ApplicationShutdownHooks.add(ApplicationShutdownHooks.java:66)

at java.lang.Runtime.addShutdownHook(Runtime.java:211)

at com.yammer.metrics.Metrics.<clinit>(Metrics.java:21) ... 15 more

展开
收起
爱吃鱼的程序员 2020-06-07 17:08:17 669 0
1 条回答
写回答
取消 提交回答
  • https://developer.aliyun.com/profile/5yerqm5bn5yqg?spm=a2c6h.12873639.0.0.6eae304abcjaIB
                        <p>Java一处编译,到处报错!</p>
    
                    
    
                        <p>兄弟,对于你发的日志,我看都不想看~~~~~~~~~能不能分个行???</p>
    
                    
    
                        <p>这是因为确实了一个simple的json包</p>
    
    2020-06-07 17:08:28
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

更多
Spring Cloud Alibaba - 重新定义 Java Cloud-Native 立即下载
The Reactive Cloud Native Arch 立即下载
JAVA开发手册1.5.0 立即下载