We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent f80753f commit 9388842Copy full SHA for 9388842
1 file changed
common/src/main/java/org/apache/rocketmq/common/MixAll.java
@@ -249,7 +249,9 @@ public static synchronized void fsyncDirectory(Path dir) throws IOException {
249
if (!Files.isDirectory(dir)) {
250
throw new NotDirectoryException(dir.toString());
251
}
252
-
+ if (isWindows()) {
253
+ return;
254
+ }
255
try (FileChannel fc = FileChannel.open(dir, StandardOpenOption.READ)) {
256
fc.force(true);
257
0 commit comments