[incubator-seatunnel] branch dev updated: [Connector][File-S3]Set AK is not required (#3713)

[dijiekstra]

This is an automated email from the ASF dual-hosted git repository.

dijiekstra pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-seatunnel.git


The following commit(s) were added to refs/heads/dev by this push:
     new da3c52617 [Connector][File-S3]Set AK is not required (#3713)
da3c52617 is described below

commit da3c5261720cd7c46b236ffcc68ec5427ca9f213
Author: Kirs <k...@apache.org>
AuthorDate: Tue Dec 13 15:03:01 2022 +0800

    [Connector][File-S3]Set AK is not required (#3713)
---
 .../apache/seatunnel/connectors/seatunnel/file/s3/sink/S3FileSink.java | 3 +--
 .../seatunnel/connectors/seatunnel/file/s3/source/S3FileSource.java    | 3 +--
 2 files changed, 2 insertions(+), 4 deletions(-)

diff --git 
a/seatunnel-connectors-v2/connector-file/connector-file-s3/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/s3/sink/S3FileSink.java
 
b/seatunnel-connectors-v2/connector-file/connector-file-s3/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/s3/sink/S3FileSink.java
index 5f7622575..2047de135 100644
--- 
a/seatunnel-connectors-v2/connector-file/connector-file-s3/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/s3/sink/S3FileSink.java
+++ 
b/seatunnel-connectors-v2/connector-file/connector-file-s3/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/s3/sink/S3FileSink.java
@@ -44,8 +44,7 @@ public class S3FileSink extends BaseFileSink {
     public void prepare(Config pluginConfig) throws PrepareFailException {
         super.prepare(pluginConfig);
         CheckResult result = CheckConfigUtil.checkAllExists(pluginConfig,
-                S3Config.FILE_PATH.key(), S3Config.S3_BUCKET.key(),
-                S3Config.S3_ACCESS_KEY.key(), S3Config.S3_SECRET_KEY.key());
+                S3Config.FILE_PATH.key(), S3Config.S3_BUCKET.key());
         if (!result.isSuccess()) {
             throw new 
FileConnectorException(SeaTunnelAPIErrorCode.CONFIG_VALIDATION_FAILED,
                     String.format("PluginName: %s, PluginType: %s, Message: 
%s",
diff --git 
a/seatunnel-connectors-v2/connector-file/connector-file-s3/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/s3/source/S3FileSource.java
 
b/seatunnel-connectors-v2/connector-file/connector-file-s3/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/s3/source/S3FileSource.java
index 46995347c..38a51b690 100644
--- 
a/seatunnel-connectors-v2/connector-file/connector-file-s3/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/s3/source/S3FileSource.java
+++ 
b/seatunnel-connectors-v2/connector-file/connector-file-s3/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/s3/source/S3FileSource.java
@@ -51,8 +51,7 @@ public class S3FileSource extends BaseFileSource {
     @Override
     public void prepare(Config pluginConfig) throws PrepareFailException {
         CheckResult result = CheckConfigUtil.checkAllExists(pluginConfig,
-                S3Config.FILE_PATH.key(), S3Config.FILE_TYPE.key(), 
S3Config.S3_BUCKET.key(),
-                S3Config.S3_ACCESS_KEY.key(), S3Config.S3_SECRET_KEY.key());
+                S3Config.FILE_PATH.key(), S3Config.FILE_TYPE.key(), 
S3Config.S3_BUCKET.key());
         if (!result.isSuccess()) {
             throw new 
FileConnectorException(SeaTunnelAPIErrorCode.CONFIG_VALIDATION_FAILED,
                     String.format("PluginName: %s, PluginType: %s, Message: 
%s",