diff --git a/src/QueryPipeline/narrowBlockInputStreams.cpp b/src/QueryPipeline/narrowPipe.cpp
similarity index 97%
rename from src/QueryPipeline/narrowBlockInputStreams.cpp
rename to src/QueryPipeline/narrowPipe.cpp
index 19bebe4a0bf..9dc579eb34f 100644
--- a/src/QueryPipeline/narrowBlockInputStreams.cpp
+++ b/src/QueryPipeline/narrowPipe.cpp
@@ -1,8 +1,9 @@
+#include <QueryPipeline/narrowPipe.h>
+
 #include <random>
 #include <Common/thread_local_rng.h>
 #include <Processors/ConcatProcessor.h>
 #include <QueryPipeline/Pipe.h>
-#include "narrowBlockInputStreams.h"
 
 
 namespace DB
diff --git a/src/QueryPipeline/narrowBlockInputStreams.h b/src/QueryPipeline/narrowPipe.h
similarity index 85%
rename from src/QueryPipeline/narrowBlockInputStreams.h
rename to src/QueryPipeline/narrowPipe.h
index c026f5fbedf..e271669b8d1 100644
--- a/src/QueryPipeline/narrowBlockInputStreams.h
+++ b/src/QueryPipeline/narrowPipe.h
@@ -9,7 +9,7 @@ namespace DB
 class Pipe;
 
 /** If the number of sources of `inputs` is greater than `width`,
-  *  then glues the sources to each other (using ConcatBlockInputStream),
+  *  then glues the sources to each other (using ConcatProcessor),
   *  so that the number of sources becomes no more than `width`.
   *
   * Trying to glue the sources with each other uniformly randomly.
diff --git a/src/Storages/HDFS/StorageHDFSCluster.cpp b/src/Storages/HDFS/StorageHDFSCluster.cpp
index 3e02fd46596..fd242169a8a 100644
--- a/src/Storages/HDFS/StorageHDFSCluster.cpp
+++ b/src/Storages/HDFS/StorageHDFSCluster.cpp
@@ -11,7 +11,7 @@
 #include <Interpreters/InterpreterSelectQuery.h>
 #include <Interpreters/getTableExpressions.h>
 #include <Processors/Transforms/AddingDefaultsTransform.h>
-#include <QueryPipeline/narrowBlockInputStreams.h>
+#include <QueryPipeline/narrowPipe.h>
 #include <QueryPipeline/Pipe.h>
 #include <Processors/Sources/RemoteSource.h>
 #include <QueryPipeline/RemoteQueryExecutor.h>
diff --git a/src/Storages/StorageMerge.cpp b/src/Storages/StorageMerge.cpp
index f28ebe01eaf..5b1586040df 100644
--- a/src/Storages/StorageMerge.cpp
+++ b/src/Storages/StorageMerge.cpp
@@ -1,4 +1,4 @@
-#include <QueryPipeline/narrowBlockInputStreams.h>
+#include <QueryPipeline/narrowPipe.h>
 #include <Processors/Sources/SourceFromSingleChunk.h>
 #include <Storages/StorageMerge.h>
 #include <Storages/StorageFactory.h>
diff --git a/src/Storages/StorageS3.cpp b/src/Storages/StorageS3.cpp
index b393a479c1b..94f7c34323b 100644
--- a/src/Storages/StorageS3.cpp
+++ b/src/Storages/StorageS3.cpp
@@ -36,7 +36,7 @@
 #include <Processors/Transforms/AddingDefaultsTransform.h>
 #include <Processors/Formats/IOutputFormat.h>
 #include <Processors/Formats/IInputFormat.h>
-#include <QueryPipeline/narrowBlockInputStreams.h>
+#include <QueryPipeline/narrowPipe.h>
 
 #include <QueryPipeline/QueryPipelineBuilder.h>
 #include <Processors/Executors/PullingPipelineExecutor.h>
diff --git a/src/Storages/StorageS3Cluster.cpp b/src/Storages/StorageS3Cluster.cpp
index 36b839bf572..16f465c0b5a 100644
--- a/src/Storages/StorageS3Cluster.cpp
+++ b/src/Storages/StorageS3Cluster.cpp
@@ -21,7 +21,7 @@
 #include <Interpreters/InterpreterSelectQuery.h>
 #include <Interpreters/getTableExpressions.h>
 #include <Processors/Transforms/AddingDefaultsTransform.h>
-#include <QueryPipeline/narrowBlockInputStreams.h>
+#include <QueryPipeline/narrowPipe.h>
 #include <QueryPipeline/Pipe.h>
 #include "Processors/Sources/SourceWithProgress.h"
 #include <Processors/Sources/RemoteSource.h>