[Fix](inverted index) fix memory leak when inverted index writer not …

…close (#33724) (#34374) Co-authored-by: airborne12 <[email protected]>
apache · May 1, 2024 · d0e89c0 · d0e89c0
1 parent 74ed6e8
commit d0e89c0
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/be/src/olap/rowset/segment_v2/inverted_index_writer.cpp b/be/src/olap/rowset/segment_v2/inverted_index_writer.cpp
@@ -84,7 +84,11 @@ class InvertedIndexColumnWriterImpl : public InvertedIndexColumnWriter {
         _field_name = std::wstring(field_name.begin(), field_name.end());
     }
 
-    ~InvertedIndexColumnWriterImpl() override = default;
+    ~InvertedIndexColumnWriterImpl() override {
+        if (_index_writer != nullptr) {
+            close_on_error();
+        }
+    }
 
     Status init() override {
         try {
@@ -105,6 +109,7 @@ class InvertedIndexColumnWriterImpl : public InvertedIndexColumnWriter {
     void close() {
         if (_index_writer) {
             _index_writer->close();
+            _index_writer.reset();
             if (config::enable_write_index_searcher_cache) {
                 // open index searcher into cache
                 auto index_file_name = InvertedIndexDescriptor::get_index_file_name(