thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-11-10 01:25:21 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix test 03221_mutation_analyzer_skip_part

Browse Source
This commit is contained in:
Anton Popov 2024-08-15 13:42:57 +00:00
parent 014c1650f8
commit 9fec833d95
2 changed files with 53 additions and 33 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

53
tests/queries/0_stateless/03221_mutate_profile_events.sh Executable file
View File

@ -0,0 +1,53 @@
#!/usr/bin/env bash
# Tags: no-random-settings, no-random-merge-tree-settings
CUR_DIR=$(cd "$(dirname "${BASH_SOURCE[0]}")" && pwd)
# shellcheck source=../shell_config.sh
. "$CUR_DIR"/../shell_config.sh
${CLICKHOUSE_CLIENT} --query "
DROP TABLE IF EXISTS t_mutate_profile_events;
CREATE TABLE t_mutate_profile_events (key UInt64, id UInt64, v1 UInt64, v2 UInt64)
ENGINE = MergeTree ORDER BY id PARTITION BY key
SETTINGS min_bytes_for_wide_part = 0;
INSERT INTO t_mutate_profile_events SELECT 1, number, number, number FROM numbers(10000);
INSERT INTO t_mutate_profile_events SELECT 2, number, number, number FROM numbers(10000);
SET mutations_sync = 2;
ALTER TABLE t_mutate_profile_events UPDATE v1 = 1000 WHERE key = 1;
ALTER TABLE t_mutate_profile_events DELETE WHERE key = 2 AND v2 % 10 = 0;
"
# Mutation query may return before the entry is added to part log.
# So, we may have to retry the flush of logs until all entries are actually flushed.
for _ in {1..10}; do
${CLICKHOUSE_CLIENT} --query "SYSTEM FLUSH LOGS"
res=$(${CLICKHOUSE_CLIENT} --query "SELECT count() FROM system.part_log WHERE database = currentDatabase() AND table = 't_mutate_profile_events' AND event_type = 'MutatePart'")
if [[ $res -eq 4 ]]; then
break
fi
sleep 2.0
done
${CLICKHOUSE_CLIENT} --query "
SELECT
splitByChar('_', part_name)[-1] AS version,
sum(ProfileEvents['MutationTotalParts']),
sum(ProfileEvents['MutationUntouchedParts']),
sum(ProfileEvents['MutatedRows']),
sum(ProfileEvents['MutatedUncompressedBytes']),
sum(ProfileEvents['MutationAllPartColumns']),
sum(ProfileEvents['MutationSomePartColumns']),
sum(ProfileEvents['MutationTotalMilliseconds']) > 0,
sum(ProfileEvents['MutationExecuteMilliseconds']) > 0,
FROM system.part_log
WHERE database = currentDatabase() AND table = 't_mutate_profile_events' AND event_type = 'MutatePart'
GROUP BY version ORDER BY version;
DROP TABLE IF EXISTS t_mutate_profile_events;
"

33
tests/queries/0_stateless/03221_mutate_profile_events.sql
View File

@ -1,33 +0,0 @@
-- Tags: no-random-settings, no-random-merge-tree-settings
DROP TABLE IF EXISTS t_mutate_profile_events;
CREATE TABLE t_mutate_profile_events (key UInt64, id UInt64, v1 UInt64, v2 UInt64)
ENGINE = MergeTree ORDER BY id PARTITION BY key
SETTINGS min_bytes_for_wide_part = 0;
INSERT INTO t_mutate_profile_events SELECT 1, number, number, number FROM numbers(10000);
INSERT INTO t_mutate_profile_events SELECT 2, number, number, number FROM numbers(10000);
SET mutations_sync = 2;
ALTER TABLE t_mutate_profile_events UPDATE v1 = 1000 WHERE key = 1;
ALTER TABLE t_mutate_profile_events DELETE WHERE key = 2 AND v2 % 10 = 0;
SYSTEM FLUSH LOGS;
SELECT
splitByChar('_', part_name)[-1] AS version,
sum(ProfileEvents['MutationTotalParts']),
sum(ProfileEvents['MutationUntouchedParts']),
sum(ProfileEvents['MutatedRows']),
sum(ProfileEvents['MutatedUncompressedBytes']),
sum(ProfileEvents['MutationAllPartColumns']),
sum(ProfileEvents['MutationSomePartColumns']),
sum(ProfileEvents['MutationTotalMilliseconds']) > 0,
sum(ProfileEvents['MutationExecuteMilliseconds']) > 0,
FROM system.part_log
WHERE database = currentDatabase() AND table = 't_mutate_profile_events' AND event_type = 'MutatePart'
GROUP BY version ORDER BY version;
DROP TABLE IF EXISTS t_mutate_profile_events