mirror of
https://github.com/alibaba/DataX.git
synced 2025-05-03 03:40:24 +08:00
Update FtpReader.java
This commit is contained in:
parent
42f125aabf
commit
b9bb8cc29f
@ -247,7 +247,7 @@ public class FtpReader extends Reader {
|
|||||||
// 如果deletesrc为true,则删除源文件
|
// 如果deletesrc为true,则删除源文件
|
||||||
if(readerSliceConfig.getBool(Key.DELETESRC,Constant.DEFAULT_FTP_DELETE_SRC)){
|
if(readerSliceConfig.getBool(Key.DELETESRC,Constant.DEFAULT_FTP_DELETE_SRC)){
|
||||||
ftpHelper.deleteFile(fileName);
|
ftpHelper.deleteFile(fileName);
|
||||||
LOG.info(String.format("deleted file : [%s]", fileName));
|
LOG.info(String.format("deleted src file : [%s]", fileName));
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
Loading…
Reference in New Issue
Block a user