java - Storm : java. lang.NullPointerException: null

Question

在向集群提交 Storm 拓扑时，我收到此错误。

6653 [main] INFO  backtype.storm.daemon.supervisor - Starting supervisor with id 8ee90770-957a-40c7-a70b-fd7399cab6a1 at host Ritesh-RM
6706 [main] INFO  backtype.storm.StormSubmitter - Jar not uploaded to master yet. Submitting jar...
6711 [main] INFO  backtype.storm.StormSubmitter - Uploading topology jar /home/ubuntu/apache-storm-0.9.4/lib/StormConsumer.jar to assigned location: /home/ubuntu/apache-storm-0.9.4/data/nimbus/inbox/stormjar-bb9e4775-748b-45ff-a91a-c170c65861e9.jar
6722 [main] INFO  backtype.storm.StormSubmitter - Successfully uploaded topology jar to assigned location: /home/ubuntu/apache-storm-0.9.4/data/nimbus/inbox/stormjar-bb9e4775-748b-45ff-a91a-c170c65861e9.jar
6722 [main] INFO  backtype.storm.StormSubmitter - Submitting topology topology1 in distributed mode with conf {"nimbus.host":"localhost","cassandraKeyspaceName":"topology1","topology.workers":20,"nimbus.thrift.port":6627,"topology.max.spout.pending":500,"ignoreIPList":"iplist"}
6729 [main] ERROR org.apache.storm.zookeeper.server.NIOServerCnxnFactory - Thread Thread[main,5,main] died
java.lang.NullPointerException: null
at org.apache.thrift7.protocol.TBinaryProtocol.writeString(TBinaryProtocol.java:185) ~[storm-core-0.9.4.jar:0.9.4]
at backtype.storm.generated.StormTopology.write(StormTopology.java:588) ~[storm-core-0.9.4.jar:0.9.4]
at backtype.storm.generated.Nimbus$submitTopology_args.write(Nimbus.java:2080) ~[storm-core-0.9.4.jar:0.9.4]
at org.apache.thrift7.TServiceClient.sendBase(TServiceClient.java:63) ~[storm-core-0.9.4.jar:0.9.4]
at backtype.storm.generated.Nimbus$Client.send_submitTopology(Nimbus.java:156) ~[storm-core-0.9.4.jar:0.9.4]
at backtype.storm.generated.Nimbus$Client.submitTopology(Nimbus.java:145) ~[storm-core-0.9.4.jar:0.9.4]
at backtype.storm.StormSubmitter.submitTopology(StormSubmitter.java:127) ~[storm-core-0.9.4.jar:0.9.4]
at backtype.storm.StormSubmitter.submitTopology(StormSubmitter.java:70) ~[storm-core-0.9.4.jar:0.9.4]
TopologyStructure.main(TopologyStructure.java:817) ~[StormConsumer.jar:na]

Answer 1

我相信您收到 NullPointerException 的原因是缺少 bolt ID。

当您使用 TopologyBuilder 来 setBolt 时，您可能会传递 null 作为 id ？