thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-11-22 07:31:57 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix flakiness of async insert tests due to adaptative timeout

Browse Source
This commit is contained in:
Raúl Marín 2024-07-19 16:13:36 +02:00
parent b1b5123a6a
commit e91c4b2e05
3 changed files with 8 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
tests/queries/0_stateless/02726_async_insert_flush_queue.sql
View File

@ -6,7 +6,8 @@ CREATE TABLE t_async_inserts_flush (a UInt64) ENGINE = Memory;
SET async_insert = 1;
SET wait_for_async_insert = 0;
SET async_insert_busy_timeout_min_ms = 1000000;
-- Disable adaptive timeout to prevent immediate push of the first message (if the queue last push was old)
SET async_insert_use_adaptive_busy_timeout=0;
SET async_insert_busy_timeout_max_ms = 10000000;
INSERT INTO t_async_inserts_flush VALUES (1) (2);

4
tests/queries/0_stateless/02884_async_insert_skip_settings.reference
View File

@ -1,5 +1,5 @@
4
pending to flush 4
1
1
2
1
flush queries 1

7
tests/queries/0_stateless/02884_async_insert_skip_settings.sql
View File

@ -9,7 +9,8 @@ ORDER BY id;
SET async_insert = 1;
SET async_insert_deduplicate = 1;
SET wait_for_async_insert = 0;
SET async_insert_busy_timeout_min_ms = 100000;
-- Disable adaptive timeout to prevent immediate push of the first message (if the queue last push was old)
SET async_insert_use_adaptive_busy_timeout=0;
SET async_insert_busy_timeout_max_ms = 1000000;
SET insert_deduplication_token = '1';
@ -30,7 +31,7 @@ INSERT INTO t_async_insert_skip_settings VALUES (2);
SYSTEM FLUSH LOGS;
SELECT length(entries.bytes) FROM system.asynchronous_inserts
SELECT 'pending to flush', length(entries.bytes) FROM system.asynchronous_inserts
WHERE database = currentDatabase() AND table = 't_async_insert_skip_settings'
ORDER BY first_update;
@ -40,7 +41,7 @@ SELECT * FROM t_async_insert_skip_settings ORDER BY id;
SYSTEM FLUSH LOGS;
SELECT uniqExact(flush_query_id) FROM system.asynchronous_insert_log
SELECT 'flush queries', uniqExact(flush_query_id) FROM system.asynchronous_insert_log
WHERE database = currentDatabase() AND table = 't_async_insert_skip_settings';
DROP TABLE t_async_insert_skip_settings SYNC;