Skip to content

Commit cee48d1

Browse files
committed
rmv cluster because the cluster config was introduced in a different pr
1 parent bc9f351 commit cee48d1

File tree

1 file changed

+0
-25
lines changed
  • tests/integration/test_storage_s3

1 file changed

+0
-25
lines changed

tests/integration/test_storage_s3/test.py

Lines changed: 0 additions & 25 deletions
Original file line numberDiff line numberDiff line change
@@ -2610,28 +2610,3 @@ def test_key_value_args(started_cluster):
26102610
f"insert into function s3('{url}', structure = 'a Int32, b String', partition_strategy='hive', TSV) partition by b select number, toString(number) from numbers(10) settings s3_truncate_on_insert=1"
26112611
)
26122612
)
2613-
2614-
# Check s3Cluster
2615-
assert 2 == int(
2616-
node.query(
2617-
f"select a from s3Cluster(cluster, '{url}', TSVRaw, structure = 'a Int32, b String', access_key_id = 'minio', secret_access_key = '{minio_secret_key}', compression_method = 'none') where b = '2'",
2618-
)
2619-
)
2620-
assert 2 == int(
2621-
node.query(
2622-
f"select a from s3Cluster(cluster, '{url}', format = TSVRaw, structure = 'a Int32, b String', access_key_id = 'minio', secret_access_key = '{minio_secret_key}', compression_method = 'none') where b = '2'",
2623-
)
2624-
)
2625-
assert 2 == int(
2626-
node.query(
2627-
f"select a from s3Cluster(cluster, '{url}', structure = 'a Int32, b String', access_key_id = 'minio', secret_access_key = '{minio_secret_key}', compression_method = 'none') where b = '2'",
2628-
)
2629-
)
2630-
2631-
node.query(
2632-
f"CREATE TABLE {table_name} (a Int32, b String) engine = S3('{url}', format = TSVRaw, access_key_id = 'minio', secret_access_key = '{minio_secret_key}', compression_method = 'gzip')"
2633-
)
2634-
assert (
2635-
f"S3(\\'{url}\\', \\'TSVRaw\\', format = \\'TSVRaw\\', access_key_id = \\'minio\\', secret_access_key = \\'[HIDDEN]\\', compression_method = \\'gzip\\')"
2636-
in node.query(f"SHOW CREATE TABLE {table_name}")
2637-
)

0 commit comments

Comments
 (0)