提交拓扑时发生apache storm invalidtopologyexception

hsgswve4  于 2021-06-24  发布在  Storm
关注(0)|答案(0)|浏览(200)

我在提交storm拓扑时遇到invlaidtopologyexception。代码如下:

TopologyBuilder topologyBuilder = new TopologyBuilder();
topologyBuilder.setSpout("konnect_smstags_spout",new Konnect_SMSTags_Spout(zkConnString,topic).getKonnectSMSTagsSpout());
topologyBuilder.setBolt("smstag_logger_bolt", new SMSTag_Logger_Bolt(),5).shuffleGrouping("konnect_smstags_spout");
topologyBuilder.setBolt("smstag_basicsummary_bolt", new SMSTag_BasicSummary_Bolt(),1).globalGrouping("smstag_logger_bolt");

这有什么问题?

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题