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

Fix bad test

Browse Source
This commit is contained in:
Alexey Milovidov 2020-12-08 02:09:47 +03:00
parent 1a01dbaa00
commit fa08c59d14
2 changed files with 28 additions and 28 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

28
tests/queries/0_stateless/01532_execute_merges_on_single_replica.reference
View File

@ -1,9 +1,9 @@
############################
### emulate normal feature operation - merges are distributed between replicas
############################
### emulate execute_merges_on_single_replica_time_threshold timeout
############################
### timeout not exceeded, r1 waits for r2
****************************
*** emulate normal feature operation - merges are distributed between replicas
****************************
*** emulate execute_merges_on_single_replica_time_threshold timeout
****************************
*** timeout not exceeded, r1 waits for r2
Row 1:
──────
table: execute_on_single_replica_r1
@ -19,8 +19,8 @@ type: MERGE_PARTS
new_part_name: all_0_0_5
has_postpones: 0
postpone_reason:
############################
### timeout exceeded, r1 failed to get the merged part from r2 and did the merge by its own
****************************
*** timeout exceeded, r1 failed to get the merged part from r2 and did the merge by its own
Row 1:
──────
table: execute_on_single_replica_r2
@ -28,12 +28,12 @@ type: MERGE_PARTS
new_part_name: all_0_0_5
has_postpones: 0
postpone_reason:
############################
### queue unfreeze
############################
### disable the feature
############################
### part_log
****************************
*** queue unfreeze
****************************
*** disable the feature
****************************
*** part_log
Row 1:
──────
part_name: all_0_0_1

28
tests/queries/0_stateless/01532_execute_merges_on_single_replica.sql
View File

@ -10,8 +10,8 @@ SYSTEM SYNC REPLICA execute_on_single_replica_r2;
SET optimize_throw_if_noop=1;
SELECT '############################';
SELECT '### emulate normal feature operation - merges are distributed between replicas';
SELECT '****************************';
SELECT '*** emulate normal feature operation - merges are distributed between replicas';
/* all_0_0_1 - will be merged by r1, and downloaded by r2 */
OPTIMIZE TABLE execute_on_single_replica_r1 FINAL;
@ -29,8 +29,8 @@ SYSTEM SYNC REPLICA execute_on_single_replica_r2;
OPTIMIZE TABLE execute_on_single_replica_r2 FINAL;
SYSTEM SYNC REPLICA execute_on_single_replica_r1;
SELECT '############################';
SELECT '### emulate execute_merges_on_single_replica_time_threshold timeout';
SELECT '****************************';
SELECT '*** emulate execute_merges_on_single_replica_time_threshold timeout';
SYSTEM STOP REPLICATION QUEUES execute_on_single_replica_r2;
@ -40,8 +40,8 @@ OPTIMIZE TABLE execute_on_single_replica_r1 FINAL SETTINGS replication_alter_par
/* if we will check immediately we can find the log entry unchecked */
SELECT * FROM numbers(4) where sleepEachRow(1);
SELECT '############################';
SELECT '### timeout not exceeded, r1 waits for r2';
SELECT '****************************';
SELECT '*** timeout not exceeded, r1 waits for r2';
/* we can now check that r1 waits for r2 */
SELECT
@ -59,8 +59,8 @@ FORMAT Vertical;
/* we have execute_merges_on_single_replica_time_threshold exceeded */
SELECT * FROM numbers(10) where sleepEachRow(1);
SELECT '############################';
SELECT '### timeout exceeded, r1 failed to get the merged part from r2 and did the merge by its own';
SELECT '****************************';
SELECT '*** timeout exceeded, r1 failed to get the merged part from r2 and did the merge by its own';
SELECT
table,
@ -77,8 +77,8 @@ FORMAT Vertical;
SYSTEM START REPLICATION QUEUES execute_on_single_replica_r2;
SYSTEM SYNC REPLICA execute_on_single_replica_r2;
SELECT '############################';
SELECT '### queue unfreeze';
SELECT '****************************';
SELECT '*** queue unfreeze';
SELECT
table,
@ -92,8 +92,8 @@ AND database = currentDatabase()
ORDER BY table
FORMAT Vertical;
SELECT '############################';
SELECT '### disable the feature';
SELECT '****************************';
SELECT '*** disable the feature';
ALTER TABLE execute_on_single_replica_r1 MODIFY SETTING execute_merges_on_single_replica_time_threshold=0;
ALTER TABLE execute_on_single_replica_r2 MODIFY SETTING execute_merges_on_single_replica_time_threshold=0;
@ -108,8 +108,8 @@ SYSTEM SYNC REPLICA execute_on_single_replica_r2;
SYSTEM FLUSH LOGS;
SELECT '############################';
SELECT '### part_log';
SELECT '****************************';
SELECT '*** part_log';
SELECT
part_name,
arraySort(groupArrayIf(table, event_type = 'MergeParts')) AS mergers,