你尝试下 用java 读取文件过程中,改文件名 或者移动文件。会异常



在 2021-07-26 15:19:39,"wanggaoliang" <18838915...@163.com> 写道:
















在 2021-07-26 14:56:00,"wanggaoliang" <18838915...@163.com> 写道:

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





 






 

回复