Apache
/
nifi
mirror of https://github.com/apache/nifi.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

NIFI-9549: Delegate NonFlushableOutputStream write methods to wrapped OutputStream 

Ensure that we delegate calls to write(byte[]) and write(byte[], int, int) to the underlying OutputStream for NonFlushableOutputStream, instead of allowing FilterOutputStream to iterate over every byte

This closes #5642

Signed-off-by: David Handermann <exceptionfactory@apache.org>
This commit is contained in:
Mark Payne 2022-01-06 16:34:01 -05:00 committed by exceptionfactory
parent 56593ad12f
commit d9b863a84b
No known key found for this signature in database
GPG Key ID: 29B6A52D2AAE8DBA
1 changed files with 15 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
nifi-commons/nifi-utils/src/main/java/org/apache/nifi/stream/io/NonFlushableOutputStream.java
View File

@ -34,4 +34,19 @@ public class NonFlushableOutputStream extends FilterOutputStream {
public void close() throws IOException {
out.close();
}
@Override
public void write(final byte[] b, final int off, final int len) throws IOException {
out.write(b, off, len);
}
@Override
public void write(final byte[] b) throws IOException {
out.write(b);
}
@Override
public void write(final int b) throws IOException {
out.write(b);
}
}