mirror of
https://github.com/ClickHouse/ClickHouse.git
synced 2024-11-15 12:14:18 +00:00
54013009d3
Initial implementation was different and it changed the entire ReplicatedMergeTreeSink::commitPart() which change history provided by git blame. Then RetriesControl.retryLoop() was introduced later which significantly reduces the diff since it's like while() used before. So, check outing the current version will keep more original history in git blame, which is useful here
36 lines
1.6 KiB
SQL
36 lines
1.6 KiB
SQL
-- Tags: replica
|
|
|
|
DROP TABLE IF EXISTS replicated_mutations_empty_partitions SYNC;
|
|
|
|
CREATE TABLE replicated_mutations_empty_partitions
|
|
(
|
|
key UInt64,
|
|
value String
|
|
)
|
|
ENGINE = ReplicatedMergeTree('/clickhouse/test/'||currentDatabase()||'/01586_replicated_mutations_empty_partitions/{shard}', '{replica}')
|
|
ORDER BY key
|
|
PARTITION by key;
|
|
|
|
-- insert_keeper* settings are adjusted since several actual inserts are happening behind one statement due to partitioning i.e. inserts in different partitions
|
|
INSERT INTO replicated_mutations_empty_partitions SETTINGS insert_keeper_max_retries=100, insert_keeper_retry_max_backoff_ms=10 SELECT number, toString(number) FROM numbers(10);
|
|
|
|
SELECT count(distinct value) FROM replicated_mutations_empty_partitions;
|
|
|
|
SELECT count() FROM system.zookeeper WHERE path = '/clickhouse/test/'||currentDatabase()||'/01586_replicated_mutations_empty_partitions/s1/block_numbers';
|
|
|
|
ALTER TABLE replicated_mutations_empty_partitions DROP PARTITION '3';
|
|
ALTER TABLE replicated_mutations_empty_partitions DROP PARTITION '4';
|
|
ALTER TABLE replicated_mutations_empty_partitions DROP PARTITION '5';
|
|
ALTER TABLE replicated_mutations_empty_partitions DROP PARTITION '9';
|
|
|
|
-- still ten records
|
|
SELECT count() FROM system.zookeeper WHERE path = '/clickhouse/test/'||currentDatabase()||'/01586_replicated_mutations_empty_partitions/s1/block_numbers';
|
|
|
|
ALTER TABLE replicated_mutations_empty_partitions MODIFY COLUMN value UInt64 SETTINGS replication_alter_partitions_sync=2;
|
|
|
|
SELECT sum(value) FROM replicated_mutations_empty_partitions;
|
|
|
|
SHOW CREATE TABLE replicated_mutations_empty_partitions;
|
|
|
|
DROP TABLE IF EXISTS replicated_mutations_empty_partitions SYNC;
|