2015-05-05 21 views
1

如果評論builder.setBolt然後它運行correctly.Please告訴我在哪裏得到錯誤獲取backtype.storm.generated.InvalidTopologyException:空。如果我評論打電話setBolt運行

TopologyBuilder builder = new TopologyBuilder(); 
    builder.setSpout("words", new TestWordSpout(), 3); 
    //Calling setBolt 
    builder.setBolt("exc", new ExclaimBolt(),3) 
    .allGrouping("words"); 

    Config conf = new Config(); 
    conf.setDebug(false); 
    //conf.setNumWorkers(2); 

    LocalCluster cluster = new LocalCluster(); 
    cluster.submitTopology("test", conf, builder.createTopology()); 
+0

我是傻瓜,解決它,沒有錯誤 –

+1

請寫下你做了什麼來解決你的問題,然後關閉你的問題。謝謝 – Xavjer

回答

1

沒有宣佈輸出Spout中的字段。 聲明它工作正常。