From fae4214e45bb3428023c64ca5697986eff0c6bad Mon Sep 17 00:00:00 2001
From: Zhang Xian <zhangxian@foxmail.com>
Date: Thu, 9 Sep 2021 22:44:56 +0800
Subject: [PATCH] Update StandardFtpHelper.java

---
 .../plugin/reader/ftpreader/StandardFtpHelper.java   | 12 ++++++++++++
 1 file changed, 12 insertions(+)

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 79b23f8b..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
@@ -225,5 +225,17 @@ public class StandardFtpHelper extends FtpHelper {
 			throw DataXException.asDataXException(FtpReaderErrorCode.OPEN_FILE_ERROR, message);
 		}
 	}
+	
+	@Override
+	public void deleteFile(String filePath) {
+
+		try{
+			ftpClient.deleteFile(filePath);
+		}catch(IOException e){
+			String message = String.format("删除文件 : [%s] 时出错,请确认文件：[%s]存在且配置的用户有权限读取", filePath, filePath);
+			LOG.error(message);
+			throw DataXException.asDataXException(FtpReaderErrorCode.OPEN_FILE_ERROR, message);
+		}
+	}
 
 }