diff --git a/common/src/main/java/org/apache/rocketmq/common/MixAll.java b/common/src/main/java/org/apache/rocketmq/common/MixAll.java index efde29a891b..70e82230b17 100644 --- a/common/src/main/java/org/apache/rocketmq/common/MixAll.java +++ b/common/src/main/java/org/apache/rocketmq/common/MixAll.java @@ -249,7 +249,9 @@ public static synchronized void fsyncDirectory(Path dir) throws IOException { if (!Files.isDirectory(dir)) { throw new NotDirectoryException(dir.toString()); } - + if (isWindows()) { + return; + } try (FileChannel fc = FileChannel.open(dir, StandardOpenOption.READ)) { fc.force(true); }