thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-11-19 14:11:58 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix compilation error

Browse Source
This commit is contained in:
Peng Jian 2021-03-19 20:58:32 +08:00 committed by root
parent 278d2d7df0
commit ec54f2a361
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/Storages/Kafka/KafkaBlockInputStream.cpp
View File

@ -151,17 +151,17 @@ Block KafkaBlockInputStream::readImpl()
{
input_format->resetParser();
exception_message = e.message();
for (size_t i = 0, s = result_columns.size(); i < s; ++i)
for (auto & column : result_columns)
{
// read_kafka_message could already push some rows to result_columns
// before exception, we need to fix it.
auto cur_rows = result_columns[i]->size();
auto cur_rows = column->size();
if (cur_rows > total_rows)
{
result_columns[i]->popBack(cur_rows - total_rows);
column->popBack(cur_rows - total_rows);
}
// all data columns will get default value in case of error
result_columns[i]->insertDefault();
column->insertDefault();
}
new_rows = 1;
}