看起来有多个spout示例正在读取输入文件，导致输出中出现重复记录。

在将内容写入 output.txt 文件，打开 output.txt 在附加模式下。每当发生write语句时，只需将内容附加到此语句 output.txt 通过检查文件中的重复记录，就可以实现这一点。

我也面临同样的问题，所以找到了以下解决方法。
在spout中，当您读取文件时，在open（）方法中创建filereader对象，因为此时它会初始化worker节点的reader对象。并在nexttuple（）方法中使用该对象。
（带一个喷嘴和一个螺栓）
以下是open（）和nexttuple方法的代码：

public void open(Map conf, TopologyContext context,
            SpoutOutputCollector collector) {
            try {
            this.context = context;
            File file = new File(filename);
            this.fileReader = new FileReader(file);
        } catch (FileNotFoundException e) {
            throw new RuntimeException("Error reading file ["+ filename + "]");
        }
        this.collector = collector;
    }

    public void nextTuple() {
        /**
         * The nextuple it is called forever, so if we have been readed the file
         * we will wait and then return
         */
        if (completed) {
            try {
                Thread.sleep(1000);
            } catch (InterruptedException e) {
                // Do nothing
            }
            return;
        }
        String str;
        BufferedReader reader = new BufferedReader(fileReader);
        try {
            // Read all lines
            while ((str = reader.readLine()) != null) {
                /**
                 * By each line emit a new value with the line as a their
                 */
                this.collector.emit(new Values(str), str);
            }
        } catch (Exception e) {
            throw new RuntimeException("Error reading tuple", e);
        } finally {
            completed = true;
        }
    }

输出：

Kaveen,bigdata,29
varadha,cshart,30
vignesh,winrt,21

另一个问题可能是：
您可能正在为spout运行多个示例，这可能会导致流的重复发射，或者文件是以append模式写入的。