[Fix] [Connectors-v2-file-ftp] add ftp connection mode (apache#6077)

WilliamTan778 · Dec 26, 2023 · cfa675e · cfa675e
1 parent a606868
commit cfa675e
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/...-ftp/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/ftp/config/FtpConf.java b/...-ftp/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/ftp/config/FtpConf.java
@@ -54,7 +54,7 @@ public static HadoopConf buildWithConfig(Config config) {
                 "fs.ftp.password." + host, config.getString(FtpConfigOptions.FTP_PASSWORD.key()));
         if (config.hasPath(FtpConfigOptions.FTP_ACTIVE_MODE_STATUS.key())) {
             ftpOptions.put(
-                    "fs.ftp.data.connection.mode." + host,
+                    "fs.ftp.connection.mode",
                     config.getString(FtpConfigOptions.FTP_ACTIVE_MODE_STATUS.key()));
         }
         hadoopConf.setExtraOptions(ftpOptions);

diff --git a/...ava/org/apache/seatunnel/connectors/seatunnel/file/ftp/system/SeaTunnelFTPFileSystem.java b/...ava/org/apache/seatunnel/connectors/seatunnel/file/ftp/system/SeaTunnelFTPFileSystem.java
@@ -62,7 +62,7 @@ public class SeaTunnelFTPFileSystem extends FileSystem {
     public static final String FS_FTP_HOST = "fs.ftp.host";
     public static final String FS_FTP_HOST_PORT = "fs.ftp.host.port";
     public static final String FS_FTP_PASSWORD_PREFIX = "fs.ftp.password.";
-    public static final String FS_FTP_ACTIVE_MODEL_STATUS = "fs.ftp.data.connection.mode.";
+    public static final String FS_FTP_ACTIVE_MODEL_STATUS = "fs.ftp.connection.mode";
     public static final String E_SAME_DIRECTORY_ONLY = "only same directory renames are supported";
 
     private URI uri;
@@ -155,7 +155,7 @@ private FTPClient connect() throws IOException {
         }
 
         // set passive mode
-        if (!conf.getBoolean(FS_FTP_ACTIVE_MODEL_STATUS + host, true)) {
+        if (!conf.getBoolean(FS_FTP_ACTIVE_MODEL_STATUS, true)) {
             client.enterLocalPassiveMode();
         }