This is an automated email from the ASF dual-hosted git repository.
ZanderXu pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/hadoop.git
The following commit(s) were added to refs/heads/trunk by this push:
new 3e657602a25 HDFS-17875. AtomicFileOutputStream should override
FilterOutputStream batch write API (#8197)
3e657602a25 is described below
commit 3e657602a259ea62cf33b84120477c4cc9014e97
Author: Ivan Andika <[email protected]>
AuthorDate: Wed May 6 11:07:33 2026 +0800
HDFS-17875. AtomicFileOutputStream should override FilterOutputStream batch
write API (#8197)
---
.../java/org/apache/hadoop/hdfs/util/AtomicFileOutputStream.java | 5 +++++
1 file changed, 5 insertions(+)
diff --git
a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/util/AtomicFileOutputStream.java
b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/util/AtomicFileOutputStream.java
index c6003e8b9a3..db1ee416d74 100644
---
a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/util/AtomicFileOutputStream.java
+++
b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/util/AtomicFileOutputStream.java
@@ -61,6 +61,11 @@ public AtomicFileOutputStream(File f) throws
FileNotFoundException {
tmpFile = new File(f.getParentFile(), f.getName() +
TMP_EXTENSION).getAbsoluteFile();
}
+ @Override
+ public void write(byte[] b, int off, int len) throws IOException {
+ out.write(b, off, len);
+ }
+
@Override
public void close() throws IOException {
boolean triedToClose = false, success = false;
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
