From 1ff453b9cb5dad8c6d4052037e6fee25f6473e61 Mon Sep 17 00:00:00 2001
From: Chen HaoYu <chy9700@163.com>
Date: Wed, 17 May 2023 09:50:07 +0800
Subject: [PATCH] =?UTF-8?q?fix:=20=E8=A7=A3=E5=86=B3sftp=E6=9C=8D=E5=8A=A1?=
 =?UTF-8?q?=E5=99=A8=E8=BF=9E=E6=8E=A5=E5=A4=B1=E8=B4=A5=E6=9C=AA=E6=8A=9B?=
 =?UTF-8?q?=E5=87=BA=E5=BC=82=E5=B8=B8=EF=BC=8C=E5=AF=BC=E8=87=B4=E5=90=8E?=
 =?UTF-8?q?=E7=BB=AD=E8=8E=B7=E5=8F=96ChannelSft=E5=87=BA=E7=8E=B0nullPoin?=
 =?UTF-8?q?terException?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

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

diff --git a/ftpreader/src/main/java/com/alibaba/datax/plugin/reader/ftpreader/SftpHelper.java b/ftpreader/src/main/java/com/alibaba/datax/plugin/reader/ftpreader/SftpHelper.java
index d25b040c..6e42e10c 100644
--- a/ftpreader/src/main/java/com/alibaba/datax/plugin/reader/ftpreader/SftpHelper.java
+++ b/ftpreader/src/main/java/com/alibaba/datax/plugin/reader/ftpreader/SftpHelper.java
@@ -64,6 +64,8 @@ public class SftpHelper extends FtpHelper {
 					String message = String.format("请确认连接ftp服务器端口是否正确，错误的端口: [%s] ", port);
 					LOG.error(message);
 					throw DataXException.asDataXException(FtpReaderErrorCode.FAIL_LOGIN, message, e);
+				}else{
+					throw DataXException.asDataXException(FtpReaderErrorCode.COMMAND_FTP_IO_EXCEPTION, "", e);
 				}
 			}else {
 				if("Auth fail".equals(e.getMessage())){