From 3b3cfea31daf6d4572d819a624a6ea7ee6cd2e92 Mon Sep 17 00:00:00 2001 From: Vsevolod Stakhov Date: Tue, 23 Apr 2019 15:44:04 +0100 Subject: [PATCH] [Minor] Clickhouse: Send rows exactly when limit is reached --- src/plugins/lua/clickhouse.lua | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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 = {} -- 2.39.5