通过老的API 也就是 InputFormatSourceFunction、InputFormat 实现了一版，但发现第一批文件(任务启动时也已存在的文件)会正常处理，但我新上传文件后，这里一直为空，有解决思路吗？请问
[image: image.png] ---- 或者有其他实现 ftp 目录实时读取的实现吗？尽可能满足 1. 实时读取 ftp 文件 2. 支持持续监测目录及递归子目录与文件3. 3. 支持并行读取以及大文件的切分 4. 文件种类可能有 json、txt、zip 等，支持读取不同类型文件内的数据 5. 支持断点续传以及状态的保存
