From fa43d53c91992cab735d57e2b5c7f4d52e90bf19 Mon Sep 17 00:00:00 2001 From: SSpirits Date: Thu, 4 Jan 2024 11:08:03 +0800 Subject: [PATCH] feat(s3stream): remove the logic that checks if the bucket exists (#880) Signed-off-by: SSpirits --- .../java/com/automq/stream/s3/operator/DefaultS3Operator.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/s3stream/src/main/java/com/automq/stream/s3/operator/DefaultS3Operator.java b/s3stream/src/main/java/com/automq/stream/s3/operator/DefaultS3Operator.java index e05b2330a..65a04cfbd 100644 --- a/s3stream/src/main/java/com/automq/stream/s3/operator/DefaultS3Operator.java +++ b/s3stream/src/main/java/com/automq/stream/s3/operator/DefaultS3Operator.java @@ -600,7 +600,7 @@ private void checkAvailable(S3Utils.S3Context s3Context) { String multipartPath = String.format("check_available_multipart/%d", System.nanoTime()); try { // Check network and bucket - readS3Client.getBucketAcl(b -> b.bucket(bucket)).get(3, TimeUnit.SECONDS); +// readS3Client.getBucketAcl(b -> b.bucket(bucket)).get(3, TimeUnit.SECONDS); // Simple write/read/delete this.write(path, Unpooled.wrappedBuffer(content)).get(30, TimeUnit.SECONDS);