From 62726d53d4f5821369879d84f1002ed56ca583c6 Mon Sep 17 00:00:00 2001 From: VadimPE Date: Fri, 14 Sep 2018 12:33:11 +0300 Subject: [PATCH] CLICKHOUSE-3476 fix --- dbms/src/Dictionaries/ClickHouseDictionarySource.cpp | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) diff --git a/dbms/src/Dictionaries/ClickHouseDictionarySource.cpp b/dbms/src/Dictionaries/ClickHouseDictionarySource.cpp index 191ae30ec5d..186b842bf88 100644 --- a/dbms/src/Dictionaries/ClickHouseDictionarySource.cpp +++ b/dbms/src/Dictionaries/ClickHouseDictionarySource.cpp @@ -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((*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); + } } }