diff --git a/tests/integration/test_s3_low_cardinality_right_border/test.py b/tests/integration/test_s3_low_cardinality_right_border/test.py index 3f49dbb898b..e54e6783b3d 100644 --- a/tests/integration/test_s3_low_cardinality_right_border/test.py +++ b/tests/integration/test_s3_low_cardinality_right_border/test.py @@ -133,10 +133,15 @@ def test_s3_right_border_2(started_cluster): res = node1.query("select * from s3_low_cardinality where key = 9000") assert res == "9000\t9000\n" + def test_s3_right_border_3(started_cluster): node1.query("drop table if exists s3_low_cardinality") - node1.query("create table s3_low_cardinality (x LowCardinality(String)) engine = MergeTree order by tuple() settings min_bytes_for_wide_part=0, storage_policy = 's3', max_compress_block_size=10000") - node1.query("insert into s3_low_cardinality select toString(number % 8000) || if(number < 8192 * 3, 'aaaaaaaaaaaaaaaa', if(number < 8192 * 6, 'bbbbbbbbbbbbbbbbbbbbbbbb', 'ccccccccccccccccccc')) from numbers(8192 * 9)") + node1.query( + "create table s3_low_cardinality (x LowCardinality(String)) engine = MergeTree order by tuple() settings min_bytes_for_wide_part=0, storage_policy = 's3', max_compress_block_size=10000" + ) + node1.query( + "insert into s3_low_cardinality select toString(number % 8000) || if(number < 8192 * 3, 'aaaaaaaaaaaaaaaa', if(number < 8192 * 6, 'bbbbbbbbbbbbbbbbbbbbbbbb', 'ccccccccccccccccccc')) from numbers(8192 * 9)" + ) # Marks are: # Mark 0, points to 0, 8, has rows after 8192, decompressed size 0. # Mark 1, points to 0, 8, has rows after 8192, decompressed size 0. @@ -149,7 +154,9 @@ def test_s3_right_border_3(started_cluster): # Mark 8, points to 84995, 7738, has rows after 8192, decompressed size 0. # Mark 9, points to 126531, 8637, has rows after 0, decompressed size 0. - res = node1.query("select uniq(x) from s3_low_cardinality settings max_threads=2, merge_tree_min_rows_for_concurrent_read_for_remote_filesystem=1, merge_tree_min_bytes_for_concurrent_read_for_remote_filesystem=1") + res = node1.query( + "select uniq(x) from s3_low_cardinality settings max_threads=2, merge_tree_min_rows_for_concurrent_read_for_remote_filesystem=1, merge_tree_min_bytes_for_concurrent_read_for_remote_filesystem=1" + ) # Reading ranges [0, 5) and [5, 9) assert res == "23999\n"