From 5c317a6b48869a6be2e482e3ba89431911a5671b Mon Sep 17 00:00:00 2001 From: Robin Han Date: Wed, 3 Jul 2024 17:42:55 +0800 Subject: [PATCH] fix(s3stream): fix s3 readiness check Signed-off-by: Robin Han --- .../java/com/automq/stream/s3/operator/AwsObjectStorage.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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();