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

CLICKHOUSE-3476 fix

Browse Source
This commit is contained in:
VadimPE 2018-09-14 12:33:11 +03:00
parent 383f0da97d
commit 62726d53d4
1 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
dbms/src/Dictionaries/ClickHouseDictionarySource.cpp
View File

@ -163,17 +163,17 @@ BlockInputStreamPtr ClickHouseDictionarySource::createStreamForSelectiveLoad(con
std::string ClickHouseDictionarySource::doInvalidateQuery(const std::string & request) const
{
Block invalidate_sample_block;
if (is_local)
{
auto input_block = executeQuery(request, context, true).in;
return readInvalidateQuery(dynamic_cast<IProfilingBlockInputStream&>((*input_block)));
}
auto invalidate_stream = RemoteBlockInputStream(pool, request, invalidate_sample_block, context);
return readInvalidateQuery(invalidate_stream);
else
{
Block invalidate_sample_block;
RemoteBlockInputStream invalidate_stream(pool, request, invalidate_sample_block, context);
return readInvalidateQuery(invalidate_stream);
}
}
}