commit 16661ff0387dc0d6bca047497223de46b20174d6
author Chen Zhang <zhangchen@selectdb.com> Tue Aug 05 20:04:30 2025 +0800
committer Chen Zhang <zhangchen@selectdb.com> Tue Aug 05 20:04:30 2025 +0800
tree d12f873a545d15e03f36e84974382fe8944299c6
parent 13971baa79461f1f918ed3b465436b2d13d6620a

fix core

be/src/cloud/cloud_tablet.cpp

diff --git a/be/src/cloud/cloud_tablet.cpp b/be/src/cloud/cloud_tablet.cpp
index e515c04..cfb3159 100644
--- a/be/src/cloud/cloud_tablet.cpp
+++ b/be/src/cloud/cloud_tablet.cpp
@@ -349,6 +349,8 @@
             g_file_cache_cloud_tablet_submitted_segment_size
                     << rowset->rowset_meta()->segment_file_size(seg_id);
         }
+        auto self = std::dynamic_pointer_cast<CloudTablet>(shared_from_this());
+        // clang-format off
         _engine.file_cache_block_downloader().submit_download_task(io::DownloadFileMeta {
                 .path = storage_resource.value()->remote_segment_path(*rowset_meta, seg_id),
                 .file_size = rowset->rowset_meta()->segment_file_size(seg_id),
@@ -358,8 +360,8 @@
                                 .expiration_time = expiration_time,
                                 .is_dryrun = config::enable_reader_dryrun_when_download_file_cache,
                         },
-                .download_done {[this, rowset, delay_add_rowset](Status st) {
-                    warm_up_done_cb(rowset, st, delay_add_rowset);
+                .download_done {[self, rowset, delay_add_rowset](Status st) {
+                    self->warm_up_done_cb(rowset, st, delay_add_rowset);
                     if (!st) {
                         LOG_WARNING("add rowset warm up error ").error(st);
                     }

be/src/olap/base_tablet.h

diff --git a/be/src/olap/base_tablet.h b/be/src/olap/base_tablet.h
index a46b195..0cc0fa1 100644
--- a/be/src/olap/base_tablet.h
+++ b/be/src/olap/base_tablet.h
@@ -56,7 +56,7 @@
 enum class CompactionStage { NOT_SCHEDULED, PENDING, EXECUTING };
 
 // Base class for all tablet classes
-class BaseTablet {
+class BaseTablet : public std::enable_shared_from_this<BaseTablet> {
 public:
     explicit BaseTablet(TabletMetaSharedPtr tablet_meta);
     virtual ~BaseTablet();