diff --git a/nifi-stateless/nifi-stateless-bundle/nifi-stateless-engine/src/main/java/org/apache/nifi/stateless/repository/StatelessFileSystemContentRepository.java b/nifi-stateless/nifi-stateless-bundle/nifi-stateless-engine/src/main/java/org/apache/nifi/stateless/repository/StatelessFileSystemContentRepository.java index e1c8e0d768..025483892d 100644 --- a/nifi-stateless/nifi-stateless-bundle/nifi-stateless-engine/src/main/java/org/apache/nifi/stateless/repository/StatelessFileSystemContentRepository.java +++ b/nifi-stateless/nifi-stateless-bundle/nifi-stateless-engine/src/main/java/org/apache/nifi/stateless/repository/StatelessFileSystemContentRepository.java @@ -359,6 +359,21 @@ public class StatelessFileSystemContentRepository implements ContentRepository { this.initialOffset = out.getBytesWritten(); } + @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); + } + @Override public synchronized void close() throws IOException { if (closed) {