diff --git a/ftpreader/src/main/java/com/alibaba/datax/plugin/reader/ftpreader/StandardFtpHelper.java b/ftpreader/src/main/java/com/alibaba/datax/plugin/reader/ftpreader/StandardFtpHelper.java index c876a1f2..e7a2eed9 100644 --- a/ftpreader/src/main/java/com/alibaba/datax/plugin/reader/ftpreader/StandardFtpHelper.java +++ b/ftpreader/src/main/java/com/alibaba/datax/plugin/reader/ftpreader/StandardFtpHelper.java @@ -237,17 +237,5 @@ public class StandardFtpHelper extends FtpHelper { throw DataXException.asDataXException(FtpReaderErrorCode.OPEN_FILE_ERROR, message); } } - - @Override - public void deleteFile(String filePath) { - - try{ - channelSftp.rm(filePath); - }catch(SftpException e){ - String message = String.format("删除文件 : [%s] 时出错,请确认文件:[%s]存在且配置的用户有权限读取", filePath, filePath); - LOG.error(message); - throw DataXException.asDataXException(FtpReaderErrorCode.OPEN_FILE_ERROR, message); - } - } }