From ee5fd5f6b874eda30a3e80bc6d20cfb5984b39c5 Mon Sep 17 00:00:00 2001 From: taloric Date: Thu, 29 Jun 2023 22:36:18 +0800 Subject: [PATCH] [querier] add record count for stats --- server/querier/statsd/statsd.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/server/querier/statsd/statsd.go b/server/querier/statsd/statsd.go index 7ce1e9785a9..173e64f9b00 100644 --- a/server/querier/statsd/statsd.go +++ b/server/querier/statsd/statsd.go @@ -54,7 +54,7 @@ func (c *Counter) WriteCk(qc *ClickhouseCounter) { defer c.writeCkM.Unlock() c.ck.ResponseSize += qc.ResponseSize c.ck.RowCount += qc.RowCount - c.ck.ColumnCount += qc.ColumnCount + c.ck.ColumnCount += qc.ColumnCount * qc.RowCount c.ck.QueryCount++ c.ck.QueryTimeSum += qc.QueryTime