老师你好，

我最近在开发csv source文件读取，设置成并行度1的时候并没有什么问题，但是设置多并行度的时候发现程序会重复读取csv文件，如果文件夹中几百个csv就会出现重复读取多次，用的是RichParallelSourceFunction，请问怎么解决？
代码如下
getFileTree(path).filter(_.getName.endsWith(fileExtension)).foreach(file => {
println(file)
val csvInput = env.readCsvFile[RawDepthTickData](file.getAbsolutePath, ignoreFirstLine = true)
.collect()
csvInput.foreach(tick => ctx.collect(tick))
del(file)
})