2020-08-28 00:28:37 +00:00
#!/usr/bin/env bash
2021-09-12 12:35:27 +00:00
# Tags: replica, no-parallel
2020-08-28 00:28:37 +00:00
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 "
2022-11-10 11:12:24 +00:00
DROP TABLE IF EXISTS r$i ;
2021-03-15 04:51:28 +00:00
CREATE TABLE r$i ( x UInt64) ENGINE = ReplicatedMergeTree( '/clickhouse/tables/$CLICKHOUSE_TEST_ZOOKEEPER_PREFIX/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 ..."
2022-11-10 11:12:24 +00:00
$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 ;
2021-01-25 07:43:20 +00:00
SELECT count( ) , min( x) , max( x) , sum( x) FROM r$i ; "
done
for i in $( seq 1 $NUM_REPLICAS ) ; do
2022-11-10 11:12:24 +00:00
$CLICKHOUSE_CLIENT -q " DROP TABLE IF EXISTS r $i ; "
2020-08-28 01:02:04 +00:00
done