From 40aed187f9fa4833a03abfe99170c572c5ee079c Mon Sep 17 00:00:00 2001
From: Zhang Xian <zhangxian@foxmail.com>
Date: Thu, 9 Sep 2021 22:51:05 +0800
Subject: [PATCH] Update FtpReader.java

---
 .../com/alibaba/datax/plugin/reader/ftpreader/FtpReader.java | 5 +++++
 1 file changed, 5 insertions(+)

diff --git a/ftpreader/src/main/java/com/alibaba/datax/plugin/reader/ftpreader/FtpReader.java b/ftpreader/src/main/java/com/alibaba/datax/plugin/reader/ftpreader/FtpReader.java
index c1f20dfd..8fe4e484 100644
--- a/ftpreader/src/main/java/com/alibaba/datax/plugin/reader/ftpreader/FtpReader.java
+++ b/ftpreader/src/main/java/com/alibaba/datax/plugin/reader/ftpreader/FtpReader.java
@@ -244,6 +244,11 @@ public class FtpReader extends Reader {
 				UnstructuredStorageReaderUtil.readFromStream(inputStream, fileName, this.readerSliceConfig,
 						recordSender, this.getTaskPluginCollector());
 				recordSender.flush();
+				// 如果deletesrc为true，则删除源文件
+				if(readerSliceConfig.getBool(Key.DELETESRC,Constant.DEFAULT_FTP_DELETE_SRC)){
+					ftpHelper.deleteFile(fileName);
+					LOG.info(String.format("deleted file : [%s]", fileName));
+				}
 			}
 
 			LOG.debug("end read source files...");