程序启动报错:
backtype.storm.generated.InvalidTopologyException:null
问题解决方法:
这个错误一般都是没有定义输出列造成的
检查Spout和Bolt代码中的declareOutputFields方法
declare的Field数量 等于 collector.emit数量
@Override public void declareOutputFields(OutputFieldsDeclarer declarer) { declarer.declare(new Fields("定义你的列")); }
时间: 2024-11-05 06:55:15