Flush the buffers on close to ensure all data is written.
This closes
@@ -103,6 +103,7 @@ public class WriteAvroResultWithExternalSchema extends AbstractRecordSetWriter {
@Override
public void close() throws IOException {
if (encoder != null) {
+ flush();
recycleQueue.offer(encoder);
}
