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

NIFI-9364: Ensure that we delegate calls to write(byte[]) and write(byte[], int, int) to the underlying OutputStream when writing to the file-based content repository for stateless 

Signed-off-by: Joe Gresock <jgresock@gmail.com>

This closes #5508.
This commit is contained in:
Mark Payne 2021-11-04 13:08:52 -04:00 committed by Joe Gresock
parent 9b724df6d9
commit 373498445f
No known key found for this signature in database
GPG Key ID: 37F5B9B6E258C8B7
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-stateless/nifi-stateless-bundle/nifi-stateless-engine/src/main/java/org/apache/nifi/stateless/repository/StatelessFileSystemContentRepository.java
View File

@ -359,6 +359,21 @@ public class StatelessFileSystemContentRepository implements ContentRepository {
this.initialOffset = out.getBytesWritten(); 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 @Override
public synchronized void close() throws IOException { public synchronized void close() throws IOException {
if (closed) { if (closed) {