From 07821a576dda4d8b737c0050c04fac23acade585 Mon Sep 17 00:00:00 2001 From: Konstantin Bogdanov Date: Wed, 20 Nov 2024 16:21:13 +0100 Subject: [PATCH] Cleaner test --- ..._functions_with_parallel_replicas.reference | 8 ++++++++ ...luster_functions_with_parallel_replicas.sql | 18 ++++++++---------- 2 files changed, 16 insertions(+), 10 deletions(-) diff --git a/tests/queries/0_stateless/03275_auto_cluster_functions_with_parallel_replicas.reference b/tests/queries/0_stateless/03275_auto_cluster_functions_with_parallel_replicas.reference index e69de29bb2d..7859daeb71f 100644 --- a/tests/queries/0_stateless/03275_auto_cluster_functions_with_parallel_replicas.reference +++ b/tests/queries/0_stateless/03275_auto_cluster_functions_with_parallel_replicas.reference @@ -0,0 +1,8 @@ +Expression (Project names) + ReadFromCluster +Expression (Project names) + ReadFromCluster +Expression ((Project names + (Projection + Change column names to column identifiers))) + ReadFromURL +Expression ((Project names + (Projection + Change column names to column identifiers))) + S3Source diff --git a/tests/queries/0_stateless/03275_auto_cluster_functions_with_parallel_replicas.sql b/tests/queries/0_stateless/03275_auto_cluster_functions_with_parallel_replicas.sql index 8cdbdeb1b9b..ee0d355d849 100644 --- a/tests/queries/0_stateless/03275_auto_cluster_functions_with_parallel_replicas.sql +++ b/tests/queries/0_stateless/03275_auto_cluster_functions_with_parallel_replicas.sql @@ -1,16 +1,14 @@ -- Tags: no-fasttest -- Tag no-fasttest: Depends on AWS -SET enable_parallel_replicas=1, max_parallel_replicas=3, parallel_replicas_for_non_replicated_merge_tree=1, cluster_for_parallel_replicas='test_cluster_two_shard_three_replicas_localhost'; -SELECT * FROM s3('http://localhost:11111/test/{a,b,c}.tsv', 'test', 'testtest', '', 'TSV', 'c1 UInt64, c2 UInt64, c3 UInt64', 'auto') ORDER BY c1, c2, c3 SETTINGS log_comment='03275_16cb4bb2-813a-43c2-8956-fa3520454020_parallel_replicas'; +SET enable_parallel_replicas=1; +SET cluster_for_parallel_replicas='default'; +SET parallel_replicas_for_cluster_engines=true; -SET enable_parallel_replicas=0; -SELECT * FROM s3('http://localhost:11111/test/{a,b,c}.tsv', 'test', 'testtest', '', 'TSV', 'c1 UInt64, c2 UInt64, c3 UInt64', 'auto') ORDER BY c1, c2, c3 SETTINGS log_comment='03275_16cb4bb2-813a-43c2-8956-fa3520454020_single_replica'; +EXPLAIN SELECT * FROM url('http://localhost:8123'); +EXPLAIN SELECT * FROM s3('http://localhost:11111/test/a.tsv', 'TSV'); -SYSTEM FLUSH LOGS; +SET parallel_replicas_for_cluster_engines=false; -SET enable_parallel_replicas=0; -SET max_rows_to_read = 0; -- system.text_log can be really big -SELECT count() > 0 FROM system.text_log -WHERE query_id in (select query_id from system.query_log where current_database = currentDatabase() and log_comment like '03275_16cb4bb2-813a-43c2-8956-fa3520454020%') - AND message LIKE '%Parallel reading from replicas is disabled for cluster%'; +EXPLAIN SELECT * FROM url('http://localhost:8123'); +EXPLAIN SELECT * FROM s3('http://localhost:11111/test/a.tsv', 'TSV');