thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-09-20 08:40:50 +00:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #52283 from ClickHouse/fix-01111_create_drop_replicated_db_stress

Browse Source 
Fix test `01111_create_drop_replicated_db_stress`
This commit is contained in:
alesapin 2023-07-21 12:34:10 +02:00 committed by GitHub
commit 8ff54591dd
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 18 additions and 19 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

37
tests/queries/0_stateless/01111_create_drop_replicated_db_stress.sh
View File

@ -8,7 +8,8 @@ CURDIR=$(cd "$(dirname "${BASH_SOURCE[0]}")" && pwd)
function create_db() function create_db()
{ {
while true; do local TIMELIMIT=$((SECONDS+$1))
while [ $SECONDS -lt "$TIMELIMIT" ]; do
SHARD=$(($RANDOM % 2)) SHARD=$(($RANDOM % 2))
REPLICA=$(($RANDOM % 2)) REPLICA=$(($RANDOM % 2))
SUFFIX=$(($RANDOM % 16)) SUFFIX=$(($RANDOM % 16))
@ -24,7 +25,8 @@ function create_db()
function drop_db() function drop_db()
{ {
while true; do local TIMELIMIT=$((SECONDS+$1))
while [ $SECONDS -lt "$TIMELIMIT" ]; do
database=$($CLICKHOUSE_CLIENT -q "select name from system.databases where name like '${CLICKHOUSE_DATABASE}%' order by rand() limit 1") database=$($CLICKHOUSE_CLIENT -q "select name from system.databases where name like '${CLICKHOUSE_DATABASE}%' order by rand() limit 1")
if [[ "$database" == "$CLICKHOUSE_DATABASE" ]]; then continue; fi if [[ "$database" == "$CLICKHOUSE_DATABASE" ]]; then continue; fi
if [ -z "$database" ]; then continue; fi if [ -z "$database" ]; then continue; fi
@ -36,7 +38,8 @@ function drop_db()
function sync_db() function sync_db()
{ {
while true; do local TIMELIMIT=$((SECONDS+$1))
while [ $SECONDS -lt "$TIMELIMIT" ]; do
database=$($CLICKHOUSE_CLIENT -q "select name from system.databases where name like '${CLICKHOUSE_DATABASE}%' order by rand() limit 1") database=$($CLICKHOUSE_CLIENT -q "select name from system.databases where name like '${CLICKHOUSE_DATABASE}%' order by rand() limit 1")
if [ -z "$database" ]; then continue; fi if [ -z "$database" ]; then continue; fi
$CLICKHOUSE_CLIENT --receive_timeout=1 -q \ $CLICKHOUSE_CLIENT --receive_timeout=1 -q \
@ -47,7 +50,8 @@ function sync_db()
function create_table() function create_table()
{ {
while true; do local TIMELIMIT=$((SECONDS+$1))
while [ $SECONDS -lt "$TIMELIMIT" ]; do
database=$($CLICKHOUSE_CLIENT -q "select name from system.databases where name like '${CLICKHOUSE_DATABASE}%' order by rand() limit 1") database=$($CLICKHOUSE_CLIENT -q "select name from system.databases where name like '${CLICKHOUSE_DATABASE}%' order by rand() limit 1")
if [ -z "$database" ]; then continue; fi if [ -z "$database" ]; then continue; fi
$CLICKHOUSE_CLIENT --distributed_ddl_task_timeout=0 -q \ $CLICKHOUSE_CLIENT --distributed_ddl_task_timeout=0 -q \
@ -59,7 +63,8 @@ function create_table()
function alter_table() function alter_table()
{ {
while true; do local TIMELIMIT=$((SECONDS+$1))
while [ $SECONDS -lt "$TIMELIMIT" ]; do
table=$($CLICKHOUSE_CLIENT -q "select database || '.' || name from system.tables where database like '${CLICKHOUSE_DATABASE}%' order by rand() limit 1") table=$($CLICKHOUSE_CLIENT -q "select database || '.' || name from system.tables where database like '${CLICKHOUSE_DATABASE}%' order by rand() limit 1")
if [ -z "$table" ]; then continue; fi if [ -z "$table" ]; then continue; fi
$CLICKHOUSE_CLIENT --distributed_ddl_task_timeout=0 -q \ $CLICKHOUSE_CLIENT --distributed_ddl_task_timeout=0 -q \
@ -71,7 +76,8 @@ function alter_table()
function insert() function insert()
{ {
while true; do local TIMELIMIT=$((SECONDS+$1))
while [ $SECONDS -lt "$TIMELIMIT" ]; do
table=$($CLICKHOUSE_CLIENT -q "select database || '.' || name from system.tables where database like '${CLICKHOUSE_DATABASE}%' order by rand() limit 1") table=$($CLICKHOUSE_CLIENT -q "select database || '.' || name from system.tables where database like '${CLICKHOUSE_DATABASE}%' order by rand() limit 1")
if [ -z "$table" ]; then continue; fi if [ -z "$table" ]; then continue; fi
$CLICKHOUSE_CLIENT -q \ $CLICKHOUSE_CLIENT -q \
@ -81,23 +87,16 @@ function insert()
export -f create_db
export -f drop_db
export -f sync_db
export -f create_table
export -f alter_table
export -f insert
TIMEOUT=30 TIMEOUT=30
timeout $TIMEOUT bash -c create_db & create_db $TIMEOUT &
timeout $TIMEOUT bash -c sync_db & sync_db $TIMEOUT &
timeout $TIMEOUT bash -c create_table & create_table $TIMEOUT &
timeout $TIMEOUT bash -c alter_table & alter_table $TIMEOUT &
timeout $TIMEOUT bash -c insert & insert $TIMEOUT &
sleep 1 # give other queries a head start sleep 1 # give other queries a head start
timeout $TIMEOUT bash -c drop_db & drop_db $TIMEOUT &
wait wait