This is an automated email from the ASF dual-hosted git repository.
duong pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/ozone.git
The following commit(s) were added to refs/heads/master by this push:
new 1e98ebb449 HDDS-10432. Hadoop FS client write(byte[], int, int) is
very slow in streaming (#6287)
1e98ebb449 is described below
commit 1e98ebb4491c5f3d77dd56497d4f96f87558f274
Author: Duong Nguyen <[email protected]>
AuthorDate: Tue Feb 27 14:47:40 2024 -0800
HDDS-10432. Hadoop FS client write(byte[], int, int) is very slow in
streaming (#6287)
---
.../org/apache/hadoop/ozone/client/io/ByteBufferOutputStream.java | 5 +++++
1 file changed, 5 insertions(+)
diff --git
a/hadoop-hdds/client/src/main/java/org/apache/hadoop/ozone/client/io/ByteBufferOutputStream.java
b/hadoop-hdds/client/src/main/java/org/apache/hadoop/ozone/client/io/ByteBufferOutputStream.java
index 174fd8c75f..19ce31c529 100644
---
a/hadoop-hdds/client/src/main/java/org/apache/hadoop/ozone/client/io/ByteBufferOutputStream.java
+++
b/hadoop-hdds/client/src/main/java/org/apache/hadoop/ozone/client/io/ByteBufferOutputStream.java
@@ -39,6 +39,11 @@ public abstract class ByteBufferOutputStream extends
OutputStream
write(ByteBuffer.wrap(byteArray));
}
+ @Override
+ public void write(@Nonnull byte[] byteArray, int off, int len) throws
IOException {
+ write(ByteBuffer.wrap(byteArray), off, len);
+ }
+
@Override
public void write(int b) throws IOException {
write(new byte[]{(byte) b});
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
