风暴InvalidTopologyException

Question

我收到一条错误信息，当我尝试运行我的拓扑结构：

java.lang.reflect.InvocationTargetException 
... 
Caused by: InvalidTopologyException(msg:Component: [write] subscribes from non-existent stream: [default] of component [write]) 

这里是我的拓扑声明：

TopologyBuilder builder = new TopologyBuilder(); 
    builder.setSpout("spout", spout, 1); 
    builder.setBolt("write", new PrinterBolt(), 1).shuffleGrouping("write"); 

这是怎么回事？

Answer 1

在您的喷口声明shuffleGrouping("write")引用打印机螺栓的源流。在这种情况下，它表示使用默认流ID从“写入”组件发出。

您必须将其更改为shuffleGrouping("spout")以从“喷口”组件获取源代码。