diff --git a/dbms/src/Interpreters/ClusterProxy/SelectStreamFactory.cpp b/dbms/src/Interpreters/ClusterProxy/SelectStreamFactory.cpp
index b3605201dc4..a0db1af955b 100644
--- a/dbms/src/Interpreters/ClusterProxy/SelectStreamFactory.cpp
+++ b/dbms/src/Interpreters/ClusterProxy/SelectStreamFactory.cpp
@@ -93,7 +93,7 @@ Pipe createLocalStream(const ASTPtr & query_ast, const Block & header, const Con
      */
     /// return std::make_shared<MaterializingBlockInputStream>(stream);
 
-    return interpreter.executeWithProcessors().getPipe();
+    return std::move(pipeline).getPipe();
 }
 
 static String formattedAST(const ASTPtr & ast)