You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ratis.apache.org by sz...@apache.org on 2025/05/25 15:38:34 UTC
(ratis) 23/49: RATIS-2260. AtomicFileOutputStream should truncate temp file (#1237)
This is an automated email from the ASF dual-hosted git repository.
szetszwo pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/ratis.git
commit f80e0041165a9ac53f52abb35a3a49e7fae7b9f9
Author: Doroszlai, Attila <64...@users.noreply.github.com>
AuthorDate: Mon Mar 17 18:47:59 2025 +0100
RATIS-2260. AtomicFileOutputStream should truncate temp file (#1237)
---
.../main/java/org/apache/ratis/util/AtomicFileOutputStream.java | 7 +++++--
1 file changed, 5 insertions(+), 2 deletions(-)
diff --git a/ratis-common/src/main/java/org/apache/ratis/util/AtomicFileOutputStream.java b/ratis-common/src/main/java/org/apache/ratis/util/AtomicFileOutputStream.java
index 530eb383c..b54427066 100644
--- a/ratis-common/src/main/java/org/apache/ratis/util/AtomicFileOutputStream.java
+++ b/ratis-common/src/main/java/org/apache/ratis/util/AtomicFileOutputStream.java
@@ -17,6 +17,10 @@
*/
package org.apache.ratis.util;
+import static java.nio.file.StandardOpenOption.CREATE;
+import static java.nio.file.StandardOpenOption.TRUNCATE_EXISTING;
+import static java.nio.file.StandardOpenOption.WRITE;
+
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -24,7 +28,6 @@ import java.io.File;
import java.io.FilterOutputStream;
import java.io.IOException;
import java.nio.file.StandardCopyOption;
-import java.nio.file.StandardOpenOption;
import java.util.concurrent.atomic.AtomicBoolean;
/**
@@ -60,7 +63,7 @@ public class AtomicFileOutputStream extends FilterOutputStream {
}
public AtomicFileOutputStream(File outFile, File tmpFile) throws IOException {
- super(FileUtils.newOutputStreamForceAtClose(tmpFile, StandardOpenOption.CREATE, StandardOpenOption.WRITE));
+ super(FileUtils.newOutputStreamForceAtClose(tmpFile, CREATE, TRUNCATE_EXISTING, WRITE));
this.outFile = outFile.getAbsoluteFile();
this.tmpFile = tmpFile.getAbsoluteFile();
}