Apache/nifi
1
0
Fork 0
mirror of https://github.com/apache/nifi.git synced 2025-02-09 03:25:04 +00:00
Code Issues Packages Projects Releases Wiki Activity

NIFI-6419: Flush the buffers on close to ensure all data is written.

Browse Source 
This closes #3568.

Signed-off-by: Koji Kawamura <ijokarumawak@apache.org>
This commit is contained in:
Phillip Grenier 2019-07-03 13:47:15 -04:00 committed by Koji Kawamura
parent 24e50953a3
commit e277545cea
No known key found for this signature in database
GPG Key ID: 36136B0EC89E4758
1 changed files with 1 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
nifi-nar-bundles/nifi-standard-services/nifi-record-serialization-services-bundle/nifi-record-serialization-services/src/main/java/org/apache/nifi/avro/WriteAvroResultWithExternalSchema.java
View File

@ -103,6 +103,7 @@ public class WriteAvroResultWithExternalSchema extends AbstractRecordSetWriter {
@Override
public void close() throws IOException {
if (encoder != null) {
flush();
recycleQueue.offer(encoder);
}