螺栓接收风暴拓扑的重复结果

Question

我使用的螺栓从另一个螺栓（感叹号螺栓）接收元组并将其写入文件，我得到的问题是，我有重复的结果四次，就像当我发出一个字，我发现了四次写入的字。问题可能在哪里？

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个喷口：

builder.setSpout（ “喷口”，新RandomSentenceSpout（），1）;