[fix][vectorized-storage] did not check column writer's write status
This commit is contained in:
@ -137,8 +137,9 @@ Status SegmentWriter::append_block(const vectorized::Block* block, size_t row_po
|
||||
if (cid < num_key_columns) {
|
||||
short_key_columns.push_back(converted_result.second);
|
||||
}
|
||||
_column_writers[cid]->append(converted_result.second->get_nullmap(),
|
||||
converted_result.second->get_data(), num_rows);
|
||||
RETURN_IF_ERROR(_column_writers[cid]->append(converted_result.second->get_nullmap(),
|
||||
converted_result.second->get_data(),
|
||||
num_rows));
|
||||
}
|
||||
|
||||
// create short key indexes
|
||||
@ -326,4 +327,4 @@ Status SegmentWriter::_write_raw_data(const std::vector<Slice>& slices) {
|
||||
}
|
||||
|
||||
} // namespace segment_v2
|
||||
} // namespace doris
|
||||
} // namespace doris
|
||||
|
||||
Reference in New Issue
Block a user