java - Storm 拓扑的 bolt 接收重复结果

Question

我正在使用一个从另一个 bolt (感叹号 bolt )接收元组并将其写入文件的 bolt ，我遇到的问题是我有四次重复的结果，就像当我发出一个词时，我找到了这个词写了四遍。问题可能在哪里？

public class PrinterBolty extends BaseBasicBolt {

    @Override
    public void execute(Tuple tuple, BasicOutputCollector collector) {

        try {
            BufferedWriter output;
            output = new BufferedWriter(new FileWriter("/root/src/storm-starter/hh.txt", true));
            output.newLine();
            output.append(tuple.getString(0));
            output.close();
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
    }

    @Override
    public void declareOutputFields(OutputFieldsDeclarer ofd) {
    }
}

Answer 1

解决方案是在主类中指定 1 个 spout:

builder.setSpout("spout", new RandomSentenceSpout(), 1);