diff --git a/broker/src/main/java/org/apache/rocketmq/broker/processor/SendMessageProcessor.java b/broker/src/main/java/org/apache/rocketmq/broker/processor/SendMessageProcessor.java index a11fb6cc1e544522d140b1438b3721820da16979..9c42c808bf9ae8b1261386e79b55244a48b231f5 100644 --- a/broker/src/main/java/org/apache/rocketmq/broker/processor/SendMessageProcessor.java +++ b/broker/src/main/java/org/apache/rocketmq/broker/processor/SendMessageProcessor.java @@ -637,7 +637,7 @@ public class SendMessageProcessor extends AbstractSendMessageProcessor implement private String diskUtil() { double physicRatio = -1; - String storePath =this.brokerController.getMessageStoreConfig().getStorePathCommitLog(); + String storePath = this.brokerController.getMessageStoreConfig().getStorePathCommitLog(); if (storePath.contains(MessageStoreConfig.MULTI_PATH_SPLITTER)) { String[] paths = storePath.trim().split(MessageStoreConfig.MULTI_PATH_SPLITTER); for (String storePathPhysic : paths) { diff --git a/store/src/main/java/org/apache/rocketmq/store/MappedFileQueue.java b/store/src/main/java/org/apache/rocketmq/store/MappedFileQueue.java index be29e6cb64613277733f373aaa7dd6ffda56b102..9a5318812ca575d6db8d24c5fdbd887f9880f7e2 100644 --- a/store/src/main/java/org/apache/rocketmq/store/MappedFileQueue.java +++ b/store/src/main/java/org/apache/rocketmq/store/MappedFileQueue.java @@ -411,7 +411,7 @@ public class MappedFileQueue { destroy = maxOffsetInLogicQueue < offset; if (destroy) { log.info("physic min offset " + offset + ", logics in current mappedFile max offset " - + maxOffsetInLogicQueue + ", delete it"); + + maxOffsetInLogicQueue + ", delete it"); } } else if (!mappedFile.isAvailable()) { // Handle hanged file. log.warn("Found a hanged consume queue file, attempting to delete it."); @@ -479,7 +479,7 @@ public class MappedFileQueue { if (firstMappedFile != null && lastMappedFile != null) { if (offset < firstMappedFile.getFileFromOffset() || offset >= lastMappedFile.getFileFromOffset() + this.mappedFileSize) { LOG_ERROR.warn("Offset not matched. Request offset: {}, firstOffset: {}, lastOffset: {}, mappedFileSize: {}, mappedFiles count: {}", - offset, + offset, firstMappedFile.getFileFromOffset(), lastMappedFile.getFileFromOffset() + this.mappedFileSize, this.mappedFileSize, @@ -493,7 +493,7 @@ public class MappedFileQueue { } if (targetFile != null && offset >= targetFile.getFileFromOffset() - && offset < targetFile.getFileFromOffset() + this.mappedFileSize) { + && offset < targetFile.getFileFromOffset() + this.mappedFileSize) { return targetFile; } diff --git a/store/src/main/java/org/apache/rocketmq/store/MultiPathMappedFileQueue.java b/store/src/main/java/org/apache/rocketmq/store/MultiPathMappedFileQueue.java index d7a413228c894aeb8eacf5a3e6d05116988f4e9f..a81fc49979eddedb09c4799438cd88d550622d0a 100644 --- a/store/src/main/java/org/apache/rocketmq/store/MultiPathMappedFileQueue.java +++ b/store/src/main/java/org/apache/rocketmq/store/MultiPathMappedFileQueue.java @@ -18,7 +18,6 @@ package org.apache.rocketmq.store; import java.util.Arrays; -import java.util.Collection; import java.util.HashSet; import java.util.Set; import java.util.function.Supplier; diff --git a/store/src/main/java/org/apache/rocketmq/store/config/MessageStoreConfig.java b/store/src/main/java/org/apache/rocketmq/store/config/MessageStoreConfig.java index 113fba093c6c4bf8af1bc05c7cb138f6314e985f..d26577dcd2271442ed106039b848bbd89d04541e 100644 --- a/store/src/main/java/org/apache/rocketmq/store/config/MessageStoreConfig.java +++ b/store/src/main/java/org/apache/rocketmq/store/config/MessageStoreConfig.java @@ -17,9 +17,6 @@ package org.apache.rocketmq.store.config; import java.io.File; -import java.util.Arrays; -import java.util.Collections; -import java.util.List; import org.apache.rocketmq.common.annotation.ImportantField; import org.apache.rocketmq.store.ConsumeQueue; diff --git a/store/src/test/java/org/apache/rocketmq/store/MultiPathMappedFileQueueTest.java b/store/src/test/java/org/apache/rocketmq/store/MultiPathMappedFileQueueTest.java index d299df15987a0c29dc9633f78397c33b48272a7d..628ad2d91747649fc6d0960614536a769681e799 100644 --- a/store/src/test/java/org/apache/rocketmq/store/MultiPathMappedFileQueueTest.java +++ b/store/src/test/java/org/apache/rocketmq/store/MultiPathMappedFileQueueTest.java @@ -73,7 +73,7 @@ public class MultiPathMappedFileQueueTest { mappedFileQueue.load(); - assertThat(mappedFileQueue.mappedFiles.size()).isEqualTo(1025); + assertThat(mappedFileQueue.mappedFiles.size()).isEqualTo(1024); mappedFileQueue.destroy(); }