You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@nifi.apache.org by ij...@apache.org on 2019/07/12 08:24:11 UTC
[nifi] 02/02: NIFI-6419: Flush the buffers on close to ensure all
data is written.
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 <ph...@nifi.rocks>
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 <ij...@apache.org>
---
.../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);
}