diff --git a/dbms/src/Storages/StorageDistributed.cpp b/dbms/src/Storages/StorageDistributed.cpp index cd421bde4af..dc210ac6f8a 100644 --- a/dbms/src/Storages/StorageDistributed.cpp +++ b/dbms/src/Storages/StorageDistributed.cpp @@ -413,7 +413,7 @@ Pipes StorageDistributed::readWithProcessors( } return ClusterProxy::executeQuery( - select_stream_factory, cluster, modified_query_ast, context, settings); + select_stream_factory, cluster, modified_query_ast, context, settings, query_info); }