From fcd7314c399f4d9eb8fa0dc257806430ae92028d Mon Sep 17 00:00:00 2001 From: Alex Sharov Date: Thu, 20 Oct 2022 18:29:46 +0700 Subject: [PATCH] compress: to use less ram (#691) --- compress/compress.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/compress/compress.go b/compress/compress.go index 1cc8b9ce0..d50be426a 100644 --- a/compress/compress.go +++ b/compress/compress.go @@ -95,7 +95,7 @@ func NewCompressor(ctx context.Context, logPrefix, outputFile, tmpDir string, mi wg.Add(workers) suffixCollectors := make([]*etl.Collector, workers) for i := 0; i < workers; i++ { - collector := etl.NewCollector(logPrefix+"_dict", tmpDir, etl.NewSortableBuffer(etl.BufferOptimalSize)) + collector := etl.NewCollector(logPrefix+"_dict", tmpDir, etl.NewSortableBuffer(etl.BufferOptimalSize/2)) collector.LogLvl(lvl) suffixCollectors[i] = collector