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
The following commit(s) were added to refs/heads/master by this push:
new 0bc5aad71 RATIS-2260. AtomicFileOutputStream should truncate temp file
(#1237)
0bc5aad71 is described below
commit 0bc5aad71ff735e923b2492edbde9a803c682078
Author: Doroszlai, Attila <[email protected]>
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();
}