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());
我是傻瓜,解決它,沒有錯誤 –
請寫下你做了什麼來解決你的問題,然後關閉你的問題。謝謝 – Xavjer