Fix S3 config check error

apache · Dec 13, 2022 · 4522785 · 4522785
1 parent 18517db
commit 4522785
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...ile-s3/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/s3/config/S3Conf.java b/...ile-s3/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/s3/config/S3Conf.java
@@ -72,7 +72,7 @@ private String switchHdfsImpl() {
     }
 
     private static void putS3SK(Map<String, String> s3Options, Config config) {
-        if (!CheckConfigUtil.isValidParam(config, S3Config.S3_ACCESS_KEY.key()) && CheckConfigUtil.isValidParam(config, S3Config.S3_SECRET_KEY.key())) {
+        if (!CheckConfigUtil.isValidParam(config, S3Config.S3_ACCESS_KEY.key()) && !CheckConfigUtil.isValidParam(config, S3Config.S3_SECRET_KEY.key())) {
             return;
         }
         String accessKey = config.getString(S3Config.S3_ACCESS_KEY.key());