This is an automated email from the ASF dual-hosted git repository. yiguolei pushed a commit to branch branch-2.1 in repository https://gitbox.apache.org/repos/asf/doris.git
commit 218fb80938e605929060b2d0337ec9b03c90e980 Author: meiyi <[email protected]> AuthorDate: Tue Jan 30 14:03:29 2024 +0800 [fix](group commit) Fix group commit VOlapTablePartitionParam memory … (#30491) --- be/src/vec/sink/group_commit_block_sink.cpp | 2 +- be/src/vec/sink/group_commit_block_sink.h | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/be/src/vec/sink/group_commit_block_sink.cpp b/be/src/vec/sink/group_commit_block_sink.cpp index 75ffa13233e..cc1abaafcf2 100644 --- a/be/src/vec/sink/group_commit_block_sink.cpp +++ b/be/src/vec/sink/group_commit_block_sink.cpp @@ -59,7 +59,7 @@ Status GroupCommitBlockSink::init(const TDataSink& t_sink) { _group_commit_mode = table_sink.group_commit_mode; _load_id = table_sink.load_id; _max_filter_ratio = table_sink.max_filter_ratio; - _vpartition = new doris::VOlapTablePartitionParam(_schema, table_sink.partition); + _vpartition = std::make_unique<doris::VOlapTablePartitionParam>(_schema, table_sink.partition); RETURN_IF_ERROR(_vpartition->init()); return Status::OK(); } diff --git a/be/src/vec/sink/group_commit_block_sink.h b/be/src/vec/sink/group_commit_block_sink.h index 9a57cb594e7..cfe7727e3e6 100644 --- a/be/src/vec/sink/group_commit_block_sink.h +++ b/be/src/vec/sink/group_commit_block_sink.h @@ -73,7 +73,7 @@ private: double _max_filter_ratio = 0.0; // used for find_partition - VOlapTablePartitionParam* _vpartition = nullptr; + std::unique_ptr<VOlapTablePartitionParam> _vpartition = nullptr; // reuse for find_tablet. std::vector<VOlapTablePartition*> _partitions; Bitmap _filter_bitmap; --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
