|
1 | 1 | #!/usr/bin/env bash |
2 | 2 | # Tags: zookeeper, no-parallel |
3 | 3 |
|
4 | | -CURDIR=$(cd "$(dirname "${BASH_SOURCE[0]}")" && pwd) |
5 | | -# shellcheck source=../shell_config.sh |
6 | | -. "$CURDIR"/../shell_config.sh |
| 4 | +# CURDIR=$(cd "$(dirname "${BASH_SOURCE[0]}")" && pwd) |
| 5 | +# # shellcheck source=../shell_config.sh |
| 6 | +# . "$CURDIR"/../shell_config.sh |
7 | 7 |
|
8 | | -$CLICKHOUSE_CLIENT --query "DROP TABLE IF EXISTS replicated_mutation_table" |
| 8 | +# $CLICKHOUSE_CLIENT --query "DROP TABLE IF EXISTS replicated_mutation_table" |
9 | 9 |
|
10 | | -$CLICKHOUSE_CLIENT --query " |
11 | | - CREATE TABLE replicated_mutation_table( |
12 | | - date Date, |
13 | | - key UInt64, |
14 | | - value String |
15 | | - ) |
16 | | - ENGINE = ReplicatedMergeTree('/clickhouse/tables/$CLICKHOUSE_TEST_ZOOKEEPER_PREFIX/mutation_table', '1') |
17 | | - ORDER BY tuple() |
18 | | - PARTITION BY date |
19 | | -" |
| 10 | +# $CLICKHOUSE_CLIENT --query " |
| 11 | +# CREATE TABLE replicated_mutation_table( |
| 12 | +# date Date, |
| 13 | +# key UInt64, |
| 14 | +# value String |
| 15 | +# ) |
| 16 | +# ENGINE = ReplicatedMergeTree('/clickhouse/tables/$CLICKHOUSE_TEST_ZOOKEEPER_PREFIX/mutation_table', '1') |
| 17 | +# ORDER BY tuple() |
| 18 | +# PARTITION BY date |
| 19 | +# " |
20 | 20 |
|
21 | | -$CLICKHOUSE_CLIENT --query "INSERT INTO replicated_mutation_table SELECT toDate('2019-10-02'), number, '42' FROM numbers(4)" |
| 21 | +# $CLICKHOUSE_CLIENT --query "INSERT INTO replicated_mutation_table SELECT toDate('2019-10-02'), number, '42' FROM numbers(4)" |
22 | 22 |
|
23 | | -$CLICKHOUSE_CLIENT --query "INSERT INTO replicated_mutation_table SELECT toDate('2019-10-02'), number, 'Hello' FROM numbers(4)" |
| 23 | +# $CLICKHOUSE_CLIENT --query "INSERT INTO replicated_mutation_table SELECT toDate('2019-10-02'), number, 'Hello' FROM numbers(4)" |
24 | 24 |
|
25 | | -$CLICKHOUSE_CLIENT --query "ALTER TABLE replicated_mutation_table UPDATE key = key + 1 WHERE sleepEachRow(1) == 0 SETTINGS mutations_sync = 2" 2>&1 | grep -o 'Mutation 0000000000 was killed' | head -n 1 & |
| 25 | +# $CLICKHOUSE_CLIENT --query "ALTER TABLE replicated_mutation_table UPDATE key = key + 1 WHERE sleepEachRow(1) == 0 SETTINGS mutations_sync = 2" 2>&1 | grep -o 'Mutation 0000000000 was killed' | head -n 1 & |
26 | 26 |
|
27 | | -check_query="SELECT count() FROM system.mutations WHERE table='replicated_mutation_table' and database='$CLICKHOUSE_DATABASE' and mutation_id='0000000000'" |
| 27 | +# check_query="SELECT count() FROM system.mutations WHERE table='replicated_mutation_table' and database='$CLICKHOUSE_DATABASE' and mutation_id='0000000000'" |
28 | 28 |
|
29 | | -query_result=$($CLICKHOUSE_CLIENT --query="$check_query" 2>&1) |
| 29 | +# query_result=$($CLICKHOUSE_CLIENT --query="$check_query" 2>&1) |
30 | 30 |
|
31 | | -while [ "$query_result" != "1" ] |
32 | | -do |
33 | | - query_result=$($CLICKHOUSE_CLIENT --query="$check_query" 2>&1) |
34 | | - sleep 0.1 |
35 | | -done |
| 31 | +# while [ "$query_result" != "1" ] |
| 32 | +# do |
| 33 | +# query_result=$($CLICKHOUSE_CLIENT --query="$check_query" 2>&1) |
| 34 | +# sleep 0.1 |
| 35 | +# done |
36 | 36 |
|
37 | | -$CLICKHOUSE_CLIENT --query "KILL MUTATION WHERE table='replicated_mutation_table' and database='$CLICKHOUSE_DATABASE' and mutation_id='0000000000'" &> /dev/null |
| 37 | +# $CLICKHOUSE_CLIENT --query "KILL MUTATION WHERE table='replicated_mutation_table' and database='$CLICKHOUSE_DATABASE' and mutation_id='0000000000'" &> /dev/null |
38 | 38 |
|
39 | | -while [ "$query_result" != "0" ] |
40 | | -do |
41 | | - query_result=$($CLICKHOUSE_CLIENT --query="$check_query" 2>&1) |
42 | | - sleep 0.5 |
43 | | -done |
| 39 | +# while [ "$query_result" != "0" ] |
| 40 | +# do |
| 41 | +# query_result=$($CLICKHOUSE_CLIENT --query="$check_query" 2>&1) |
| 42 | +# sleep 0.5 |
| 43 | +# done |
44 | 44 |
|
45 | | -wait |
| 45 | +# wait |
46 | 46 |
|
47 | 47 |
|
48 | | -$CLICKHOUSE_CLIENT --query "ALTER TABLE replicated_mutation_table MODIFY COLUMN value UInt64 SETTINGS replication_alter_partitions_sync = 2" 2>&1 | grep -o "Cannot parse string 'Hello' as UInt64" | head -n 1 & |
| 48 | +# $CLICKHOUSE_CLIENT --query "ALTER TABLE replicated_mutation_table MODIFY COLUMN value UInt64 SETTINGS replication_alter_partitions_sync = 2" 2>&1 | grep -o "Cannot parse string 'Hello' as UInt64" | head -n 1 & |
49 | 49 |
|
50 | | -check_query="SELECT type = 'UInt64' FROM system.columns WHERE table='replicated_mutation_table' and database='$CLICKHOUSE_DATABASE' and name='value'" |
| 50 | +# check_query="SELECT type = 'UInt64' FROM system.columns WHERE table='replicated_mutation_table' and database='$CLICKHOUSE_DATABASE' and name='value'" |
51 | 51 |
|
52 | | -query_result=$($CLICKHOUSE_CLIENT --query="$check_query" 2>&1) |
| 52 | +# query_result=$($CLICKHOUSE_CLIENT --query="$check_query" 2>&1) |
53 | 53 |
|
54 | | -while [ "$query_result" != "1" ] |
55 | | -do |
56 | | - query_result=$($CLICKHOUSE_CLIENT --query="$check_query" 2>&1) |
57 | | - sleep 0.5 |
58 | | -done |
| 54 | +# while [ "$query_result" != "1" ] |
| 55 | +# do |
| 56 | +# query_result=$($CLICKHOUSE_CLIENT --query="$check_query" 2>&1) |
| 57 | +# sleep 0.5 |
| 58 | +# done |
59 | 59 |
|
60 | | -wait |
| 60 | +# wait |
61 | 61 |
|
62 | 62 |
|
63 | | -check_query="SELECT count() FROM system.mutations WHERE table='replicated_mutation_table' and database='$CLICKHOUSE_DATABASE' and mutation_id='0000000001'" |
| 63 | +# check_query="SELECT count() FROM system.mutations WHERE table='replicated_mutation_table' and database='$CLICKHOUSE_DATABASE' and mutation_id='0000000001'" |
64 | 64 |
|
65 | | -$CLICKHOUSE_CLIENT --query "KILL MUTATION WHERE table='replicated_mutation_table' and database='$CLICKHOUSE_DATABASE' AND mutation_id='0000000001'" &> /dev/null |
| 65 | +# $CLICKHOUSE_CLIENT --query "KILL MUTATION WHERE table='replicated_mutation_table' and database='$CLICKHOUSE_DATABASE' AND mutation_id='0000000001'" &> /dev/null |
66 | 66 |
|
67 | | -while [ "$query_result" != "0" ] |
68 | | -do |
69 | | - query_result=$($CLICKHOUSE_CLIENT --query="$check_query" 2>&1) |
70 | | - sleep 0.5 |
71 | | -done |
| 67 | +# while [ "$query_result" != "0" ] |
| 68 | +# do |
| 69 | +# query_result=$($CLICKHOUSE_CLIENT --query="$check_query" 2>&1) |
| 70 | +# sleep 0.5 |
| 71 | +# done |
72 | 72 |
|
73 | | -$CLICKHOUSE_CLIENT --query "SELECT distinct(value) FROM replicated_mutation_table ORDER BY value" 2>&1 | grep -o "Cannot parse string 'Hello' as UInt64" | head -n 1 |
| 73 | +# $CLICKHOUSE_CLIENT --query "SELECT distinct(value) FROM replicated_mutation_table ORDER BY value" 2>&1 | grep -o "Cannot parse string 'Hello' as UInt64" | head -n 1 |
74 | 74 |
|
75 | | -$CLICKHOUSE_CLIENT --query "ALTER TABLE replicated_mutation_table MODIFY COLUMN value String SETTINGS replication_alter_partitions_sync = 2" |
| 75 | +# $CLICKHOUSE_CLIENT --query "ALTER TABLE replicated_mutation_table MODIFY COLUMN value String SETTINGS replication_alter_partitions_sync = 2" |
76 | 76 |
|
77 | | -$CLICKHOUSE_CLIENT --query "SELECT distinct(value) FROM replicated_mutation_table ORDER BY value" |
| 77 | +# $CLICKHOUSE_CLIENT --query "SELECT distinct(value) FROM replicated_mutation_table ORDER BY value" |
78 | 78 |
|
0 commit comments