Apache Storm:InvalidTopologyException（消息：组件：[x]从不存在的组件[y]订阅）

Question

我使用了这个博客中的代码（效果很好）：

TopologyBuilder builder = new TopologyBuilder();
builder.setSpout("line-reader-spout", new LineReaderSpout());
builder.setBolt("word-spitter", new WordSpitterBolt()).shuffleGrouping("line-reader-spout");
builder.setBolt("word-counter", new WordCounterBolt()).shuffleGrouping("word-spitter");

LocalCluster cluster = new LocalCluster();
cluster.submitTopology("HelloStorm", config, builder.createTopology());

但是，当我调整它，使其有两个可以读取行的喷口，将行发送到两个单词吐出器螺栓，最后将结果发送到单个单词计数器螺栓时，就会抛出无效拓扑的异常。

我修改过的代码

TopologyBuilder builder = new TopologyBuilder();

builder.setSpout("line-reader-spout", new LineReaderSpout());
builder.setSpout("line-reader-spout2", new LineReaderSpout());        
builder.setBolt("word-spitter", new WordSpitterBolt()).shuffleGrouping("line-reader-spout");
builder.setBolt("word-spitter2", new WordSpitterBolt()).shuffleGrouping("line-reader-spout2");
builder.setBolt("word-counter", new WordCounterBolt(),2).shuffleGrouping("word-spitter").shuffleGrouping("word-splitter2");
LocalCluster cluster = new LocalCluster();
cluster.submitTopology("HelloStorm", config, builder.createTopology());

拓扑有什么问题，我没有看到任何不正当的流，在实际创建时，word-spitter2怎么可能不存在？

6661[main]INFOb.s.d.nimbus-[req 1]从以下位置访问：主体： op： submitTopology 6718[main]WARNb.s.d.nimbus-拓扑提交异常。（拓扑名称='HelloStorm'）#InvalidTopology yExctive InvalidTopology yExctive（msg： Component：[word-计数器]订阅不存在的组件[word-splitter2]）6721[main]ERROR o. a. s. o. a. z. s.NIOServerCnxnFactory-线程[main，5， main]死exec_fn__1236__auto__InvalidTopology异常在fn__6583$validate_structure_BANG_. invoke（exec_fn__1236__auto__）~[0_73： 0.10.0]在backtype.storm.daemon.common$system_topology_BANG_. invoke（common.clj:299）~[storm-core-0.10.0.jar： 0.10.0]在backtype.storm.daemon.nimbus$fn__6583$backtype.storm.generated.$reify__6598.submit拓扑选择（nimbus.clj:1091）~[storm-core-0.10.0.jar： 0.10.0]在backtype.storm.daemon.nimbus$backtype.storm.daemon.common$common.clj:160$reify__6598.submit拓扑（nimbus.clj:1119）~[storm-core-0.10.0.jar： 0.10.0]在sun.reflect.NativemetodAccessorImpl.invoke0（本机方法）~[？： 1.8.storm-core-0.10.0.jar]在sun.reflect.NativeomeodAccessorInm. invoke（NativeomeodAccessorInm. java： 62）~[？： 1.8.0_73]在sun. reava. reflector. java： 43）~[？： 1.8.0_73]在clojure. lang. reava. rang. reflector. tnkeMatchingmethod（Reflector. java： 93）~[clojure-1.6.0. jar：？]在Clojure. lang. Reflector. ainkeInstancemethod（Reflector. java： 28）~[clojure-1.6.0. jar：？]在backtype. Storm. test$submit_local_topology. invoke（test. clj： 276）~[Stor-core-0.10.0. jar： 0.10.0]在backtype. Storm. LocalClusterLocalCluster. submitTopology（未知来源）~[Storm-core-0.10.0. jar： 0.10.0]在com. spNotes. Storm. HelloStorm. main（HelloStorm. java： 36）~[类/：？]




Answer 1

你有拼写错误拆分器2。

建设者setBolt（“word-spitter2”，新单词SpitterBolt（）。洗牌组合（“line-reader-spout2”）；建设者设置螺栓（“单词计数器”，新单词计数器螺栓（），2）。洗牌组合（“吐字者”）。洗牌组合（“单词拆分器2”）；