使用自定义源代码可以很容易地做到这一点，只要您希望从单个文件（每个源代码示例）读取内容。您将需要使用操作符状态并实现检查点。状态处理和检查点如下所示：

public class CheckpointedFileSource implements SourceFunction<Event>, ListCheckpointed<Long> {
    private long eventCnt = 0;

    public void run(SourceContext<Event> sourceContext) throws Exception {
        final Object lock = sourceContext.getCheckpointLock();

        // skip over previously emitted events
        ...

        while (not cancelled) {
            read event from file;

            synchronized (lock) {
                eventCnt++;
                sourceContext.collectWithTimestamp(event, timestamp);
            }

        }
    }

    @Override
    public List<Long> snapshotState(long checkpointId, long checkpointTimestamp) throws Exception {
        return Collections.singletonList(eventCnt);
    }

    @Override
    public void restoreState(List<Long> state) throws Exception {
        for (Long s : state)
            this.eventCnt = s;
    }

}

有关完整的示例，请参阅flink培训练习中使用的检查点出租车乘坐数据源。您必须对它进行一些调整，因为它是为读取静态文件而设计的，而不是附加到其中的文件。