]> git.ipfire.org Git - thirdparty/rspamd.git/commitdiff
[Minor] Clickhouse: Send rows exactly when limit is reached
authorVsevolod Stakhov <vsevolod@highsecure.ru>
Tue, 23 Apr 2019 14:44:04 +0000 (15:44 +0100)
committerVsevolod Stakhov <vsevolod@highsecure.ru>
Tue, 23 Apr 2019 14:44:04 +0000 (15:44 +0100)
src/plugins/lua/clickhouse.lua

index 7482da01eba9e5f1a22af066c9faaeb6cdb77d0d..c3be9e2d9d4e5c3bdd068c0d0cbd98bc1c329e7a 100644 (file)
@@ -745,7 +745,7 @@ local function clickhouse_collect(task)
   table.insert(data_rows, row)
   lua_util.debugm(N, task, "add clickhouse row %s / %s", nrows, settings.limit)
 
-  if nrows > settings['limit'] then
+  if nrows >= settings['limit'] then
     clickhouse_send_data(task)
     nrows = 0
     data_rows = {}