This is an automated email from the ASF dual-hosted git repository. joewitt pushed a commit to branch support/nifi-1.15 in repository https://gitbox.apache.org/repos/asf/nifi.git
commit 667cfcd780cde9876fe09e43384207a79834f54c Author: Mark Payne <[email protected]> AuthorDate: Thu Jan 6 16:34:01 2022 -0500 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 <[email protected]> --- .../apache/nifi/stream/io/NonFlushableOutputStream.java | 15 +++++++++++++++ 1 file changed, 15 insertions(+) diff --git a/nifi-commons/nifi-utils/src/main/java/org/apache/nifi/stream/io/NonFlushableOutputStream.java b/nifi-commons/nifi-utils/src/main/java/org/apache/nifi/stream/io/NonFlushableOutputStream.java index e951064..335d864 100644 --- a/nifi-commons/nifi-utils/src/main/java/org/apache/nifi/stream/io/NonFlushableOutputStream.java +++ b/nifi-commons/nifi-utils/src/main/java/org/apache/nifi/stream/io/NonFlushableOutputStream.java @@ -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); + } }
