mirror of
https://github.com/ClickHouse/ClickHouse.git
synced 2024-09-19 16:20:50 +00:00
Simplify tests/queries/0_stateless/02967_parallel_replicas_join_algo_and_analyzer_3.sh
+ enable parallel_replicas_local_plan by default
This commit is contained in:
parent
d711ec118c
commit
bce0f46254
@ -21,23 +21,21 @@ insert into num_2 select number * 3, -number from numbers(1.5e6);
|
|||||||
echo
|
echo
|
||||||
echo "nested join with analyzer and parallel replicas, both global"
|
echo "nested join with analyzer and parallel replicas, both global"
|
||||||
|
|
||||||
$CLICKHOUSE_CLIENT -q "
|
PARALLEL_REPLICAS_SETTINGS="allow_experimental_parallel_reading_from_replicas = 2, max_parallel_replicas = 2, parallel_replicas_for_non_replicated_merge_tree = 1, cluster_for_parallel_replicas = 'test_cluster_one_shard_three_replicas_localhost', parallel_replicas_local_plan=1"
|
||||||
select * from (select key, value from num_1) l
|
|
||||||
inner join (select key, value from num_2 inner join
|
|
||||||
(select number * 7 as key from numbers(1e5)) as nn on num_2.key = nn.key settings parallel_replicas_prefer_local_join=0) r
|
|
||||||
on l.key = r.key order by l.key limit 10 offset 10000
|
|
||||||
SETTINGS allow_experimental_analyzer=1,
|
|
||||||
allow_experimental_parallel_reading_from_replicas = 2, max_parallel_replicas = 2, parallel_replicas_for_non_replicated_merge_tree = 1,
|
|
||||||
cluster_for_parallel_replicas = 'test_cluster_one_shard_three_replicas_localhost', parallel_replicas_prefer_local_join=0"
|
|
||||||
|
|
||||||
$CLICKHOUSE_CLIENT -q "
|
$CLICKHOUSE_CLIENT -q "
|
||||||
select * from (select key, value from num_1) l
|
select * from (select key, value from num_1) l
|
||||||
inner join (select key, value from num_2 inner join
|
inner join (select key, value from num_2 inner join
|
||||||
(select number * 7 as key from numbers(1e5)) as nn on num_2.key = nn.key settings parallel_replicas_prefer_local_join=0) r
|
(select number * 7 as key from numbers(1e5)) as nn on num_2.key = nn.key settings parallel_replicas_prefer_local_join=0) r
|
||||||
on l.key = r.key order by l.key limit 10 offset 10000
|
on l.key = r.key order by l.key limit 10 offset 10000
|
||||||
SETTINGS allow_experimental_analyzer=1, send_logs_level='trace',
|
SETTINGS allow_experimental_analyzer=1, $PARALLEL_REPLICAS_SETTINGS, parallel_replicas_prefer_local_join=0"
|
||||||
allow_experimental_parallel_reading_from_replicas = 2, max_parallel_replicas = 2, parallel_replicas_for_non_replicated_merge_tree = 1,
|
|
||||||
cluster_for_parallel_replicas = 'test_cluster_one_shard_three_replicas_localhost', parallel_replicas_prefer_local_join=0" 2>&1 |
|
$CLICKHOUSE_CLIENT -q "
|
||||||
|
select * from (select key, value from num_1) l
|
||||||
|
inner join (select key, value from num_2 inner join
|
||||||
|
(select number * 7 as key from numbers(1e5)) as nn on num_2.key = nn.key settings parallel_replicas_prefer_local_join=0) r
|
||||||
|
on l.key = r.key order by l.key limit 10 offset 10000
|
||||||
|
SETTINGS allow_experimental_analyzer=1, send_logs_level='trace', $PARALLEL_REPLICAS_SETTINGS, parallel_replicas_prefer_local_join=0" 2>&1 |
|
||||||
grep "executeQuery\|<Debug>.*Coordinator: Coordination done" |
|
grep "executeQuery\|<Debug>.*Coordinator: Coordination done" |
|
||||||
grep -o "SELECT.*WithMergeableState)\|<Debug>.*Coordinator: Coordination done" |
|
grep -o "SELECT.*WithMergeableState)\|<Debug>.*Coordinator: Coordination done" |
|
||||||
sed -re 's/_data_[[:digit:]]+_[[:digit:]]+/_data_/g'
|
sed -re 's/_data_[[:digit:]]+_[[:digit:]]+/_data_/g'
|
||||||
@ -51,18 +49,14 @@ select * from (select key, value from num_1) l
|
|||||||
inner join (select key, value from num_2 inner join
|
inner join (select key, value from num_2 inner join
|
||||||
(select number * 7 as key from numbers(1e5)) as nn on num_2.key = nn.key settings parallel_replicas_prefer_local_join=1) r
|
(select number * 7 as key from numbers(1e5)) as nn on num_2.key = nn.key settings parallel_replicas_prefer_local_join=1) r
|
||||||
on l.key = r.key order by l.key limit 10 offset 10000
|
on l.key = r.key order by l.key limit 10 offset 10000
|
||||||
SETTINGS allow_experimental_analyzer=1,
|
SETTINGS allow_experimental_analyzer=1, $PARALLEL_REPLICAS_SETTINGS, parallel_replicas_prefer_local_join=0"
|
||||||
allow_experimental_parallel_reading_from_replicas = 2, max_parallel_replicas = 2, parallel_replicas_for_non_replicated_merge_tree = 1,
|
|
||||||
cluster_for_parallel_replicas = 'test_cluster_one_shard_three_replicas_localhost', parallel_replicas_prefer_local_join=0"
|
|
||||||
|
|
||||||
$CLICKHOUSE_CLIENT -q "
|
$CLICKHOUSE_CLIENT -q "
|
||||||
select * from (select key, value from num_1) l
|
select * from (select key, value from num_1) l
|
||||||
inner join (select key, value from num_2 inner join
|
inner join (select key, value from num_2 inner join
|
||||||
(select number * 7 as key from numbers(1e5)) as nn on num_2.key = nn.key settings parallel_replicas_prefer_local_join=1) r
|
(select number * 7 as key from numbers(1e5)) as nn on num_2.key = nn.key settings parallel_replicas_prefer_local_join=1) r
|
||||||
on l.key = r.key order by l.key limit 10 offset 10000
|
on l.key = r.key order by l.key limit 10 offset 10000
|
||||||
SETTINGS allow_experimental_analyzer=1, send_logs_level='trace',
|
SETTINGS allow_experimental_analyzer=1, send_logs_level='trace', $PARALLEL_REPLICAS_SETTINGS, parallel_replicas_prefer_local_join=0" 2>&1 |
|
||||||
allow_experimental_parallel_reading_from_replicas = 2, max_parallel_replicas = 2, parallel_replicas_for_non_replicated_merge_tree = 1,
|
|
||||||
cluster_for_parallel_replicas = 'test_cluster_one_shard_three_replicas_localhost', parallel_replicas_prefer_local_join=0" 2>&1 |
|
|
||||||
grep "executeQuery\|<Debug>.*Coordinator: Coordination done" |
|
grep "executeQuery\|<Debug>.*Coordinator: Coordination done" |
|
||||||
grep -o "SELECT.*WithMergeableState)\|<Debug>.*Coordinator: Coordination done" |
|
grep -o "SELECT.*WithMergeableState)\|<Debug>.*Coordinator: Coordination done" |
|
||||||
sed -re 's/_data_[[:digit:]]+_[[:digit:]]+/_data_/g'
|
sed -re 's/_data_[[:digit:]]+_[[:digit:]]+/_data_/g'
|
||||||
@ -77,18 +71,14 @@ select * from (select key, value from num_1) l
|
|||||||
inner join (select key, value from num_2 inner join
|
inner join (select key, value from num_2 inner join
|
||||||
(select number * 7 as key from numbers(1e5)) as nn on num_2.key = nn.key settings join_algorithm='full_sorting_merge') r
|
(select number * 7 as key from numbers(1e5)) as nn on num_2.key = nn.key settings join_algorithm='full_sorting_merge') r
|
||||||
on l.key = r.key order by l.key limit 10 offset 10000
|
on l.key = r.key order by l.key limit 10 offset 10000
|
||||||
SETTINGS allow_experimental_analyzer=1, parallel_replicas_prefer_local_join=0,
|
SETTINGS allow_experimental_analyzer=1, $PARALLEL_REPLICAS_SETTINGS, parallel_replicas_prefer_local_join=0, join_algorithm='full_sorting_merge'"
|
||||||
allow_experimental_parallel_reading_from_replicas = 2, max_parallel_replicas = 2, parallel_replicas_for_non_replicated_merge_tree = 1,
|
|
||||||
cluster_for_parallel_replicas = 'test_cluster_one_shard_three_replicas_localhost', join_algorithm='full_sorting_merge'"
|
|
||||||
|
|
||||||
$CLICKHOUSE_CLIENT -q "
|
$CLICKHOUSE_CLIENT -q "
|
||||||
select * from (select key, value from num_1) l
|
select * from (select key, value from num_1) l
|
||||||
inner join (select key, value from num_2 inner join
|
inner join (select key, value from num_2 inner join
|
||||||
(select number * 7 as key from numbers(1e5)) as nn on num_2.key = nn.key settings join_algorithm='full_sorting_merge') r
|
(select number * 7 as key from numbers(1e5)) as nn on num_2.key = nn.key settings join_algorithm='full_sorting_merge') r
|
||||||
on l.key = r.key order by l.key limit 10 offset 10000
|
on l.key = r.key order by l.key limit 10 offset 10000
|
||||||
SETTINGS allow_experimental_analyzer=1, parallel_replicas_prefer_local_join=0, send_logs_level='trace',
|
SETTINGS allow_experimental_analyzer=1, send_logs_level='trace', $PARALLEL_REPLICAS_SETTINGS, parallel_replicas_prefer_local_join=0, join_algorithm='full_sorting_merge'" 2>&1 |
|
||||||
allow_experimental_parallel_reading_from_replicas = 2, max_parallel_replicas = 2, parallel_replicas_for_non_replicated_merge_tree = 1,
|
|
||||||
cluster_for_parallel_replicas = 'test_cluster_one_shard_three_replicas_localhost', join_algorithm='full_sorting_merge'" 2>&1 |
|
|
||||||
grep "executeQuery\|<Debug>.*Coordinator: Coordination done" |
|
grep "executeQuery\|<Debug>.*Coordinator: Coordination done" |
|
||||||
grep -o "SELECT.*WithMergeableState)\|<Debug>.*Coordinator: Coordination done" |
|
grep -o "SELECT.*WithMergeableState)\|<Debug>.*Coordinator: Coordination done" |
|
||||||
sed -re 's/_data_[[:digit:]]+_[[:digit:]]+/_data_/g'
|
sed -re 's/_data_[[:digit:]]+_[[:digit:]]+/_data_/g'
|
||||||
@ -102,18 +92,14 @@ select * from (select key, value from num_1) l
|
|||||||
inner join (select key, value from num_2 inner join
|
inner join (select key, value from num_2 inner join
|
||||||
(select number * 7 as key from numbers(1e5)) as nn on num_2.key = nn.key settings join_algorithm='hash') r
|
(select number * 7 as key from numbers(1e5)) as nn on num_2.key = nn.key settings join_algorithm='hash') r
|
||||||
on l.key = r.key order by l.key limit 10 offset 10000
|
on l.key = r.key order by l.key limit 10 offset 10000
|
||||||
SETTINGS allow_experimental_analyzer=1, parallel_replicas_prefer_local_join=0,
|
SETTINGS allow_experimental_analyzer=1, $PARALLEL_REPLICAS_SETTINGS, parallel_replicas_prefer_local_join=0, join_algorithm='full_sorting_merge'"
|
||||||
allow_experimental_parallel_reading_from_replicas = 2, max_parallel_replicas = 2, parallel_replicas_for_non_replicated_merge_tree = 1,
|
|
||||||
cluster_for_parallel_replicas = 'test_cluster_one_shard_three_replicas_localhost', join_algorithm='full_sorting_merge'"
|
|
||||||
|
|
||||||
$CLICKHOUSE_CLIENT -q "
|
$CLICKHOUSE_CLIENT -q "
|
||||||
select * from (select key, value from num_1) l
|
select * from (select key, value from num_1) l
|
||||||
inner join (select key, value from num_2 inner join
|
inner join (select key, value from num_2 inner join
|
||||||
(select number * 7 as key from numbers(1e5)) as nn on num_2.key = nn.key settings join_algorithm='hash') r
|
(select number * 7 as key from numbers(1e5)) as nn on num_2.key = nn.key settings join_algorithm='hash') r
|
||||||
on l.key = r.key order by l.key limit 10 offset 10000
|
on l.key = r.key order by l.key limit 10 offset 10000
|
||||||
SETTINGS allow_experimental_analyzer=1, parallel_replicas_prefer_local_join=0, send_logs_level='trace',
|
SETTINGS allow_experimental_analyzer=1, send_logs_level='trace', $PARALLEL_REPLICAS_SETTINGS, parallel_replicas_prefer_local_join=0, join_algorithm='full_sorting_merge'" 2>&1 |
|
||||||
allow_experimental_parallel_reading_from_replicas = 2, max_parallel_replicas = 2, parallel_replicas_for_non_replicated_merge_tree = 1,
|
|
||||||
cluster_for_parallel_replicas = 'test_cluster_one_shard_three_replicas_localhost', join_algorithm='full_sorting_merge'" 2>&1 |
|
|
||||||
grep "executeQuery\|<Debug>.*Coordinator: Coordination done" |
|
grep "executeQuery\|<Debug>.*Coordinator: Coordination done" |
|
||||||
grep -o "SELECT.*WithMergeableState)\|<Debug>.*Coordinator: Coordination done" |
|
grep -o "SELECT.*WithMergeableState)\|<Debug>.*Coordinator: Coordination done" |
|
||||||
sed -re 's/_data_[[:digit:]]+_[[:digit:]]+/_data_/g'
|
sed -re 's/_data_[[:digit:]]+_[[:digit:]]+/_data_/g'
|
||||||
@ -127,18 +113,14 @@ select * from (select key, value from num_1) l
|
|||||||
inner join (select key, value from num_2 inner join
|
inner join (select key, value from num_2 inner join
|
||||||
(select number * 7 as key from numbers(1e5)) as nn on num_2.key = nn.key settings join_algorithm='full_sorting_merge') r
|
(select number * 7 as key from numbers(1e5)) as nn on num_2.key = nn.key settings join_algorithm='full_sorting_merge') r
|
||||||
on l.key = r.key order by l.key limit 10 offset 10000
|
on l.key = r.key order by l.key limit 10 offset 10000
|
||||||
SETTINGS allow_experimental_analyzer=1, parallel_replicas_prefer_local_join=0,
|
SETTINGS allow_experimental_analyzer=1, $PARALLEL_REPLICAS_SETTINGS, parallel_replicas_prefer_local_join=0, join_algorithm='hash'"
|
||||||
allow_experimental_parallel_reading_from_replicas = 2, max_parallel_replicas = 2, parallel_replicas_for_non_replicated_merge_tree = 1,
|
|
||||||
cluster_for_parallel_replicas = 'test_cluster_one_shard_three_replicas_localhost', join_algorithm='hash'"
|
|
||||||
|
|
||||||
$CLICKHOUSE_CLIENT -q "
|
$CLICKHOUSE_CLIENT -q "
|
||||||
select * from (select key, value from num_1) l
|
select * from (select key, value from num_1) l
|
||||||
inner join (select key, value from num_2 inner join
|
inner join (select key, value from num_2 inner join
|
||||||
(select number * 7 as key from numbers(1e5)) as nn on num_2.key = nn.key settings join_algorithm='full_sorting_merge') r
|
(select number * 7 as key from numbers(1e5)) as nn on num_2.key = nn.key settings join_algorithm='full_sorting_merge') r
|
||||||
on l.key = r.key order by l.key limit 10 offset 10000
|
on l.key = r.key order by l.key limit 10 offset 10000
|
||||||
SETTINGS allow_experimental_analyzer=1, parallel_replicas_prefer_local_join=0, send_logs_level='trace',
|
SETTINGS allow_experimental_analyzer=1, send_logs_level='trace', $PARALLEL_REPLICAS_SETTINGS, parallel_replicas_prefer_local_join=0, join_algorithm='hash'" 2>&1 |
|
||||||
allow_experimental_parallel_reading_from_replicas = 2, max_parallel_replicas = 2, parallel_replicas_for_non_replicated_merge_tree = 1,
|
|
||||||
cluster_for_parallel_replicas = 'test_cluster_one_shard_three_replicas_localhost', join_algorithm='hash'" 2>&1 |
|
|
||||||
grep "executeQuery\|<Debug>.*Coordinator: Coordination done" |
|
grep "executeQuery\|<Debug>.*Coordinator: Coordination done" |
|
||||||
grep -o "SELECT.*WithMergeableState)\|<Debug>.*Coordinator: Coordination done" |
|
grep -o "SELECT.*WithMergeableState)\|<Debug>.*Coordinator: Coordination done" |
|
||||||
sed -re 's/_data_[[:digit:]]+_[[:digit:]]+/_data_/g'
|
sed -re 's/_data_[[:digit:]]+_[[:digit:]]+/_data_/g'
|
||||||
|
Loading…
Reference in New Issue
Block a user