From 826bf3b5586a0140aa4eac953bbe85611f052a80 Mon Sep 17 00:00:00 2001 From: SSpirits Date: Fri, 3 Nov 2023 12:40:20 +0800 Subject: [PATCH] fix(controller): fix merge Signed-off-by: SSpirits --- .../rocketmq/controller/server/tasks/ReclaimS3ObjectTask.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/controller/src/main/java/com/automq/rocketmq/controller/server/tasks/ReclaimS3ObjectTask.java b/controller/src/main/java/com/automq/rocketmq/controller/server/tasks/ReclaimS3ObjectTask.java index 00ee4c64a..f1b2f13f1 100644 --- a/controller/src/main/java/com/automq/rocketmq/controller/server/tasks/ReclaimS3ObjectTask.java +++ b/controller/src/main/java/com/automq/rocketmq/controller/server/tasks/ReclaimS3ObjectTask.java @@ -70,7 +70,7 @@ public void process() throws ControllerException { ); if (!result.isEmpty()) { - s3ObjectMapper.batchDelete(result); + s3ObjectMapper.deleteByCriteria(S3ObjectCriteria.newBuilder().addAll(result).build()); streamObjectMapper.batchDelete(result); } }