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

Fixing tests.

Browse Source
This commit is contained in:
Nikolai Kochetov 2020-12-14 19:18:12 +03:00
parent db9ad80168
commit 3af47d2bda
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/DataStreams/RemoteQueryExecutor.cpp
View File

@ -217,7 +217,7 @@ std::variant<Block, int> RemoteQueryExecutor::read(std::unique_ptr<ReadContext>
do
{
if (!read_context->resumeRoutine(was_cancelled_mutex))
if (!read_context->resumeRoutine())
return Block();
if (read_context->is_read_in_progress)
@ -312,7 +312,7 @@ void RemoteQueryExecutor::finish(std::unique_ptr<ReadContext> * read_context)
return;
if (read_context && *read_context)
(*read_context)->cancel(was_cancelled_mutex);
(*read_context)->cancel();
/** If you have not read all the data yet, but they are no longer needed.
* This may be due to the fact that the data is sufficient (for example, when using LIMIT).
@ -363,7 +363,7 @@ void RemoteQueryExecutor::cancel(std::unique_ptr<ReadContext> * read_context)
return;
if (read_context && *read_context)
(*read_context)->cancel(was_cancelled_mutex);
(*read_context)->cancel();
tryCancel("Cancelling query");
}