[querier] add record count for stats

deepflowio · Jul 2, 2023 · ee5fd5f · ee5fd5f
1 parent 1da95e4
commit ee5fd5f
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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