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

Try fix race

Browse Source
This commit is contained in:
kssenii 2024-11-15 15:53:25 +01:00
parent 8c1dee30a9
commit 2a5385b4a0
1 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/Interpreters/Cache/FileSegment.cpp
View File

@ -321,7 +321,9 @@ void FileSegment::resetRemoteFileReader()
FileSegment::RemoteFileReaderPtr FileSegment::extractRemoteFileReader()
{
auto lk = lock();
if (remote_file_reader && (download_state == State::DOWNLOADED
if (remote_file_reader
&& remote_file_reader.unique()
&& (download_state == State::DOWNLOADED
|| download_state == State::PARTIALLY_DOWNLOADED_NO_CONTINUATION))
{
return std::move(remote_file_reader);