From 4711bf28f0fb823063cac65786ac7cfa3feea28e Mon Sep 17 00:00:00 2001 From: Alexander Date: Fri, 26 Jan 2024 13:48:03 +0100 Subject: [PATCH] feat(backend): small improvements in CH client --- ee/backend/pkg/db/clickhouse/connector.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/ee/backend/pkg/db/clickhouse/connector.go b/ee/backend/pkg/db/clickhouse/connector.go index 77b5353b4..a0f88b973 100644 --- a/ee/backend/pkg/db/clickhouse/connector.go +++ b/ee/backend/pkg/db/clickhouse/connector.go @@ -51,7 +51,7 @@ type task struct { } func NewTask() *task { - return &task{bulks: make([]Bulk, 0, 14)} + return &task{bulks: make([]Bulk, 0, 21)} } type connectorImpl struct { @@ -95,7 +95,7 @@ func NewConnector(url string) Connector { c := &connectorImpl{ conn: conn, - batches: make(map[string]Bulk, 13), + batches: make(map[string]Bulk, 20), workerTask: make(chan *task, 1), done: make(chan struct{}), finished: make(chan struct{}), @@ -152,7 +152,7 @@ func (c *connectorImpl) Commit() error { for _, b := range c.batches { newTask.bulks = append(newTask.bulks, b) } - c.batches = make(map[string]Bulk, 13) + c.batches = make(map[string]Bulk, 20) if err := c.Prepare(); err != nil { log.Printf("can't prepare new CH batch set: %s", err) }