thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-09-21 01:00:48 +00:00
Code Issues Packages Projects Releases Wiki Activity

Use s3 disk explicitly for log tables in test_log_family_s3.

Browse Source
This commit is contained in:
Pavel Kovalenko 2020-12-12 16:44:19 +03:00
parent ca20058cdc
commit c2c497e290
2 changed files with 3 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
tests/integration/test_log_family_s3/configs/minio.xml
View File

@ -2,13 +2,13 @@
<yandex>
<storage_configuration>
<disks>
<default>
<s3>
<type>s3</type>
<endpoint>http://minio1:9001/root/data/</endpoint>
<access_key_id>minio</access_key_id>
<secret_access_key>minio123</secret_access_key>
<send_object_metadata>true</send_object_metadata>
</default>
</s3>
</disks>
</storage_configuration>
</yandex>

3
tests/integration/test_log_family_s3/test.py
View File

@ -27,7 +27,6 @@ def cluster():
def assert_objects_count(cluster, objects_count, path='data/'):
minio = cluster.minio_client
s3_objects = list(minio.list_objects(cluster.minio_bucket, path))
print(s3_objects, file=sys.stderr)
if objects_count != len(s3_objects):
for s3_object in s3_objects:
object_meta = minio.stat_object(cluster.minio_bucket, s3_object.object_name)
@ -41,7 +40,7 @@ def assert_objects_count(cluster, objects_count, path='data/'):
def test_log_family_s3(cluster, log_engine, files_overhead, files_overhead_per_insert):
node = cluster.instances["node"]
node.query("CREATE TABLE s3_test (id UInt64) Engine={}".format(log_engine))
node.query("CREATE TABLE s3_test (id UInt64) ENGINE={} SETTINGS disk = 's3'".format(log_engine))
node.query("INSERT INTO s3_test SELECT number FROM numbers(5)")
assert node.query("SELECT * FROM s3_test") == "0\n1\n2\n3\n4\n"