github/DataX
5
0
Fork 0
mirror of https://github.com/alibaba/DataX.git synced 2025-05-02 00:40:25 +08:00
Code Issues Packages Projects Releases Wiki Activity

Merge branch 'alibaba:master' into example_demo

Browse Source
This commit is contained in:
FuYouJ 2023-08-22 10:10:11 +08:00 committed by GitHub
commit eaf2608900
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
4 changed files with 6 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
clickhousereader/src/main/assembly/package.xml
View File

@ -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">
<id>datax</id>
<id></id>
<formats>
<format>dir</format>
</formats>

4
ftpreader/pom.xml
View File

@ -45,7 +45,7 @@
<dependency>
<groupId>com.jcraft</groupId>
<artifactId>jsch</artifactId>
<version>0.1.51</version>
<version>0.1.54</version>
</dependency>
<dependency>
<groupId>commons-net</groupId>
@ -89,4 +89,4 @@
</plugins>
</build>
</project>
</project>

2
ftpreader/src/main/java/com/alibaba/datax/plugin/reader/ftpreader/SftpHelper.java
View File

@ -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())){

2
ftpwriter/pom.xml
View File

@ -45,7 +45,7 @@
<dependency>
<groupId>com.jcraft</groupId>
<artifactId>jsch</artifactId>
<version>0.1.51</version>
<version>0.1.54</version>
</dependency>
<dependency>
<groupId>commons-net</groupId>