[Minor] Clickhouse: Send rows exactly when limit is reached

rspamd · Apr 23, 2019 · 3b3cfea · 3b3cfea
1 parent babeb8b
commit 3b3cfea
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/plugins/lua/clickhouse.lua b/src/plugins/lua/clickhouse.lua
@@ -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 = {}