thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-11-22 07:31:57 +00:00
Code Issues Packages Projects Releases Wiki Activity

Correct stop condition

Browse Source
This commit is contained in:
FawnD2 2020-05-03 22:59:19 +03:00
parent 6b2e97fd56
commit 2359ba3497
1 changed files with 4 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/Processors/Formats/Impl/ArrowBlockInputFormat.cpp
View File

@ -41,6 +41,10 @@ Chunk ArrowBlockInputFormat::generate()
throw Exception{"Error while reading batch of Arrow data: " + read_status.ToString(),
ErrorCodes::CANNOT_READ_ALL_DATA};
// nullptr means `no data left in stream`
if (!single_batch[0])
return res;
std::shared_ptr<arrow::Table> table;
arrow::Status make_status = arrow::Table::FromRecordBatches(single_batch, &table);
if (!make_status.ok())