github-mirrors/VictoriaMetrics
1
0
Fork 0
mirror of https://github.com/VictoriaMetrics/VictoriaMetrics.git synced 2024-12-31 15:06:26 +00:00
Code Issues Projects Releases Packages Wiki Activity

wip

Browse source
This commit is contained in:
Aliaksandr Valialkin 2024-05-06 19:14:36 +02:00
parent 97786db05e
commit e54966456c
No known key found for this signature in database
GPG key ID: 52C003EE2BCDB9EB
1 changed files with 2 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

9
lib/logstorage/pipe_sort.go
View file

@ -38,16 +38,11 @@ func (ps *pipeSort) String() string {
} }
func (ps *pipeSort) getNeededFields() ([]string, map[string][]string) { func (ps *pipeSort) getNeededFields() ([]string, map[string][]string) {
byFields := ps.byFields return []string{"*"}, nil
neededFields := make([]string, len(byFields))
for i := range byFields {
neededFields[i] = byFields[i].name
}
return neededFields, nil
} }
func (ps *pipeSort) newPipeProcessor(workersCount int, stopCh <-chan struct{}, cancel func(), ppBase pipeProcessor) pipeProcessor { 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) shards := make([]pipeSortProcessorShard, workersCount)
for i := range shards { for i := range shards {