Fixed error [#METR-21408].

dbms/include/DB/DataStreams/AsynchronousBlockInputStream.h

@@ -39,9 +39,11 @@ public:
 	void readPrefix() override
 	{
 		/// Не будем вызывать readPrefix у ребёнка, чтобы соответствующие действия совершались в отдельном потоке.
-
-		next();
-		started = true;
+		if (!started)
+		{
+			next();
+			started = true;
+		}
 	}
 
 	void readSuffix() override

dbms/src/DataStreams/MergingSortedBlockInputStream.cpp

@@ -22,10 +22,6 @@ void MergingSortedBlockInputStream::init(Block & merged_block, ColumnPlainPtrs &
 	{
 		first = false;
 
-		/// Например, если дети - AsynchronousBlockInputStream, это действие инициирует начало работы в фоновых потоках.
-		for (auto & child : children)
-			child->readPrefix();
-
 		size_t i = 0;
 		for (auto it = source_blocks.begin(); it != source_blocks.end(); ++it, ++i)
 		{