thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-11-21 15:12:02 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix data race in StorgeFileLog

Browse Source
This commit is contained in:
fenglv 2022-04-07 02:20:20 +00:00
parent e7fdb0ddce
commit 517c2ae8df
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/Storages/FileLog/StorageFileLog.cpp
View File

@ -720,7 +720,7 @@ bool StorageFileLog::streamToViews()
assertBlocksHaveEqualStructure(input.getHeader(), block_io.pipeline.getHeader(), "StorageFileLog streamToViews"); assertBlocksHaveEqualStructure(input.getHeader(), block_io.pipeline.getHeader(), "StorageFileLog streamToViews");
size_t rows = 0; std::atomic<size_t> rows = 0;
{ {
block_io.pipeline.complete(std::move(input)); block_io.pipeline.complete(std::move(input));
block_io.pipeline.setNumThreads(max_streams_number); block_io.pipeline.setNumThreads(max_streams_number);