diff options
| author | Vsevolod Stakhov <vsevolod@highsecure.ru> | 2019-04-23 15:44:04 +0100 |
|---|---|---|
| committer | Vsevolod Stakhov <vsevolod@highsecure.ru> | 2019-04-23 15:44:04 +0100 |
| commit | 3b3cfea31daf6d4572d819a624a6ea7ee6cd2e92 (patch) | |
| tree | 914c5c59f2f2dfd479db177474b7667fae0cff07 /src/plugins | |
| parent | babeb8beaa4560f0a273cc193d739df05b94db49 (diff) | |
| download | rspamd-3b3cfea31daf6d4572d819a624a6ea7ee6cd2e92.tar.gz rspamd-3b3cfea31daf6d4572d819a624a6ea7ee6cd2e92.zip | |
[Minor] Clickhouse: Send rows exactly when limit is reached
Diffstat (limited to 'src/plugins')
| -rw-r--r-- | src/plugins/lua/clickhouse.lua | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/src/plugins/lua/clickhouse.lua b/src/plugins/lua/clickhouse.lua index 7482da01e..c3be9e2d9 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 = {} |