thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-09-20 00:30:49 +00:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #61259 from qoega/flaky-01603

Browse Source
This commit is contained in:
Ilya Yatsishin 2024-03-14 02:46:47 +04:00 committed by GitHub
commit fdd249fcba
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
3 changed files with 19 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
tests/queries/0_stateless/01603_insert_select_too_many_parts.sql
View File

@ -7,7 +7,8 @@ SET max_block_size = 1, min_insert_block_size_rows = 0, min_insert_block_size_by
SET max_threads=1, max_insert_threads=1;
-- exception is not thrown if threshold is exceeded when multi-block INSERT is already started.
INSERT INTO too_many_parts SELECT * FROM numbers(10);
-- Single thread is used as different threads check it separately https://github.com/ClickHouse/ClickHouse/issues/61158
INSERT INTO too_many_parts SELECT * FROM numbers(10) SETTINGS max_insert_threads=1;
SELECT count() FROM too_many_parts;
-- exception is thrown if threshold is exceeded on new INSERT.

1
tests/queries/0_stateless/02997_insert_select_too_many_parts_multithread.reference Normal file
View File

@ -0,0 +1 @@
100

16
tests/queries/0_stateless/02997_insert_select_too_many_parts_multithread.sql Normal file
View File

@ -0,0 +1,16 @@
-- Tags: disabled
-- TODO: Fix parts_to_throw_insert logic for parallel MergeTreeSink onStart calls
DROP TABLE IF EXISTS too_many_parts;
CREATE TABLE too_many_parts (x UInt64) ENGINE = MergeTree ORDER BY tuple() SETTINGS parts_to_delay_insert = 5, parts_to_throw_insert = 5;
SYSTEM STOP MERGES too_many_parts;
SET max_block_size = 1, min_insert_block_size_rows = 0, min_insert_block_size_bytes = 0, max_threads=100, max_insert_threads=100;
-- exception is not thrown if threshold is exceeded when multi-block INSERT is already started.
INSERT INTO too_many_parts SELECT * FROM numbers_mt(100);
SELECT count() FROM too_many_parts;
INSERT INTO too_many_parts SELECT * FROM numbers_mt(10); -- { serverError 252 }
DROP TABLE too_many_parts;