修改 ftpclient 测试

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

@@ -21,7 +21,7 @@ public class FtpClientService {
     public static final String FS_FTP_PASSWORD_PREFIX = "ftp.";
     public static final String E_SAME_DIRECTORY_ONLY = "/ftp";
 
-    private FTPClient connect() throws IOException {
+    public static FTPClient connect() throws IOException {
         FTPClient client = null;
         String host = FS_FTP_HOST;
         int port = FS_FTP_HOST_PORT;

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

@@ -18,6 +18,7 @@
 package org.apache.seatunnel.datasource.plugin.ftp;
 
 import lombok.NonNull;
+import org.apache.commons.net.ftp.FTPClient;
 import org.apache.hadoop.conf.Configuration;
 import org.apache.hadoop.fs.FileSystem;
 import org.apache.hadoop.fs.Path;
@@ -46,11 +47,26 @@ public class FtpDatasourceChannel implements DataSourceChannel {
     public boolean checkDataSourceConnectivity(
             @NonNull String pluginName, @NonNull Map<String, String> requestParams) {
         FtpConfiguration conf = FtpAConfiguration.getConfiguration(requestParams);
-        if (Objects.isNull(conf)){
+        try {
+            FTPClient ftpClient = FtpClientService.connect();
+
+            if (Objects.isNull(conf)) {
+                throw new DataSourcePluginException(
+                        String.format("check ftp connectivity failed, config is: %s", requestParams));
+            }
+
+            if (ftpClient.changeWorkingDirectory(requestParams.get(FtpOptionRule.PATH.key()))) {
+                return true;
+            } else {
+                throw new DataSourcePluginException(
+                        String.format("check ftp connectivity failed, config is: %s", requestParams));
+            }
+
+        } catch (Exception e) {
             throw new DataSourcePluginException(
                     String.format("check ftp connectivity failed, config is: %s", requestParams));
         }
-        return true;
+      //  return true;
     }
 
     @Override

seatunnel-datasource/seatunnel-datasource-plugins/datasource-opcua/src/main/java/org/apache/seatunnel/datasource/plugin/opcua/OpcuaOptionRule.java

@@ -41,8 +41,11 @@ public class OpcuaOptionRule {
     public static final Option<String> TYPE =
             Options.key("type").stringType().defaultValue("int").withDescription("type");
 
+    public static final Option<Integer> GS =
+            Options.key("gs").intType().defaultValue(1).withDescription("type");
+
     public static OptionRule optionRule() {
-        return OptionRule.builder().required(HOST, PORT, SUFFIX, NS, ID, TYPE).build();
+        return OptionRule.builder().required(HOST, PORT, SUFFIX, NS, ID, TYPE).optional(GS).build();
     }
 
     public static OptionRule metadataRule() {