From e54966456c72a5a94b64c7a002f42a8480465b15 Mon Sep 17 00:00:00 2001 From: Aliaksandr Valialkin Date: Mon, 6 May 2024 19:14:36 +0200 Subject: [PATCH] wip --- lib/logstorage/pipe_sort.go | 9 ++------- 1 file changed, 2 insertions(+), 7 deletions(-) diff --git a/lib/logstorage/pipe_sort.go b/lib/logstorage/pipe_sort.go index 11387c625..2e7d42d29 100644 --- a/lib/logstorage/pipe_sort.go +++ b/lib/logstorage/pipe_sort.go @@ -38,16 +38,11 @@ func (ps *pipeSort) String() string { } func (ps *pipeSort) getNeededFields() ([]string, map[string][]string) { - byFields := ps.byFields - neededFields := make([]string, len(byFields)) - for i := range byFields { - neededFields[i] = byFields[i].name - } - return neededFields, nil + return []string{"*"}, nil } func (ps *pipeSort) newPipeProcessor(workersCount int, stopCh <-chan struct{}, cancel func(), ppBase pipeProcessor) pipeProcessor { - maxStateSize := int64(float64(memory.Allowed()) * 0.3) + maxStateSize := int64(float64(memory.Allowed()) * 0.1) shards := make([]pipeSortProcessorShard, workersCount) for i := range shards {