From a2ce366c3420a2806eb6974e3cb45020115deb39 Mon Sep 17 00:00:00 2001
From: fenglv <fenglv15@mails.ucas.ac.cn>
Date: Wed, 6 Apr 2022 04:49:43 +0000
Subject: [PATCH] parallel reading files for FileLog Engine

---
 src/Storages/FileLog/StorageFileLog.cpp | 1 +
 1 file changed, 1 insertion(+)

diff --git a/src/Storages/FileLog/StorageFileLog.cpp b/src/Storages/FileLog/StorageFileLog.cpp
index 32ca936f039..4fb19b12bab 100644
--- a/src/Storages/FileLog/StorageFileLog.cpp
+++ b/src/Storages/FileLog/StorageFileLog.cpp
@@ -723,6 +723,7 @@ bool StorageFileLog::streamToViews()
     size_t rows = 0;
     {
         block_io.pipeline.complete(std::move(input));
+        block_io.pipeline.setNumThreads(max_streams_number);
         block_io.pipeline.setProgressCallback([&](const Progress & progress) { rows += progress.read_rows.load(); });
         CompletedPipelineExecutor executor(block_io.pipeline);
         executor.execute();