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 integration test test_storage_kafka failed error

Browse Source
This commit is contained in:
Chao Ma 2021-04-18 09:51:53 +08:00 committed by mergify-bot
parent 8d7a53efda
commit 6238028225
1 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/Processors/Formats/Impl/ORCBlockInputFormat.cpp
View File

@ -28,7 +28,6 @@ namespace ErrorCodes
ORCBlockInputFormat::ORCBlockInputFormat(ReadBuffer & in_, Block header_) : IInputFormat(std::move(header_), in_)
{
prepareReader();
}
Chunk ORCBlockInputFormat::generate()
@ -36,6 +35,9 @@ Chunk ORCBlockInputFormat::generate()
Chunk res;
const Block & header = getPort().getHeader();
if (!file_reader)
prepareReader();
if (stripe_current >= stripe_total)
return res;
@ -62,7 +64,7 @@ void ORCBlockInputFormat::resetParser()
file_reader.reset();
include_indices.clear();
prepareReader();
stripe_current = 0;
}
void ORCBlockInputFormat::prepareReader()