Fix flaky test 01650

This commit is contained in:
alesapin 2021-12-28 12:40:07 +03:00
parent 90db762c87
commit cb3c3970fe
2 changed files with 16 additions and 4 deletions

View File

@ -1,3 +1,4 @@
~~~~source parts~~~~~
1 1_0_0_0
1 1_1_1_0
2 2_0_0_0
@ -10,6 +11,7 @@
2_ 2_1_1_0
3_ 3_0_0_0
3_ 3_1_1_0
~~~~parts after deduplication~~~~~
1 1_0_0_0
1 1_1_1_0
2 2_0_0_0
@ -22,6 +24,7 @@
2_ 2_1_1_0
3_ 3_0_0_0
3_ 3_1_1_0
~~~~parts after drop 3_1_1_0~~~~~
1 1_0_0_0
1 1_1_1_0
2 2_0_0_0
@ -32,6 +35,7 @@
2_ 2_0_0_0
2_ 2_1_1_0
3_ 3_0_0_0
~~~~parts after new part without deduplication~~~~~
1 1_0_0_0
1 1_1_1_0
2 2_0_0_0

View File

@ -17,25 +17,33 @@ SYSTEM STOP MERGES partitioned_table;
INSERT INTO partitioned_table VALUES (1, 1, 'A'), (2, 2, 'B'), (3, 3, 'C');
INSERT INTO partitioned_table VALUES (11, 1, 'AA'), (22, 2, 'BB'), (33, 3, 'CC');
SELECT partition_id, name FROM system.parts WHERE table = 'partitioned_table' AND database = currentDatabase() ORDER BY name;
SELECT '~~~~source parts~~~~~';
SELECT partition_id, name FROM system.parts WHERE table = 'partitioned_table' AND database = currentDatabase() and active ORDER BY name;
SELECT substring(name, 1, 2), value FROM system.zookeeper WHERE path='/clickhouse/' || currentDatabase() || '/01650_drop_part_and_deduplication_partitioned_table/blocks/' ORDER BY value;
INSERT INTO partitioned_table VALUES (33, 3, 'CC'); -- must be deduplicated
SELECT partition_id, name FROM system.parts WHERE table = 'partitioned_table' AND database = currentDatabase() ORDER BY name;
SELECT '~~~~parts after deduplication~~~~~';
SELECT partition_id, name FROM system.parts WHERE table = 'partitioned_table' AND database = currentDatabase() and active ORDER BY name;
SELECT substring(name, 1, 2), value FROM system.zookeeper WHERE path='/clickhouse/' || currentDatabase() || '/01650_drop_part_and_deduplication_partitioned_table/blocks/' ORDER BY value;
ALTER TABLE partitioned_table DROP PART '3_1_1_0';
SELECT partition_id, name FROM system.parts WHERE table = 'partitioned_table' AND database = currentDatabase() ORDER BY name;
SELECT '~~~~parts after drop 3_1_1_0~~~~~';
SELECT partition_id, name FROM system.parts WHERE table = 'partitioned_table' AND database = currentDatabase() and active ORDER BY name;
SELECT substring(name, 1, 2), value FROM system.zookeeper WHERE path='/clickhouse/' || currentDatabase() || '/01650_drop_part_and_deduplication_partitioned_table/blocks/' ORDER BY value;
INSERT INTO partitioned_table VALUES (33, 3, 'CC'); -- mustn't be deduplicated
SELECT partition_id, name FROM system.parts WHERE table = 'partitioned_table' AND database = currentDatabase() ORDER BY name;
SELECT '~~~~parts after new part without deduplication~~~~~';
SELECT partition_id, name FROM system.parts WHERE table = 'partitioned_table' AND database = currentDatabase() and active ORDER BY name;
SELECT substring(name, 1, 2), value FROM system.zookeeper WHERE path='/clickhouse/' || currentDatabase() || '/01650_drop_part_and_deduplication_partitioned_table/blocks/' ORDER BY value;