ClickHouse/tests/queries/0_stateless/replication.lib

87 lines
4.4 KiB
Plaintext
Raw Normal View History

#!/usr/bin/env bash
# shellcheck source=./mergetree_mutations.lib
. "$CURDIR"/mergetree_mutations.lib
2021-08-11 15:24:47 +00:00
function try_sync_replicas()
{
2021-08-24 15:56:32 +00:00
table_name_prefix=$1
2021-08-16 09:18:52 +00:00
readarray -t empty_partitions_arr < <(${CLICKHOUSE_CLIENT} -q \
"SELECT DISTINCT substr(new_part_name, 1, position(new_part_name, '_') - 1) AS partition_id
FROM system.replication_queue
2021-08-24 15:56:32 +00:00
WHERE (database = currentDatabase()) AND (table LIKE '$table_name_prefix%') AND (last_exception LIKE '%No active replica has part%') AND (partition_id NOT IN (
2021-08-16 09:18:52 +00:00
SELECT partition_id
FROM system.parts
2021-08-24 15:56:32 +00:00
WHERE (database = currentDatabase()) AND (table LIKE '$table_name_prefix%')
2021-08-16 09:18:52 +00:00
))")
2021-08-24 15:56:32 +00:00
readarray -t tables_arr < <(${CLICKHOUSE_CLIENT} -q "SELECT name FROM system.tables WHERE database=currentDatabase() AND name like '$table_name_prefix%' AND engine like '%Replicated%'")
2021-08-16 09:18:52 +00:00
for t in "${tables_arr[@]}"
do
for p in "${empty_partitions_arr[@]}"
do
# Avoid "Empty part ... is not created instead of lost part because there are no parts in partition"
$CLICKHOUSE_CLIENT -q "ALTER TABLE $t DROP PARTITION ID '$p'" 2>/dev/null
done
done
for t in "${tables_arr[@]}"
do
# The size of log may be big, so increase timeout.
2021-08-12 10:39:06 +00:00
$CLICKHOUSE_CLIENT --receive_timeout 400 -q "SYSTEM SYNC REPLICA $t" || $CLICKHOUSE_CLIENT -q \
2021-08-16 09:18:52 +00:00
"select 'sync failed, queue:', * from system.replication_queue where database=currentDatabase() and table='$t' order by database, table, node_name" &
done
wait
2021-08-24 15:56:32 +00:00
echo "Replication did not hang: synced all replicas of $table_name_prefix"
}
function check_replication_consistency()
{
2021-08-24 15:56:32 +00:00
table_name_prefix=$1
check_query_part=$2
2021-08-23 19:28:30 +00:00
# Do not check anything if all replicas are readonly,
# because is this case all replicas are probably lost (it may happen and it's not a bug)
2021-08-24 15:56:32 +00:00
res=$($CLICKHOUSE_CLIENT -q "SELECT count() - sum(is_readonly) FROM system.replicas WHERE database=currentDatabase() AND table LIKE '$table_name_prefix%'")
2021-08-23 19:28:30 +00:00
if [ $res -eq 0 ]; then
# Print dummy lines
2021-08-24 15:56:32 +00:00
echo "Replication did not hang: synced all replicas of $table_name_prefix"
2021-08-23 19:28:30 +00:00
echo "Consistency: 1"
return 0
fi
2021-08-16 12:36:12 +00:00
# Trigger pullLogsToQueue(...) and updateMutations(...) on some replica to make it pull all mutations, so it will be possible to kill them
2021-08-24 15:56:32 +00:00
some_table=$($CLICKHOUSE_CLIENT -q "SELECT name FROM system.tables WHERE database=currentDatabase() AND name like '$table_name_prefix%' ORDER BY rand() LIMIT 1")
2021-08-17 18:10:08 +00:00
$CLICKHOUSE_CLIENT --receive_timeout 3 -q "SYSTEM SYNC REPLICA $some_table" 1>/dev/null 2>/dev/null ||:
2021-08-24 15:56:32 +00:00
some_table=$($CLICKHOUSE_CLIENT -q "SELECT name FROM system.tables WHERE database=currentDatabase() AND name like '$table_name_prefix%' ORDER BY rand() LIMIT 1")
2021-08-16 12:51:04 +00:00
$CLICKHOUSE_CLIENT --receive_timeout 3 -q "SYSTEM SYNC REPLICA $some_table" 1>/dev/null 2>/dev/null ||:
2021-08-16 12:36:12 +00:00
2021-08-11 15:24:47 +00:00
# Forcefully cancel mutations to avoid waiting for them to finish
2021-08-24 15:56:32 +00:00
${CLICKHOUSE_CLIENT} -q "KILL MUTATION WHERE database=currentDatabase() AND table like '$table_name_prefix%'" > /dev/null
# SYNC REPLICA is not enough if some MUTATE_PARTs are not assigned yet
2021-08-24 15:56:32 +00:00
wait_for_all_mutations "$table_name_prefix%"
2021-08-24 15:56:32 +00:00
try_sync_replicas "$table_name_prefix"
2021-08-11 15:24:47 +00:00
2021-08-12 10:39:06 +00:00
res=$($CLICKHOUSE_CLIENT -q \
"SELECT
2021-08-12 15:58:49 +00:00
if((countDistinct(data) as c) == 0, 1, c)
FROM
(
2021-08-24 15:56:32 +00:00
SELECT _table, ($check_query_part) AS data
FROM merge(currentDatabase(), '$table_name_prefix') GROUP BY _table
2021-08-12 10:39:06 +00:00
)")
echo "Consistency: $res"
if [ $res -ne 1 ]; then
echo "Replicas have diverged:"
2021-08-24 15:56:32 +00:00
$CLICKHOUSE_CLIENT -q "select 'data', _table, $check_query_part, arraySort(groupArrayDistinct(_part)) from merge(currentDatabase(), '$table_name_prefix') group by _table order by _table"
$CLICKHOUSE_CLIENT -q "select 'queue', * from system.replication_queue where database=currentDatabase() and table like '$table_name_prefix%' order by database, table, node_name"
$CLICKHOUSE_CLIENT -q "select 'mutations', * from system.mutations where database=currentDatabase() and table like '$table_name_prefix%' order by database, table, mutation_id"
$CLICKHOUSE_CLIENT -q "select 'parts', * from system.parts where database=currentDatabase() and table like '$table_name_prefix%' order by database, table, name"
2021-08-12 10:39:06 +00:00
echo "Good luck with debugging..."
2021-08-11 15:24:47 +00:00
fi
}