diff --git a/writer/writer.go b/writer/writer.go index 3efaf5e4..8c743f4d 100644 --- a/writer/writer.go +++ b/writer/writer.go @@ -220,6 +220,9 @@ func (pw *ParquetWriter) WriteStop() error { if _, err = pw.PFile.Write([]byte("PAR1")); err != nil { return err } + if err = pw.PFile.Close(); err != nil { + return err + } return nil }