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); + } }