diff --git a/s3stream/src/main/java/com/automq/stream/s3/operator/AwsObjectStorage.java b/s3stream/src/main/java/com/automq/stream/s3/operator/AwsObjectStorage.java index 71aefb9384..4b044f140e 100644 --- a/s3stream/src/main/java/com/automq/stream/s3/operator/AwsObjectStorage.java +++ b/s3stream/src/main/java/com/automq/stream/s3/operator/AwsObjectStorage.java @@ -273,7 +273,7 @@ private String range(long start, long end) { private void readinessCheck() { try { - String path = "/automq/readiness_check/%d" + System.nanoTime(); + String path = "__automq/readiness_check/%d" + System.nanoTime(); byte[] content = new Date().toString().getBytes(StandardCharsets.UTF_8); doWrite(new WriteOptions(), path, Unpooled.wrappedBuffer(content)).get(); doDeleteObjects(List.of(path)).get();