This is an automated email from the ASF dual-hosted git repository. ijokarumawak pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/nifi.git
commit e277545cea0bfc79fd7fc54c77a3d873df3853d1 Author: Phillip Grenier <[email protected]> AuthorDate: Wed Jul 3 13:47:15 2019 -0400 NIFI-6419: Flush the buffers on close to ensure all data is written. This closes #3568. Signed-off-by: Koji Kawamura <[email protected]> --- .../java/org/apache/nifi/avro/WriteAvroResultWithExternalSchema.java | 1 + 1 file changed, 1 insertion(+) diff --git a/nifi-nar-bundles/nifi-standard-services/nifi-record-serialization-services-bundle/nifi-record-serialization-services/src/main/java/org/apache/nifi/avro/WriteAvroResultWithExternalSchema.java b/nifi-nar-bundles/nifi-standard-services/nifi-record-serialization-services-bundle/nifi-record-serialization-services/src/main/java/org/apache/nifi/avro/WriteAvroResultWithExternalSchema.java index a50efa0..a457f96 100644 --- a/nifi-nar-bundles/nifi-standard-services/nifi-record-serialization-services-bundle/nifi-record-serialization-services/src/main/java/org/apache/nifi/avro/WriteAvroResultWithExternalSchema.java +++ b/nifi-nar-bundles/nifi-standard-services/nifi-record-serialization-services-bundle/nifi-record-serialization-services/src/main/java/org/apache/nifi/avro/WriteAvroResultWithExternalSchema.java @@ -103,6 +103,7 @@ public class WriteAvroResultWithExternalSchema extends AbstractRecordSetWriter { @Override public void close() throws IOException { if (encoder != null) { + flush(); recycleQueue.offer(encoder); }
