mirror of
https://github.com/ClickHouse/ClickHouse.git
synced 2024-09-20 08:40:50 +00:00
6fc225e676
* Distributed insertion to one random shard * add some tests * add some documentation * Respect shards' weights * fine locking Co-authored-by: Ivan Lezhankin <ilezhankin@yandex-team.ru>
23 lines
656 B
SQL
23 lines
656 B
SQL
drop table if exists shard;
|
|
drop table if exists distr;
|
|
|
|
create table shard (id Int32) engine = MergeTree order by cityHash64(id);
|
|
create table distr as shard engine Distributed (test_cluster_two_shards_localhost, currentDatabase(), shard);
|
|
|
|
insert into distr (id) values (0), (1); -- { serverError 55; }
|
|
|
|
set insert_distributed_sync = 1;
|
|
|
|
insert into distr (id) values (0), (1); -- { serverError 55; }
|
|
|
|
set insert_distributed_sync = 0;
|
|
set insert_distributed_one_random_shard = 1;
|
|
|
|
insert into distr (id) values (0), (1);
|
|
insert into distr (id) values (2), (3);
|
|
|
|
select * from distr order by id;
|
|
|
|
drop table if exists shard;
|
|
drop table if exists distr;
|