[hotfix-#1842][core] Fixed the config of sftp is null and support wri…

…te mode
DTStack · Nov 21, 2023 · e596e42 · e596e42
1 parent 9be5ac8
commit e596e42
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/...tor-ftp/src/main/java/com/dtstack/chunjun/connector/ftp/table/FtpDynamicTableFactory.java b/...tor-ftp/src/main/java/com/dtstack/chunjun/connector/ftp/table/FtpDynamicTableFactory.java
@@ -69,6 +69,7 @@ private static FtpConfig getFtpConfByOptions(ReadableConfig config) {
         ftpConfig.setCompressType(config.get(FtpOptions.COMPRESS_TYPE));
         ftpConfig.setFileType(config.get(FtpOptions.FILE_TYPE));
         ftpConfig.setNextCheckRows(config.get(BaseFileOptions.NEXT_CHECK_ROWS));
+        ftpConfig.setWriteMode(config.get(BaseFileOptions.WRITE_MODE));
 
         if (!ConfigConstants.DEFAULT_FIELD_DELIMITER.equals(
                 config.get(FtpOptions.FIELD_DELIMITER))) {
@@ -181,6 +182,7 @@ public Set<ConfigOption<?>> optionalOptions() {
         options.add(FtpOptions.FIELD_DELIMITER);
         options.add(FtpOptions.COMPRESS_TYPE);
         options.add(BaseFileOptions.NEXT_CHECK_ROWS);
+        options.add(BaseFileOptions.WRITE_MODE);
         return options;
     }
 }