fix

Author: mymeiyi

be/src/olap/tablet_meta.cpp

@@ -1314,19 +1314,30 @@ std::shared_ptr<roaring::Roaring> DeleteBitmap::get_agg(const BitmapKey& bmk) co
     //        of cache entries in some cases?
     if (val == nullptr) { // Renew if needed, put a new Value to cache
         val = new AggCache::Value();
-        {
-            std::shared_lock l(lock);
-            Version start_version = 0;
-            auto it0 = _rowset_cache_version.find(std::get<0>(bmk));
-            if (it0 != _rowset_cache_version.end()) {
-                auto it1 = it0->second.find(std::get<1>(bmk));
-                if (it1 != it0->second.end()) {
-                    start_version = it1->second;// + 1;
-                    LOG(INFO) << "sout: start agg for tablet=" << _tablet_id
-                              << ", rowset=" << std::get<0>(bmk).to_string()
-                              << ", segment=" << std::get<1>(bmk) << ", version=" << start_version;
+        Version start_version = 0;
+        auto it0 = _rowset_cache_version.find(std::get<0>(bmk));
+        if (it0 != _rowset_cache_version.end()) {
+            auto it1 = it0->second.find(std::get<1>(bmk));
+            if (it1 != it0->second.end()) {
+                start_version = it1->second; // + 1;
+                BitmapKey agg_bmk = {std::get<0>(bmk), std::get<1>(bmk), start_version};
+                std::string agg_key_str = agg_cache_key(_tablet_id, agg_bmk); // Cache key container
+                CacheKey agg_key(agg_key_str);
+                Cache::Handle* handle2 = _agg_cache->repr()->lookup(agg_key);
+                if (handle == nullptr) {
+                    start_version = 0;
+                    val = new AggCache::Value();
+                } else {
+                    val = reinterpret_cast<AggCache::Value*>(_agg_cache->repr()->value(handle));
                 }
+                LOG(INFO) << "sout: start agg for tablet=" << _tablet_id
+                          << ", rowset=" << std::get<0>(bmk).to_string()
+                          << ", segment=" << std::get<1>(bmk) << ", version=" << it1->second
+                          << ", final version=" << start_version;
             }
+        }
+        {
+            std::shared_lock l(lock);
             DeleteBitmap::BitmapKey start {std::get<0>(bmk), std::get<1>(bmk), start_version};
             for (auto it = delete_bitmap.lower_bound(start); it != delete_bitmap.end(); ++it) {
                 auto& [k, bm] = *it;