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

Apply black check

Browse Source
This commit is contained in:
alesapin 2023-05-01 14:02:07 +02:00
parent 17effd4f6d
commit 5b24a84fc0
2 changed files with 19 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
tests/integration/test_merge_tree_hdfs/test.py
View File

@ -366,9 +366,10 @@ def test_move_replace_partition_to_another_table(cluster):
for obj in hdfs_objects:
print("Object in HDFS after move", obj)
wait_for_delete_hdfs_objects(
cluster, FILES_OVERHEAD * 2
cluster,
FILES_OVERHEAD * 2
+ FILES_OVERHEAD_PER_PART_WIDE * 4
- FILES_OVERHEAD_METADATA_VERSION * 2
- FILES_OVERHEAD_METADATA_VERSION * 2,
)
# Add new partitions to source table, but with different values and replace them from copied table.
@ -388,9 +389,10 @@ def test_move_replace_partition_to_another_table(cluster):
print("Object in HDFS after insert", obj)
wait_for_delete_hdfs_objects(
cluster, FILES_OVERHEAD * 2
cluster,
FILES_OVERHEAD * 2
+ FILES_OVERHEAD_PER_PART_WIDE * 6
- FILES_OVERHEAD_METADATA_VERSION * 2
- FILES_OVERHEAD_METADATA_VERSION * 2,
)
node.query("ALTER TABLE hdfs_test REPLACE PARTITION '2020-01-03' FROM hdfs_clone")
@ -419,7 +421,8 @@ def test_move_replace_partition_to_another_table(cluster):
print("Object in HDFS after drop", obj)
wait_for_delete_hdfs_objects(
cluster, FILES_OVERHEAD
cluster,
FILES_OVERHEAD
+ FILES_OVERHEAD_PER_PART_WIDE * 4
- FILES_OVERHEAD_METADATA_VERSION * 2
- FILES_OVERHEAD_METADATA_VERSION * 2,
)

17
tests/integration/test_merge_tree_s3/test.py
View File

@ -471,9 +471,10 @@ def test_move_replace_partition_to_another_table(cluster, node_name):
# Number of objects in S3 should be unchanged.
wait_for_delete_s3_objects(
cluster, FILES_OVERHEAD * 2
cluster,
FILES_OVERHEAD * 2
+ FILES_OVERHEAD_PER_PART_WIDE * 4
- FILES_OVERHEAD_METADATA_VERSION * 2
- FILES_OVERHEAD_METADATA_VERSION * 2,
)
# Add new partitions to source table, but with different values and replace them from copied table.
@ -490,9 +491,10 @@ def test_move_replace_partition_to_another_table(cluster, node_name):
print("Object after insert", obj.object_name)
wait_for_delete_s3_objects(
cluster, FILES_OVERHEAD * 2
cluster,
FILES_OVERHEAD * 2
+ FILES_OVERHEAD_PER_PART_WIDE * 6
- FILES_OVERHEAD_METADATA_VERSION * 2
- FILES_OVERHEAD_METADATA_VERSION * 2,
)
node.query("ALTER TABLE s3_test REPLACE PARTITION '2020-01-03' FROM s3_clone")
@ -520,9 +522,10 @@ def test_move_replace_partition_to_another_table(cluster, node_name):
# Data should remain in S3
wait_for_delete_s3_objects(
cluster, FILES_OVERHEAD
cluster,
FILES_OVERHEAD
+ FILES_OVERHEAD_PER_PART_WIDE * 4
- FILES_OVERHEAD_METADATA_VERSION * 2
- FILES_OVERHEAD_METADATA_VERSION * 2,
)
node.query("ALTER TABLE s3_test FREEZE")
@ -535,7 +538,7 @@ def test_move_replace_partition_to_another_table(cluster, node_name):
cluster,
FILES_OVERHEAD
+ FILES_OVERHEAD_PER_PART_WIDE * 4
- FILES_OVERHEAD_METADATA_VERSION * 2
- FILES_OVERHEAD_METADATA_VERSION * 2,
)
node.query("DROP TABLE s3_test NO DELAY")