2020-08-28 00:28:37 +00:00
#!/usr/bin/env bash
set -e
CURDIR = $( cd " $( dirname " ${ BASH_SOURCE [0] } " ) " && pwd )
2020-12-28 11:46:53 +00:00
# shellcheck source=../shell_config.sh
2020-08-28 00:28:37 +00:00
. " $CURDIR " /../shell_config.sh
2020-08-28 01:02:04 +00:00
NUM_REPLICAS = 10
2020-08-28 00:28:37 +00:00
2020-08-28 01:02:04 +00:00
for i in $( seq 1 $NUM_REPLICAS ) ; do
$CLICKHOUSE_CLIENT -n -q "
DROP TABLE IF EXISTS r$i ;
2020-09-17 19:30:17 +00:00
CREATE TABLE r$i ( x UInt64) ENGINE = ReplicatedMergeTree( '/clickhouse/tables/01459_manual_write_ro_replicas/r' , 'r$i' ) ORDER BY x;
2020-08-28 01:02:04 +00:00
"
done
2020-08-28 00:28:37 +00:00
function thread {
for x in { 0..99} ; do
2020-10-28 11:54:13 +00:00
# sometimes we can try to commit obsolete part if fetches will be quite fast,
# so supress warning messages like "Tried to commit obsolete part ... covered by ..."
$CLICKHOUSE_CLIENT --query " INSERT INTO r $1 SELECT $x % $NUM_REPLICAS = $1 ? $x - 1 : $x " 2>/dev/null # Replace some records as duplicates so they will be written by other replicas
2020-08-28 00:28:37 +00:00
done
}
2020-08-28 01:02:04 +00:00
for i in $( seq 1 $NUM_REPLICAS ) ; do
thread $i &
done
2020-08-28 00:28:37 +00:00
wait
2020-08-28 01:02:04 +00:00
for i in $( seq 1 $NUM_REPLICAS ) ; do
$CLICKHOUSE_CLIENT -n -q "
SYSTEM SYNC REPLICA r$i ;
SELECT count( ) , min( x) , max( x) , sum( x) FROM r$i ;
DROP TABLE IF EXISTS r$i ;
2020-08-28 00:28:37 +00:00
"
2020-08-28 01:02:04 +00:00
done