修改 ftpclient 测试

seatunnel-datasource/seatunnel-datasource-plugins/datasource-ftp/src/main/java/org/apache/seatunnel/datasource/plugin/ftp/FtpAConfiguration.java

@@ -24,39 +24,39 @@ import java.util.Map;
 @Slf4j
 public class FtpAConfiguration {
 
-    public static FtpConfiguration getConfiguration(Map<String, String> FtpOption) {
+    public static FtpConfiguration getConfiguration(Map<String, String> ftpOption) {
 
-        if (!FtpOption.containsKey(FtpOptionRule.HOST.key())) {
+        if (!ftpOption.containsKey(FtpOptionRule.HOST.key())) {
             throw new IllegalArgumentException(
                     "FtpRedshift datasource host is null, please check your config");
         }
-        if (!FtpOption.containsKey(FtpOptionRule.PORT.key())) {
+        if (!ftpOption.containsKey(FtpOptionRule.PORT.key())) {
             throw new IllegalArgumentException(
                     "FtpRedshift datasource port is null, please check your config");
         }
-        if (!FtpOption.containsKey(FtpOptionRule.USERNAME.key())) {
+        if (!ftpOption.containsKey(FtpOptionRule.USERNAME.key())) {
             throw new IllegalArgumentException(
                     "FtpRedshift datasource username is null, please check your config");
         }
-        if (!FtpOption.containsKey(FtpOptionRule.PASSWORD.key())) {
+        if (!ftpOption.containsKey(FtpOptionRule.PASSWORD.key())) {
             throw new IllegalArgumentException(
                     "FtpRedshift datasource password is null, please check your config");
         }
-        if (!FtpOption.containsKey(FtpOptionRule.PATH.key())) {
+        if (!ftpOption.containsKey(FtpOptionRule.PATH.key())) {
             throw new IllegalArgumentException(
                     "FtpRedshift datasource path is null, please check your config");
         }
-        if (!FtpOption.containsKey(FtpOptionRule.FILE_FORMAT_TYPE.key())) {
+        if (!ftpOption.containsKey(FtpOptionRule.FILE_FORMAT_TYPE.key())) {
             throw new IllegalArgumentException(
                     "FtpRedshift datasource file_format_type is null, please check your config");
         }
         FtpConfiguration ftpConfiguration = new FtpConfiguration();
-        ftpConfiguration.setHost(FtpOptionRule.HOST.key());
-        ftpConfiguration.setPort(FtpOptionRule.PORT.key());
-        ftpConfiguration.setUser(FtpOptionRule.USERNAME.key());
-        ftpConfiguration.setPassword(FtpOptionRule.PASSWORD.key());
-        ftpConfiguration.setPath(FtpOptionRule.PATH.key());
-        ftpConfiguration.setType(FtpOptionRule.FILE_FORMAT_TYPE.key());
+        ftpConfiguration.setHost(ftpOption.get(FtpOptionRule.HOST.key()));
+        ftpConfiguration.setPort(ftpOption.get(FtpOptionRule.PORT.key()));
+        ftpConfiguration.setUser(ftpOption.get(FtpOptionRule.USERNAME.key()));
+        ftpConfiguration.setPassword(ftpOption.get(FtpOptionRule.PASSWORD.key()));
+        ftpConfiguration.setPath(ftpOption.get(FtpOptionRule.PATH.key()));
+        ftpConfiguration.setType(ftpOption.get(FtpOptionRule.FILE_FORMAT_TYPE.key()));
 
         return ftpConfiguration;
     }

seatunnel-datasource/seatunnel-datasource-plugins/datasource-ftp/src/main/java/org/apache/seatunnel/datasource/plugin/ftp/FtpClientService.java

@@ -3,7 +3,6 @@ package org.apache.seatunnel.datasource.plugin.ftp;
 import org.apache.commons.net.ftp.FTP;
 import org.apache.commons.net.ftp.FTPClient;
 import org.apache.commons.net.ftp.FTPReply;
-import org.apache.hadoop.fs.FileSystem;
 import org.apache.hadoop.net.NetUtils;
 
 import io.netty.util.internal.StringUtil;
@@ -13,7 +12,6 @@ import java.net.ConnectException;
 
 public class FtpClientService {
 
-
     public static FTPClient connect(FtpConfiguration conf) throws IOException {
         FTPClient client = null;
         String host = conf.getHost();