(doris) 07/33: [fix](memory) Fix compaction destructor memory tracking #33549 (#33572)

[yiguolei]

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 441704ad28f4b79c61e82711b084c05892673faa
Author: Xinyi Zou <zouxiny...@gmail.com>
AuthorDate: Fri Apr 12 17:04:04 2024 +0800

    [fix](memory) Fix compaction destructor memory tracking #33549 (#33572)
---
 be/src/olap/compaction.cpp | 10 +++++++++-
 1 file changed, 9 insertions(+), 1 deletion(-)

diff --git a/be/src/olap/compaction.cpp b/be/src/olap/compaction.cpp
index 19b4d03c346..8928d471609 100644
--- a/be/src/olap/compaction.cpp
+++ b/be/src/olap/compaction.cpp
@@ -61,6 +61,7 @@
 #include "olap/txn_manager.h"
 #include "olap/utils.h"
 #include "runtime/memory/mem_tracker_limiter.h"
+#include "runtime/thread_context.h"
 #include "util/time.h"
 #include "util/trace.h"
 
@@ -80,7 +81,14 @@ Compaction::Compaction(const TabletSharedPtr& tablet, const 
std::string& label)
     init_profile(label);
 }
 
-Compaction::~Compaction() {}
+Compaction::~Compaction() {
+    SCOPED_SWITCH_THREAD_MEM_TRACKER_LIMITER(_mem_tracker);
+    _output_rs_writer.reset();
+    _tablet.reset();
+    _input_rowsets.clear();
+    _output_rowset.reset();
+    _cur_tablet_schema.reset();
+}
 
 void Compaction::init_profile(const std::string& label) {
     _profile = std::make_unique<RuntimeProfile>(label);


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org