thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-11-29 19:12:03 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix test

Browse Source
This commit is contained in:
Igor Nikonov 2024-02-02 11:28:35 +00:00
parent 82d7b22144
commit 4b77258341
2 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/QueryPipeline/RemoteQueryExecutor.h
View File

@ -52,7 +52,7 @@ public:
std::optional<IConnections::ReplicaInfo> replica_info = {}; std::optional<IConnections::ReplicaInfo> replica_info = {};
}; };
/// Takes a connection pool to a node (not cluster) /// Takes a connection pool for a node (not cluster)
RemoteQueryExecutor( RemoteQueryExecutor(
IConnectionPool * pool, IConnectionPool * pool,
const String & query_, const String & query_,

5
tests/queries/0_stateless/02769_parallel_replicas_unavailable_shards.sql
View File

@ -6,10 +6,11 @@ SYSTEM FLUSH LOGS;
SET allow_experimental_parallel_reading_from_replicas=2, max_parallel_replicas=11, cluster_for_parallel_replicas='parallel_replicas', parallel_replicas_for_non_replicated_merge_tree=1; SET allow_experimental_parallel_reading_from_replicas=2, max_parallel_replicas=11, cluster_for_parallel_replicas='parallel_replicas', parallel_replicas_for_non_replicated_merge_tree=1;
SET send_logs_level='error'; SET send_logs_level='error';
SELECT count() FROM test_parallel_replicas_unavailable_shards WHERE NOT ignore(*); SELECT count() FROM test_parallel_replicas_unavailable_shards WHERE NOT ignore(*) SETTINGS log_comment = '02769_7b513191-5082-4073-8568-53b86a49da79';
SYSTEM FLUSH LOGS; SYSTEM FLUSH LOGS;
SELECT count() > 0 FROM system.text_log WHERE yesterday() <= event_date AND message LIKE '%Replica number 10 is unavailable%'; SET allow_experimental_parallel_reading_from_replicas=0;
SELECT count() FROM system.text_log WHERE yesterday() <= event_date AND query_id in (select query_id from system.query_log where log_comment = '02769_7b513191-5082-4073-8568-53b86a49da79' and current_database = currentDatabase()) and message LIKE '%Replica number % is unavailable%';
DROP TABLE test_parallel_replicas_unavailable_shards; DROP TABLE test_parallel_replicas_unavailable_shards;