请教各位大佬，flink读取hdfs文件时的疑问

[wanggaoliang]

flink读取hdfs文件时，FileInputFormat.java类中，acceptFile()方法默认过滤掉了以"_"和"."开头的文件，那如果读入了in-progress文件和.pending文件，
在执行open()方法时，突然in-progress或.pending文件状态发生了改变而导致原来的文件路径消失，会不会出现什么问题？或者是有没有可能出现这种情况？