thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-09-20 08:40:50 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix 00613_shard_distributed_max_execution_time flakyness

Browse Source
This commit is contained in:
Raúl Marín 2021-11-23 14:50:23 +01:00
parent cbe3a47f2f
commit 15dc86bd37
3 changed files with 3 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/Processors/Executors/PipelineExecutor.cpp
View File

@ -142,6 +142,8 @@ bool PipelineExecutor::checkTimeLimit()
throw Exception("Query was cancelled", ErrorCodes::QUERY_WAS_CANCELLED); throw Exception("Query was cancelled", ErrorCodes::QUERY_WAS_CANCELLED);
bool cont = limits.checkTimeLimit(process_list_element->watch, overflow_mode); bool cont = limits.checkTimeLimit(process_list_element->watch, overflow_mode);
// We call cancel here so that all processors are notified and tasks waken up
// so that the "break" is faster and doesn't wait for long events
if (!cont) if (!cont)
cancel(); cancel();
return cont; return cont;

10
tests/queries/0_stateless/00613_shard_distributed_max_execution_time.reference
View File

@ -1,10 +0,0 @@
0
1
2
3
4
5
6
7
8
9

2
tests/queries/0_stateless/00613_shard_distributed_max_execution_time.sql
View File

@ -1,4 +1,4 @@
-- Tags: distributed -- Tags: distributed
SET max_execution_time = 1, timeout_overflow_mode = 'break'; SET max_execution_time = 1, timeout_overflow_mode = 'break';
SELECT DISTINCT * FROM remote('127.0.0.{2,3}', system.numbers) WHERE number < 10; SELECT * FROM remote('127.0.0.{2,3}', system.numbers) WHERE number < 10 FORMAT Null;