diff --git a/be/src/olap/rowset/beta_rowset_writer.h b/be/src/olap/rowset/beta_rowset_writer.h index 92ffe1bb0922414..cfdc212359a4667 100644 --- a/be/src/olap/rowset/beta_rowset_writer.h +++ b/be/src/olap/rowset/beta_rowset_writer.h @@ -273,6 +273,8 @@ class BetaRowsetWriter : public BaseBetaRowsetWriter { Status build(RowsetSharedPtr& rowset) override; + Status init(const RowsetWriterContext& rowset_writer_context) override; + Status add_segment(uint32_t segment_id, const SegmentStatistics& segstat, TabletSchemaSPtr flush_schema) override; diff --git a/be/src/olap/rowset/segcompaction.h b/be/src/olap/rowset/segcompaction.h index 370f0cd42647c38..09ea56387ada35e 100644 --- a/be/src/olap/rowset/segcompaction.h +++ b/be/src/olap/rowset/segcompaction.h @@ -98,6 +98,7 @@ class SegcompactionWorker { // for unique key mow table std::unique_ptr _rowid_conversion; DeleteBitmapPtr _converted_delete_bitmap; + std::shared_ptr _seg_compact_mem_tracker = nullptr; // the state is not mutable when 1)actual compaction operation started or 2) cancelled std::atomic _is_compacting_state_mutable = true;