diff --git a/dbms/include/DB/Dictionaries/ClickhouseDictionarySource.h b/dbms/include/DB/Dictionaries/ClickhouseDictionarySource.h index badd32057a1..5880ce8617a 100644 --- a/dbms/include/DB/Dictionaries/ClickhouseDictionarySource.h +++ b/dbms/include/DB/Dictionaries/ClickhouseDictionarySource.h @@ -3,11 +3,10 @@ #include #include #include -#include -#include #include #include #include +#include namespace DB { @@ -50,7 +49,9 @@ public: BlockInputStreamPtr loadAll() override { if (is_local) - return executeQuery(load_all_query, context).in; + return new RemoteBlockInputStream{pool.get(), load_all_query, nullptr}; + /// should be processed locally but due to some coupling problems cannot be handled properly now + /// return executeQuery(load_all_query, context).in; return new RemoteBlockInputStream{pool.get(), load_all_query, nullptr}; }