diff --git a/rocketmq-store/src/main/java/com/alibaba/rocketmq/store/MappedFileQueue.java b/rocketmq-store/src/main/java/com/alibaba/rocketmq/store/MappedFileQueue.java index 8d9d3ab0b4a7707d4b751cc55ad1869eca05067e..0d15ece1d243e72058d2caf27e60ac0499f25ed6 100644 --- a/rocketmq-store/src/main/java/com/alibaba/rocketmq/store/MappedFileQueue.java +++ b/rocketmq-store/src/main/java/com/alibaba/rocketmq/store/MappedFileQueue.java @@ -484,10 +484,10 @@ public class MappedFileQueue { try { return this.mappedFiles.get(index); } catch (Exception e) { - if (returnFirstOnNotFound) + if (returnFirstOnNotFound) { return mappedFile; - - LOG_ERROR.warn("findMappedFileByOffset failure. {}", UtilAll.currentStackTrace()); + } + LOG_ERROR.warn("findMappedFileByOffset failure. ", e); } } } catch (Exception e) { diff --git a/rocketmq-store/src/main/java/com/alibaba/rocketmq/store/index/IndexService.java b/rocketmq-store/src/main/java/com/alibaba/rocketmq/store/index/IndexService.java index fded74734c29abfb6854ccc4562ac6586a2fc4bf..f4f27bc3b8d295b86fa75704cba0c7bc90b51ba3 100644 --- a/rocketmq-store/src/main/java/com/alibaba/rocketmq/store/index/IndexService.java +++ b/rocketmq-store/src/main/java/com/alibaba/rocketmq/store/index/IndexService.java @@ -279,7 +279,7 @@ public class IndexService { * * @return {@link IndexFile} or null on failure. */ - private IndexFile retryGetAndCreateIndexFile() { + public IndexFile retryGetAndCreateIndexFile() { IndexFile indexFile = null; for (int times = 0; null == indexFile && times < MAX_TRY_IDX_CREATE; times++) { @@ -288,7 +288,7 @@ public class IndexService { break; try { - log.error("Tried to create index file " + times + " times"); + log.info("Tried to create index file " + times + " times"); Thread.sleep(1000); } catch (InterruptedException e) { e.printStackTrace(); diff --git a/rocketmq-store/src/test/resources/logback-test.xml b/rocketmq-store/src/test/resources/logback-test.xml index 11d429dfd8c80be79bf3c1811e0e9df96c65404e..6754c0aaf3708ae36f852d6d2de88c0e0e390818 100644 --- a/rocketmq-store/src/test/resources/logback-test.xml +++ b/rocketmq-store/src/test/resources/logback-test.xml @@ -20,6 +20,7 @@ %d{HH:mm:ss.SSS} [%thread] %-5level %logger{5} - %msg%n + UTF-8