From d9b863a84bcd60bffd85ab9506484fcd20ff0607 Mon Sep 17 00:00:00 2001 From: Mark Payne Date: Thu, 6 Jan 2022 16:34:01 -0500 Subject: [PATCH] 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 --- .../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 e951064a17..335d8648b1 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); + } }