diff --git a/dbms/src/Client/PerformanceTest.cpp b/dbms/src/Client/PerformanceTest.cpp
index c91f6c54d21..9300b0aac1b 100644
--- a/dbms/src/Client/PerformanceTest.cpp
+++ b/dbms/src/Client/PerformanceTest.cpp
@@ -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;