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

fix

Browse Source
This commit is contained in:
xiedeyantu 2022-12-23 19:33:08 +08:00
parent d0eb22a1cd
commit 68aeb39892
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/Storages/StorageS3.cpp
View File

@ -552,7 +552,7 @@ StorageS3Source::StorageS3Source(
, create_reader_scheduler(threadPoolCallbackRunner<ReaderHolder>(create_reader_pool, "CreateS3Reader")) , create_reader_scheduler(threadPoolCallbackRunner<ReaderHolder>(create_reader_pool, "CreateS3Reader"))
{ {
reader = createReader(); reader = createReader();
if (reader || if (reader ||
(reader.getReadMode() == StorageS3Source::ReaderHolder::ONLY_VIRTUAL_COLUMNS && (reader.getReadMode() == StorageS3Source::ReaderHolder::ONLY_VIRTUAL_COLUMNS &&
!reader.isFinishedForOnlyVirtualColumns())) !reader.isFinishedForOnlyVirtualColumns()))
reader_future = createReaderAsync(); reader_future = createReaderAsync();
@ -756,7 +756,7 @@ Chunk StorageS3Source::generate()
assert(reader_future.valid()); assert(reader_future.valid());
reader = reader_future.get(); reader = reader_future.get();
if ((!reader && if ((!reader &&
reader.getReadMode() == ReaderHolder::ALL) || reader.getReadMode() == ReaderHolder::ALL) ||
(reader.getReadMode() == ReaderHolder::ONLY_VIRTUAL_COLUMNS && (reader.getReadMode() == ReaderHolder::ONLY_VIRTUAL_COLUMNS &&
reader.isFinishedForOnlyVirtualColumns())) reader.isFinishedForOnlyVirtualColumns()))