修改s3类型上的bucket 赋值

seatunnel-datasource/seatunnel-datasource-plugins/datasource-csv/src/main/java/org/apache/seatunnel/datasource/plugin/csv/CSVClientService.java

@@ -16,7 +16,12 @@ public class CSVClientService {
     private MinioClient minioClient;
 
     public CSVClientService(
-            String endpoint, String provider, String username, String password, Integer port, String backet)
+            String endpoint,
+            String provider,
+            String username,
+            String password,
+            Integer port,
+            String backet)
             throws MinioException {
         this.ENDPOINT = endpoint;
         this.PROVIDER = provider;

seatunnel-datasource/seatunnel-datasource-plugins/datasource-csv/src/main/java/org/apache/seatunnel/datasource/plugin/csv/CSVDatasourceChannel.java

@@ -17,7 +17,6 @@
 
 package org.apache.seatunnel.datasource.plugin.csv;
 
-import org.apache.hadoop.conf.Configuration;
 import org.apache.seatunnel.api.configuration.util.OptionRule;
 import org.apache.seatunnel.common.utils.SeaTunnelException;
 import org.apache.seatunnel.datasource.plugin.api.DataSourceChannel;
@@ -201,7 +200,6 @@ public class CSVDatasourceChannel implements DataSourceChannel {
         }
         try {
 
-
             createS3Client(requestParams);
             return true;
         } catch (Exception ex) {
@@ -309,7 +307,8 @@ public class CSVDatasourceChannel implements DataSourceChannel {
         String password = requestParams.get("secret_key");
         String bucket = requestParams.get("bucket");
         try {
-            s3ClientService = new CSVClientService(endpoint, provider, username, password, port, bucket);
+            s3ClientService =
+                    new CSVClientService(endpoint, provider, username, password, port, bucket);
             return s3ClientService;
         } catch (Exception e) {
             throw new SeaTunnelException("创建Mqtt客户端错误！");

seatunnel-datasource/seatunnel-datasource-plugins/datasource-excel/src/main/java/org/apache/seatunnel/datasource/plugin/excel/ExcelClientService.java

@@ -16,7 +16,12 @@ public class ExcelClientService {
     private MinioClient minioClient;
 
     public ExcelClientService(
-            String endpoint, String provider, String username, String password, Integer port, String bucket)
+            String endpoint,
+            String provider,
+            String username,
+            String password,
+            Integer port,
+            String bucket)
             throws MinioException {
         this.ENDPOINT = endpoint;
         this.PROVIDER = provider;

seatunnel-datasource/seatunnel-datasource-plugins/datasource-excel/src/main/java/org/apache/seatunnel/datasource/plugin/excel/ExcelDatasourceChannel.java

@@ -306,7 +306,8 @@ public class ExcelDatasourceChannel implements DataSourceChannel {
         String password = requestParams.get("secret_key");
         String bucket = requestParams.get("bucket");
         try {
-            s3ClientService = new ExcelClientService(endpoint, provider, username, password, port, bucket);
+            s3ClientService =
+                    new ExcelClientService(endpoint, provider, username, password, port, bucket);
             return s3ClientService;
         } catch (Exception e) {
             throw new SeaTunnelException("创建Mqtt客户端错误！");

seatunnel-datasource/seatunnel-datasource-plugins/datasource-s3/src/main/java/org/apache/seatunnel/datasource/plugin/s3/S3ClientService.java

@@ -16,14 +16,19 @@ public class S3ClientService {
     private MinioClient minioClient;
 
     public S3ClientService(
-            String endpoint, String provider, String username, String password, Integer port,String bucket)
+            String endpoint,
+            String provider,
+            String username,
+            String password,
+            Integer port,
+            String bucket)
             throws MinioException {
         this.ENDPOINT = endpoint;
         this.PROVIDER = provider;
         this.USERNAME = username;
         this.PASSWORD = password;
         this.PORT = port;
-        this.BUCKET=bucket;
+        this.BUCKET = bucket;
         setMinioClient(endpoint, provider, username, password, port);
     }
 

seatunnel-datasource/seatunnel-datasource-plugins/datasource-s3/src/main/java/org/apache/seatunnel/datasource/plugin/s3/S3DatasourceChannel.java

@@ -317,7 +317,8 @@ public class S3DatasourceChannel implements DataSourceChannel {
         String password = requestParams.get("secret_key");
         String bucket = requestParams.get("bucket");
         try {
-            s3ClientService = new S3ClientService(endpoint, provider, username, password, port, bucket);
+            s3ClientService =
+                    new S3ClientService(endpoint, provider, username, password, port, bucket);
             return s3ClientService;
         } catch (Exception e) {
             throw new SeaTunnelException("创建Mqtt客户端错误！");

seatunnel-datasource/seatunnel-datasource-plugins/datasource-xml/src/main/java/org/apache/seatunnel/datasource/plugin/xml/XMLClientService.java

@@ -16,14 +16,19 @@ public class XMLClientService {
     private MinioClient minioClient;
 
     public XMLClientService(
-            String endpoint, String provider, String username, String password, Integer port,String bucket)
+            String endpoint,
+            String provider,
+            String username,
+            String password,
+            Integer port,
+            String bucket)
             throws MinioException {
         this.ENDPOINT = endpoint;
         this.PROVIDER = provider;
         this.USERNAME = username;
         this.PASSWORD = password;
         this.PORT = port;
-        this.BUCKET=bucket;
+        this.BUCKET = bucket;
         setMinioClient(endpoint, provider, username, password, port);
     }
 

seatunnel-datasource/seatunnel-datasource-plugins/datasource-xml/src/main/java/org/apache/seatunnel/datasource/plugin/xml/XMLDatasourceChannel.java

@@ -297,16 +297,17 @@ public class XMLDatasourceChannel implements DataSourceChannel {
 
     public XMLClientService createS3Client(Map<String, String> requestParams) {
         int i = requestParams.get("fs.s3a.endpoint").lastIndexOf(":");
-        String endpoint = requestParams.get("fs.s3a.endpoint")  ;
+        String endpoint = requestParams.get("fs.s3a.endpoint");
         Integer port =
                 Integer.valueOf(
                         requestParams.get("fs.s3a.endpoint").substring(i + 1).replace("/", ""));
-        String provider = requestParams.get("fs.s3a.aws.credentials.provider")  ;
-        String username = requestParams.get("access_key")  ;
-        String password = requestParams.get("secret_key")  ;
-        String bucket = requestParams.get("bucket") ;
+        String provider = requestParams.get("fs.s3a.aws.credentials.provider");
+        String username = requestParams.get("access_key");
+        String password = requestParams.get("secret_key");
+        String bucket = requestParams.get("bucket");
         try {
-            s3ClientService = new XMLClientService(endpoint, provider, username, password, port,bucket);
+            s3ClientService =
+                    new XMLClientService(endpoint, provider, username, password, port, bucket);
             return s3ClientService;
         } catch (Exception e) {
             throw new SeaTunnelException("创建Mqtt客户端错误！");