thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-11-24 00:22:29 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix bad test 01602_max_distributed_connections

Browse Source
This commit is contained in:
Alexey Milovidov 2021-04-19 22:36:45 +03:00
parent 2d3b4af67a
commit f7d3f77222
1 changed files with 24 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

32
tests/queries/0_stateless/01602_max_distributed_connections.sh
View File

@ -4,13 +4,29 @@ CURDIR=$(cd "$(dirname "${BASH_SOURCE[0]}")" && pwd)
# shellcheck source=../shell_config.sh
. "$CURDIR"/../shell_config.sh
common_opts=(
"--format=Null"
# We check that even if max_threads is small, the setting max_distributed_connections
# will allow to process queries on multiple shards concurrently.
"--max_threads=1"
"--max_distributed_connections=3"
)
# We do sleep 0.15 seconds on ten machines.
# If concurrency is one (bad) the query will take at least 1.5 seconds and the following loops are guaranteed to be infinite.
# If concurrency is 10 (good), the query may take less than 1 second with non-zero probability
# and the following loops will finish with probability 1 assuming independent random variables.
# NOTE: the test use higher timeout to avoid flakiness.
timeout 9s ${CLICKHOUSE_CLIENT} "$@" "${common_opts[@]}" -q "select sleep(3) from remote('127.{1,2,3,4,5}', system.one)" --prefer_localhost_replica=0
timeout 9s ${CLICKHOUSE_CLIENT} "$@" "${common_opts[@]}" -q "select sleep(3) from remote('127.{1,2,3,4,5}', system.one)" --prefer_localhost_replica=1
while true; do
timeout 1 ${CLICKHOUSE_CLIENT} --max_threads 1 --max_distributed_connections 10 --query "
SELECT sleep(0.15) FROM remote('127.{1..10}', system.one) FORMAT Null" --prefer_localhost_replica=0 && break
done
while true; do
timeout 1 ${CLICKHOUSE_CLIENT} --max_threads 1 --max_distributed_connections 10 --query "
SELECT sleep(0.15) FROM remote('127.{1..10}', system.one) FORMAT Null" --prefer_localhost_replica=1 && break
done
# If max_distributed_connections is low and async_socket_for_remote is disabled,
# the concurrency of distributed queries will be also low.
timeout 1 ${CLICKHOUSE_CLIENT} --max_threads 1 --max_distributed_connections 1 --async_socket_for_remote 0 --query "
SELECT sleep(0.15) FROM remote('127.{1..10}', system.one) FORMAT Null" --prefer_localhost_replica=0 && echo 'Fail'
timeout 1 ${CLICKHOUSE_CLIENT} --max_threads 1 --max_distributed_connections 1 --async_socket_for_remote 0 --query "
SELECT sleep(0.15) FROM remote('127.{1..10}', system.one) FORMAT Null" --prefer_localhost_replica=1 && echo 'Fail'