[fix](load) fix ctx nullptr core in flush_single_memtable (#20573)
This commit is contained in:
@ -494,7 +494,9 @@ Status BetaRowsetWriter::flush_single_memtable(const vectorized::Block* block, i
|
||||
int32_t segment_id = writer->get_segment_id();
|
||||
RETURN_IF_ERROR(_add_block(block, &writer));
|
||||
RETURN_IF_ERROR(_flush_segment_writer(&writer, flush_size));
|
||||
RETURN_IF_ERROR(ctx->generate_delete_bitmap(segment_id));
|
||||
if (ctx != nullptr && ctx->generate_delete_bitmap) {
|
||||
RETURN_IF_ERROR(ctx->generate_delete_bitmap(segment_id));
|
||||
}
|
||||
RETURN_IF_ERROR(_segcompaction_if_necessary());
|
||||
return Status::OK();
|
||||
}
|
||||
|
||||
@ -41,9 +41,7 @@ struct FlushContext {
|
||||
TabletSchemaSPtr flush_schema = nullptr;
|
||||
const vectorized::Block* block = nullptr;
|
||||
std::optional<int32_t> segment_id = std::nullopt;
|
||||
std::function<Status(int32_t)> generate_delete_bitmap = [](int32_t segment_id) {
|
||||
return Status::OK();
|
||||
};
|
||||
std::function<Status(int32_t)> generate_delete_bitmap;
|
||||
};
|
||||
|
||||
class RowsetWriter {
|
||||
|
||||
Reference in New Issue
Block a user