fix(s3Stream): support aliyun oss (#804)

Signed-off-by: Curtis Wan <[email protected]>
AutoMQ · Mar 14, 2024 · a6ba8fa · a6ba8fa
1 parent 818d7da
commit a6ba8fa
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 4 deletions.
diff --git a/s3stream/pom.xml b/s3stream/pom.xml
@@ -22,7 +22,7 @@
     <modelVersion>4.0.0</modelVersion>
     <groupId>com.automq.elasticstream</groupId>
     <artifactId>s3stream</artifactId>
-    <version>0.6.8-SNAPSHOT</version>
+    <version>0.6.9-SNAPSHOT</version>
     <properties>
         <mockito-core.version>5.5.0</mockito-core.version>
         <junit-jupiter.version>5.10.0</junit-jupiter.version>

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
@@ -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
@@ -46,7 +46,7 @@ default CompletableFuture<ByteBuf> 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.
      */