mirror of
https://github.com/ClickHouse/ClickHouse.git
synced 2024-09-19 16:20:50 +00:00
Update test for in-(reverse)-order coordinator
This commit is contained in:
parent
02a2f50916
commit
860b18c251
@ -918,7 +918,7 @@ ParallelReadResponse InOrderCoordinator<mode>::handleRequest(ParallelReadRequest
|
|||||||
"Replica {} decided to read in {} mode, not in {}. This is a bug",
|
"Replica {} decided to read in {} mode, not in {}. This is a bug",
|
||||||
request.replica_num, magic_enum::enum_name(request.mode), magic_enum::enum_name(mode));
|
request.replica_num, magic_enum::enum_name(request.mode), magic_enum::enum_name(mode));
|
||||||
|
|
||||||
LOG_TRACE(log, "Got request from replica {}, data {}", request.replica_num, request.describe());
|
LOG_TRACE(log, "Got read request: {}", request.describe());
|
||||||
|
|
||||||
ParallelReadResponse response;
|
ParallelReadResponse response;
|
||||||
response.description = request.description;
|
response.description = request.description;
|
||||||
|
@ -44,9 +44,7 @@ void ParallelReadRequest::serialize(WriteBuffer & out) const
|
|||||||
|
|
||||||
String ParallelReadRequest::describe() const
|
String ParallelReadRequest::describe() const
|
||||||
{
|
{
|
||||||
String result;
|
String result = fmt::format("replica_num {}, min_num_of_marks {}, ", replica_num, min_number_of_marks);
|
||||||
result += fmt::format("replica_num: {} \n", replica_num);
|
|
||||||
result += fmt::format("min_num_of_marks: {} \n", min_number_of_marks);
|
|
||||||
result += description.describe();
|
result += description.describe();
|
||||||
return result;
|
return result;
|
||||||
}
|
}
|
||||||
|
@ -1,8 +1,14 @@
|
|||||||
100 4950
|
10000 49995000
|
||||||
1
|
1
|
||||||
89
|
89
|
||||||
90
|
90
|
||||||
91
|
91
|
||||||
92
|
92
|
||||||
93
|
93
|
||||||
1
|
3
|
||||||
|
93
|
||||||
|
92
|
||||||
|
91
|
||||||
|
90
|
||||||
|
89
|
||||||
|
3
|
||||||
|
@ -2,11 +2,12 @@ DROP TABLE IF EXISTS test;
|
|||||||
|
|
||||||
CREATE TABLE test (k UInt64, v String)
|
CREATE TABLE test (k UInt64, v String)
|
||||||
ENGINE = MergeTree
|
ENGINE = MergeTree
|
||||||
ORDER BY k;
|
ORDER BY k
|
||||||
|
SETTINGS index_granularity=1;
|
||||||
|
|
||||||
INSERT INTO test SELECT number, toString(number) FROM numbers(100);
|
INSERT INTO test SELECT number, toString(number) FROM numbers(10_000);
|
||||||
|
|
||||||
SET allow_experimental_parallel_reading_from_replicas = 2, max_parallel_replicas = 3, prefer_localhost_replica = 0, parallel_replicas_for_non_replicated_merge_tree=1, cluster_for_parallel_replicas='test_cluster_one_shard_three_replicas_localhost';
|
SET allow_experimental_parallel_reading_from_replicas = 2, max_parallel_replicas = 3, parallel_replicas_for_non_replicated_merge_tree=1, cluster_for_parallel_replicas='test_cluster_one_shard_three_replicas_localhost';
|
||||||
|
|
||||||
-- default coordinator
|
-- default coordinator
|
||||||
SELECT count(), sum(k)
|
SELECT count(), sum(k)
|
||||||
@ -14,12 +15,18 @@ FROM test
|
|||||||
SETTINGS log_comment = '02950_parallel_replicas_used_replicas_count';
|
SETTINGS log_comment = '02950_parallel_replicas_used_replicas_count';
|
||||||
|
|
||||||
SYSTEM FLUSH LOGS;
|
SYSTEM FLUSH LOGS;
|
||||||
SELECT ProfileEvents['ParallelReplicasUsedCount'] FROM system.query_log WHERE type = 'QueryFinish' AND query_id IN (SELECT query_id FROM system.query_log WHERE current_database = currentDatabase() AND log_comment = '02950_parallel_replicas_used_replicas_count' AND type = 'QueryFinish' AND initial_query_id = query_id) SETTINGS allow_experimental_parallel_reading_from_replicas=0;
|
SELECT ProfileEvents['ParallelReplicasUsedCount'] > 0 FROM system.query_log WHERE type = 'QueryFinish' AND query_id IN (SELECT query_id FROM system.query_log WHERE current_database = currentDatabase() AND log_comment = '02950_parallel_replicas_used_replicas_count' AND type = 'QueryFinish' AND initial_query_id = query_id) SETTINGS allow_experimental_parallel_reading_from_replicas=0;
|
||||||
|
|
||||||
-- In order coordinator
|
-- In order coordinator
|
||||||
SELECT k FROM test order by k limit 5 offset 89 SETTINGS optimize_read_in_order=1, log_comment='02950_parallel_replicas_used_replicas_count_2';
|
SELECT k FROM test order by k limit 5 offset 89 SETTINGS optimize_read_in_order=1, log_comment='02950_parallel_replicas_used_replicas_count_2', merge_tree_min_rows_for_concurrent_read=1, max_threads=1;
|
||||||
|
|
||||||
SYSTEM FLUSH LOGS;
|
SYSTEM FLUSH LOGS;
|
||||||
SELECT ProfileEvents['ParallelReplicasUsedCount'] FROM system.query_log WHERE type = 'QueryFinish' AND query_id IN (SELECT query_id FROM system.query_log WHERE current_database = currentDatabase() AND log_comment = '02950_parallel_replicas_used_replicas_count_2' AND type = 'QueryFinish' AND initial_query_id = query_id) SETTINGS allow_experimental_parallel_reading_from_replicas=0;
|
SELECT ProfileEvents['ParallelReplicasUsedCount'] FROM system.query_log WHERE type = 'QueryFinish' AND query_id IN (SELECT query_id FROM system.query_log WHERE current_database = currentDatabase() AND log_comment = '02950_parallel_replicas_used_replicas_count_2' AND type = 'QueryFinish' AND initial_query_id = query_id) SETTINGS allow_experimental_parallel_reading_from_replicas=0;
|
||||||
|
|
||||||
|
-- In reverse order coordinator
|
||||||
|
SELECT k FROM test order by k desc limit 5 offset 9906 SETTINGS optimize_read_in_order=1, log_comment='02950_parallel_replicas_used_replicas_count_3', merge_tree_min_rows_for_concurrent_read=1, max_threads=1;
|
||||||
|
|
||||||
|
SYSTEM FLUSH LOGS;
|
||||||
|
SELECT ProfileEvents['ParallelReplicasUsedCount'] FROM system.query_log WHERE type = 'QueryFinish' AND query_id IN (SELECT query_id FROM system.query_log WHERE current_database = currentDatabase() AND log_comment = '02950_parallel_replicas_used_replicas_count_3' AND type = 'QueryFinish' AND initial_query_id = query_id) SETTINGS allow_experimental_parallel_reading_from_replicas=0;
|
||||||
|
|
||||||
DROP TABLE test;
|
DROP TABLE test;
|
||||||
|
Loading…
Reference in New Issue
Block a user