diff --git a/src/main/java/io/openmessaging/storage/dledger/store/file/DLedgerMmapFileStore.java b/src/main/java/io/openmessaging/storage/dledger/store/file/DLedgerMmapFileStore.java index 0f86f4b0..dad87ddc 100644 --- a/src/main/java/io/openmessaging/storage/dledger/store/file/DLedgerMmapFileStore.java +++ b/src/main/java/io/openmessaging/storage/dledger/store/file/DLedgerMmapFileStore.java @@ -632,8 +632,9 @@ public FlushDataService(String name, Logger logger) { long start = System.currentTimeMillis(); DLedgerMmapFileStore.this.dataFileList.flush(0); DLedgerMmapFileStore.this.indexFileList.flush(0); - if (DLedgerUtils.elapsed(start) > 500) { - logger.info("Flush data cost={} ms", DLedgerUtils.elapsed(start)); + long elapsed; + if ((elapsed = DLedgerUtils.elapsed(start)) > 500) { + logger.info("Flush data cost={} ms", elapsed); } if (DLedgerUtils.elapsed(lastCheckPointTimeMs) > dLedgerConfig.getCheckPointInterval()) {