正在获取backtype.storm.已生成.拓扑无效异常：null,如果我注解setBolt调用，它将运行

jaql4c8m 于 2022-12-09 发布在 Apache

关注(0)|答案(1)|浏览(109)

如果注解builder.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());

apache-storm

来源：https://stackoverflow.com/questions/30044289/getting-backtype-storm-generated-invalidtopologyexception-null-if-i-comment-ca

1条答案

按热度按时间

wqnecbli1#

没有在Spout中声明输出字段。声明后工作正常。
代码示例（在u bolt类中）：

@Override

public void declareOutputFields(OutputFieldsDeclarer declarer) {

    declarer.declare(new Fields("msg"));//based on u project

}

赞(0）回复(0）举报 2022-12-09

我来回答

正在获取backtype.storm.已生成.拓扑无效异常：null,如果我注解setBolt调用，它将运行

1条答案

相关问题

热门标签

最新问答