feat: move log4j2.xml to conf (#561)

Signed-off-by: Li Zhanhui <lizhanhui@gmail.com>
AutoMQ · Nov 3, 2023 · 68b4bb3 · 68b4bb3
1 parent 826bf3b
commit 68b4bb3
Show file tree

Hide file tree

Showing 3 changed files with 13 additions and 1 deletion.
diff --git a/controller/src/main/java/com/automq/rocketmq/controller/server/tasks/RecycleS3Task.java b/controller/src/main/java/com/automq/rocketmq/controller/server/tasks/RecycleS3Task.java
@@ -69,6 +69,10 @@ public void process() throws ControllerException {
                 recyclable.addAll(streamObjectMapper.recyclable(streamIds, threshold));
             }
 
+            if (recyclable.isEmpty()) {
+                return;
+            }
+
             metadataStore.getDataStore().batchDeleteS3Objects(recyclable)
                 .whenComplete((list, e) -> {
                     if (null != e) {

diff --git a/broker/src/main/resources/log4j2.xml → distribution/conf/log4j2.xml b/broker/src/main/resources/log4j2.xml → distribution/conf/log4j2.xml
diff --git a/metadata/src/main/java/com/automq/rocketmq/metadata/s3/DefaultS3MetadataService.java b/metadata/src/main/java/com/automq/rocketmq/metadata/s3/DefaultS3MetadataService.java
@@ -119,13 +119,21 @@ public CompletableFuture<Void> commitWalObject(S3WALObject walObject,
             return CompletableFuture.failedFuture(e);
         }
 
-        LOGGER.info("commitWalObject with walObject: {}, streamObjects: {}, compactedObjects: {}",
+        LOGGER.info("commitWalObject with walObject=[{}], streamObjects=[{}], compactedObjects={}",
             TextFormat.shortDebugString(walObject),
             streamObjects.stream()
                 .map(TextFormat::shortDebugString)
                 .collect(Collectors.joining()), compactedObjects
         );
 
+        // Debug
+        for (S3StreamObject item : streamObjects) {
+            if (item.getStreamId() <= 0) {
+                LOGGER.error("Yuck, S3StreamObject is having invalid stream-id: {}",
+                    TextFormat.printer().printToString(item));
+            }
+        }
+
         CompletableFuture<Void> future = new CompletableFuture<>();
         try (SqlSession session = sessionFactory.openSession()) {
             S3WalObjectMapper s3WALObjectMapper = session.getMapper(S3WalObjectMapper.class);