diff --git a/clickhousereader/src/main/assembly/package.xml b/clickhousereader/src/main/assembly/package.xml index 2053ff75..9dc7fc13 100644 --- a/clickhousereader/src/main/assembly/package.xml +++ b/clickhousereader/src/main/assembly/package.xml @@ -2,7 +2,7 @@ xmlns="http://maven.apache.org/plugins/maven-assembly-plugin/assembly/1.1.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/plugins/maven-assembly-plugin/assembly/1.1.0 http://maven.apache.org/xsd/assembly-1.1.0.xsd"> - datax + dir diff --git a/ftpreader/pom.xml b/ftpreader/pom.xml index 7778d491..57bf889d 100755 --- a/ftpreader/pom.xml +++ b/ftpreader/pom.xml @@ -45,7 +45,7 @@ com.jcraft jsch - 0.1.51 + 0.1.54 commons-net @@ -89,4 +89,4 @@ - + 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())){ diff --git a/ftpwriter/pom.xml b/ftpwriter/pom.xml index 69ec4a07..bf7ce83d 100644 --- a/ftpwriter/pom.xml +++ b/ftpwriter/pom.xml @@ -45,7 +45,7 @@ com.jcraft jsch - 0.1.51 + 0.1.54 commons-net