database/doris
2
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

[fix](mow) fix flush_single_block core in calc_segment_delete_bitmap (#21619)

Browse Source
This commit is contained in:
Kaijie Chen
2023-07-11 15:56:57 +08:00
committed by GitHub
parent d3317aa33b
commit da86d2ff65
1 changed files with 6 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
be/src/olap/rowset/beta_rowset_writer.cpp
View File

@ -525,6 +525,10 @@ Status BetaRowsetWriter::unfold_variant_column_and_flush_block(
const std::shared_ptr<MemTracker>& flush_mem_tracker, int64_t* flush_size) {
SCOPED_CONSUME_MEM_TRACKER(flush_mem_tracker);
if (block->rows() == 0) {
return Status::OK();
}
FlushContext ctx;
ctx.block = block;
if (_context.tablet_schema->is_dynamic_schema()) {
@ -534,6 +538,8 @@ Status BetaRowsetWriter::unfold_variant_column_and_flush_block(
ctx.segment_id = std::optional<int32_t> {segment_id};
SCOPED_RAW_TIMER(&_segment_writer_ns);
RETURN_IF_ERROR(flush_single_block(block, flush_size, &ctx));
RETURN_IF_ERROR(_generate_delete_bitmap(segment_id));
RETURN_IF_ERROR(_segcompaction_if_necessary());
return Status::OK();
}
@ -555,8 +561,6 @@ Status BetaRowsetWriter::flush_single_block(const vectorized::Block* block, int6
DCHECK_EQ(writer.get(), raw_writer);
}
RETURN_IF_ERROR(_flush_segment_writer(&writer, flush_size));
RETURN_IF_ERROR(_generate_delete_bitmap(segment_id));
RETURN_IF_ERROR(_segcompaction_if_necessary());
return Status::OK();
}