Use new RemoteBlockInputStream's interface

This commit is contained in:
ivanzhukov 2017-05-05 15:28:28 +03:00
parent c6f35247bf
commit 73fa7905f0

View File

@ -951,7 +951,7 @@ private:
statistics[statisticIndex].watch_per_query.restart();
std::shared_ptr<RemoteBlockInputStream> stream
= std::make_shared<RemoteBlockInputStream>(connection, query, &settings, nullptr, Tables() /*, query_processing_stage*/
= std::make_shared<RemoteBlockInputStream>(*connection, query, &settings, nullptr, Tables() /*, query_processing_stage*/
);
size_t stream_index;