风暴三叉戟hdfs螺栓抛出错误

ssgvzors  于 2021-06-03  发布在  Hadoop
关注(0)|答案(0)|浏览(178)

storm trident topology在尝试将消息写入hdfs时,尝试将jms文本消息从trident jms喷口发送到trident hdfs bolt时抛出如下错误。
有没有人遇到过这种错误?如果你面对它,你认为这是什么?

25518 [Thread-86-b-0] ERROR backtype.storm.util - Async loop died!
java.lang.RuntimeException: java.lang.NullPointerException
    at     backtype.storm.utils.DisruptorQueue.consumeBatchToCursor(DisruptorQueue.java:107) ~[storm-core-0.9.1.2.1.3.0-563.jar:0.9.1.2.1.3.0-563]
    at backtype.storm.utils.DisruptorQueue.consumeBatchWhenAvailable(DisruptorQueue.java:78) ~[storm-core-0.9.1.2.1.3.0-563.jar:0.9.1.2.1.3.0-563]
    at backtype.storm.disruptor$consume_batch_when_available.invoke(disruptor.clj:77) ~[storm-core-0.9.1.2.1.3.0-563.jar:0.9.1.2.1.3.0-563]
    at backtype.storm.daemon.executor$fn__5870$fn__5882$fn__5929.invoke(executor.clj:745) ~[storm-core-0.9.1.2.1.3.0-563.jar:0.9.1.2.1.3.0-563]
    at backtype.storm.util$async_loop$fn__442.invoke(util.clj:436) ~[storm-core-0.9.1.2.1.3.0-563.jar:0.9.1.2.1.3.0-563]
    at clojure.lang.AFn.run(AFn.java:24) [clojure-1.4.0.jar:na]
    at java.lang.Thread.run(Thread.java:744) [na:1.7.0_45]
Caused by: java.lang.NullPointerException: null
    at org.apache.storm.hdfs.trident.format.DelimitedRecordFormat.format(DelimitedRecordFormat.java:73) ~[StormTridentXml-0.0.1-SNAPSHOT.jar:na]
    at org.apache.storm.hdfs.trident.HdfsState$HdfsFileOptions.execute(HdfsState.java:193) ~[StormTridentXml-0.0.1-SNAPSHOT.jar:na]
    at org.apache.storm.hdfs.trident.HdfsState.updateState(HdfsState.java:328) ~[StormTridentXml-0.0.1-SNAPSHOT.jar:na]
    at org.apache.storm.hdfs.trident.HdfsUpdater.updateState(HdfsUpdater.java:29) ~[StormTridentXml-0.0.1-SNAPSHOT.jar:na]
    at org.apache.storm.hdfs.trident.HdfsUpdater.updateState(HdfsUpdater.java:26) ~[StormTridentXml-0.0.1-SNAPSHOT.jar:na]
    at storm.trident.planner.processor.PartitionPersistProcessor.finishBatch(PartitionPersistProcessor.java:98) ~[storm-core-0.9.1.2.1.3.0-563.jar:0.9.1.2.1.3.0-563]
    at storm.trident.planner.SubtopologyBolt.finishBatch(SubtopologyBolt.java:152) ~[storm-core-0.9.1.2.1.3.0-563.jar:0.9.1.2.1.3.0-563]
    at storm.trident.topology.TridentBoltExecutor.finishBatch(TridentBoltExecutor.java:252) ~[storm-core-0.9.1.2.1.3.0-563.jar:0.9.1.2.1.3.0-563]
    at storm.trident.topology.TridentBoltExecutor.checkFinish(TridentBoltExecutor.java:285) ~[storm-core-0.9.1.2.1.3.0-563.jar:0.9.1.2.1.3.0-563]
    at storm.trident.topology.TridentBoltExecutor.execute(TridentBoltExecutor.java:359) ~[storm-core-0.9.1.2.1.3.0-563.jar:0.9.1.2.1.3.0-563]
    at backtype.storm.daemon.executor$fn__5870$tuple_action_fn__5872.invoke(executor.clj:630) ~[storm-core-0.9.1.2.1.3.0-563.jar:0.9.1.2.1.3.0-563]
    at backtype.storm.daemon.executor$mk_task_receiver$fn__5793.invoke(executor.clj:398) ~[storm-core-0.9.1.2.1.3.0-563.jar:0.9.1.2.1.3.0-563]
    at backtype.storm.disruptor$clojure_handler$reify__2793.onEvent(disruptor.clj:58) ~[storm-core-0.9.1.2.1.3.0-563.jar:0.9.1.2.1.3.0-563]
    at backtype.storm.utils.DisruptorQueue.consumeBatchToCursor(DisruptorQueue.java:104) ~[storm-core-0.9.1.2.1.3.0-563.jar:0.9.1.2.1.3.0-563]
    ... 6 common frames omitted

我们的storm版本是0.9.1.2.1.3.0-563
风暴hdfs为0.9.4

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题