Skip to content

Commit 5ea1012

Browse files
committed
nsq_to_file: don't open multiple GZIP streams
This changes the structure of output files to be continuous GZIP streams rather than concatenated GZIP streams. This is likely slightly more compatible and expected.
1 parent 64c8c24 commit 5ea1012

File tree

1 file changed

+5
-8
lines changed

1 file changed

+5
-8
lines changed

apps/nsq_to_file/file_logger.go

+5-8
Original file line numberDiff line numberDiff line change
@@ -212,16 +212,13 @@ func (f *FileLogger) Write(p []byte) (int, error) {
212212
}
213213

214214
func (f *FileLogger) Sync() error {
215-
var err error
216215
if f.gzipWriter != nil {
217-
f.gzipWriter.Close()
218-
err = f.out.Sync()
219-
f.gzipWriter, _ = gzip.NewWriterLevel(f, f.opts.GZIPLevel)
220-
f.writer = f.gzipWriter
221-
} else {
222-
err = f.out.Sync()
216+
err := f.gzipWriter.Flush()
217+
if err != nil {
218+
return err
219+
}
223220
}
224-
return err
221+
return f.out.Sync()
225222
}
226223

227224
func (f *FileLogger) currentFilename() string {

0 commit comments

Comments
 (0)