no limits for streaming aggregations

metrico · Mar 2, 2023 · f08fb3c · f08fb3c
1 parent 597b2d1
commit f08fb3c
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 2 deletions.
diff --git a/parser/registry/log_range_aggregation_registry/log_range_agg_reg.js b/parser/registry/log_range_aggregation_registry/log_range_agg_reg.js
@@ -12,6 +12,8 @@ const Sql = require('@cloki/clickhouse-sql')
  * @param byWithoutName {string} name of the by_without token
  */
 const applyViaStream = (token, query, counterFn, summarizeFn, lastValue, byWithoutName) => {
+  query.limit(undefined, undefined)
+  query.ctx.matrix = true
   return _applyViaStream(token, timeShiftViaStream(token, query), counterFn, summarizeFn, lastValue, byWithoutName)
 }
 
@@ -72,7 +74,6 @@ module.exports.genericRate = genericRate
  */
 module.exports.rateStream = (token, query) => {
   const duration = getDuration(token, query)
-  query.limit(undefined, undefined)
   return applyViaStream(token, query, (sum) => {
     sum = sum || 0
     ++sum

diff --git a/parser/transpiler.js b/parser/transpiler.js
@@ -22,7 +22,7 @@ const { getPlg } = require('../plugins/engine')
 const Sql = require('@cloki/clickhouse-sql')
 const { simpleAnd } = require('./registry/stream_selector_operator_registry/stream_selector_operator_registry')
 const logger = require('../lib/logger')
-const { QrynBadRequest } = require('../common').errors
+const { QrynBadRequest } = require('../lib/handlers/errors')
 
 /**
  * @param joinLabels {boolean}