diff --git a/s3stream/pom.xml b/s3stream/pom.xml index 1a21eccc44..086fb5aadc 100644 --- a/s3stream/pom.xml +++ b/s3stream/pom.xml @@ -22,7 +22,7 @@ 4.0.0 com.automq.elasticstream s3stream - 0.6.8-SNAPSHOT + 0.6.9-SNAPSHOT 5.5.0 5.10.0 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 c30d1d4ff2..e059942b7a 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 @@ -566,8 +566,8 @@ private void checkConfig() { private void checkAvailable() { byte[] content = new Date().toString().getBytes(StandardCharsets.UTF_8); - String path = String.format("/check_available/%d", System.currentTimeMillis()); - String multipartPath = String.format("/check_available_multipart/%d", System.currentTimeMillis()); + String path = String.format("check_available/%d", System.currentTimeMillis()); + String multipartPath = String.format("check_available_multipart/%d", System.currentTimeMillis()); try { // Simple write/read/delete this.write(path, Unpooled.wrappedBuffer(content)).get(30, TimeUnit.SECONDS); diff --git a/s3stream/src/main/java/com/automq/stream/s3/operator/S3Operator.java b/s3stream/src/main/java/com/automq/stream/s3/operator/S3Operator.java index e8bf965026..b7da45a62f 100644 --- a/s3stream/src/main/java/com/automq/stream/s3/operator/S3Operator.java +++ b/s3stream/src/main/java/com/automq/stream/s3/operator/S3Operator.java @@ -46,7 +46,7 @@ default CompletableFuture rangeRead(String path, long start, long end) /** * Write data to object. * - * @param path object path. + * @param path object path. The path should not start with '/' since Aliyun OSS does not support it. * @param data data. * @param throttleStrategy throttle strategy. */