thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-09-20 08:40:50 +00:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #36015 from ucasfl/filelog-fix

Browse Source 
Fix data race in StorgeFileLog
This commit is contained in:
Kseniia Sumarokova 2022-04-07 12:23:12 +02:00 committed by GitHub
commit 5909b3c04d
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
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");
size_t rows = 0;
std::atomic<size_t> rows = 0;
{
block_io.pipeline.complete(std::move(input));
block_io.pipeline.setNumThreads(max_streams_number);