From: Vsevolod Stakhov <vsevolod@highsecure.ru>
Date: Tue, 23 Apr 2019 14:44:04 +0000 (+0100)
Subject: [Minor] Clickhouse: Send rows exactly when limit is reached
X-Git-Tag: 1.9.3~84
X-Git-Url: http://git.ipfire.org/cgi-bin/gitweb.cgi?a=commitdiff_plain;h=3b3cfea31daf6d4572d819a624a6ea7ee6cd2e92;p=thirdparty%2Frspamd.git

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

diff --git a/src/plugins/lua/clickhouse.lua b/src/plugins/lua/clickhouse.lua
index 7482da01eb..c3be9e2d9d 100644
--- 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 = {}