diff --git a/src/Parquet/File/DataColumnWriter.cs b/src/Parquet/File/DataColumnWriter.cs index 9f1cf3b8..d530393d 100644 --- a/src/Parquet/File/DataColumnWriter.cs +++ b/src/Parquet/File/DataColumnWriter.cs @@ -84,7 +84,8 @@ private async Task CompressAndWriteAsync( ph.Write(new Meta.Proto.ThriftCompactProtocolWriter(headerMs)); int headerSize = (int)headerMs.Length; headerMs.Position = 0; - _stream.Flush(); + // there used to be a flush here, but removed in #432 due to excessive flushing on expensive streams + await headerMs.CopyToAsync(_stream); // write data diff --git a/src/Parquet/ParquetOptions.cs b/src/Parquet/ParquetOptions.cs index da186651..9a6bb7f1 100644 --- a/src/Parquet/ParquetOptions.cs +++ b/src/Parquet/ParquetOptions.cs @@ -6,6 +6,7 @@ namespace Parquet { /// Parquet options /// public class ParquetOptions { + /// /// When true byte arrays will be treated as UTF-8 strings on read ///