風暴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")以從「噴口」組件獲取源代碼。