diff --git a/tools/src/main/java/org/apache/rocketmq/tools/command/message/DumpCompactionLogCommand.java b/tools/src/main/java/org/apache/rocketmq/tools/command/message/DumpCompactionLogCommand.java index eee8f3d4bde..3941f5021ce 100644 --- a/tools/src/main/java/org/apache/rocketmq/tools/command/message/DumpCompactionLogCommand.java +++ b/tools/src/main/java/org/apache/rocketmq/tools/command/message/DumpCompactionLogCommand.java @@ -69,9 +69,9 @@ public void execute(CommandLine commandLine, Options options, RPCHook rpcHook) throw new SubCommandException("file " + fileName + " is a directory."); } - try { + try (RandomAccessFile raf = new RandomAccessFile(fileName, "rw"); + FileChannel fileChannel = raf.getChannel()) { long fileSize = Files.size(filePath); - FileChannel fileChannel = new RandomAccessFile(fileName, "rw").getChannel(); ByteBuffer buf = fileChannel.map(MapMode.READ_WRITE, 0, fileSize); int current = 0;