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

Fix 03006_parallel_replicas_prewhere

Browse Source
This commit is contained in:
Igor Nikonov 2024-06-11 13:25:19 +00:00
parent bb57e0bc9c
commit 23ca8608ba
2 changed files with 12 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
tests/queries/0_stateless/03006_parallel_replicas_prewhere.reference
View File

@ -0,0 +1 @@
default url_na_log 1 130000 130

12
tests/queries/0_stateless/03006_parallel_replicas_prewhere.sql
View File

@ -21,11 +21,21 @@ SELECT
FROM numbers(130000) FROM numbers(130000)
SETTINGS max_insert_block_size = 200000; SETTINGS max_insert_block_size = 200000;
SET max_block_size = 1048576, max_threads = 1, allow_experimental_parallel_reading_from_replicas = 1, parallel_replicas_for_non_replicated_merge_tree = 1, cluster_for_parallel_replicas = 'test_cluster_one_shard_three_replicas_localhost', max_parallel_replicas = 3, parallel_replicas_min_number_of_rows_per_replica=10000;
EXPLAIN ESTIMATE EXPLAIN ESTIMATE
SELECT count() SELECT count()
FROM url_na_log FROM url_na_log
PREWHERE (DateVisit >= toFixedString('2022-08-10', 10)) AND (DateVisit <= '2022-08-20') PREWHERE (DateVisit >= toFixedString('2022-08-10', 10)) AND (DateVisit <= '2022-08-20')
SETTINGS max_block_size = 1048576, max_threads = 1, allow_experimental_parallel_reading_from_replicas = 1, parallel_replicas_for_non_replicated_merge_tree = 1, cluster_for_parallel_replicas = 'test_cluster_one_shard_three_replicas_localhost', max_parallel_replicas = 3, parallel_replicas_min_number_of_rows_per_replica=10000; SETTINGS allow_experimental_analyzer=0;
-- here parallel replicas uses local snapshot as working set
-- so, the estimation can be done
EXPLAIN ESTIMATE
SELECT count()
FROM url_na_log
PREWHERE (DateVisit >= toFixedString('2022-08-10', 10)) AND (DateVisit <= '2022-08-20')
SETTINGS allow_experimental_analyzer=1;
DROP POLICY url_na_log_policy0 ON url_na_log; DROP POLICY url_na_log_policy0 ON url_na_log;
DROP TABLE url_na_log; DROP TABLE url_na_log;