[doris] branch master updated: [Fix](point query) Fix point query unstable (#24570)

[zhangchen]

This is an automated email from the ASF dual-hosted git repository.

zhangchen pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git


The following commit(s) were added to refs/heads/master by this push:
     new 67e789e025 [Fix](point query) Fix point query unstable (#24570)
67e789e025 is described below

commit 67e789e02591e8cdc98ee543c935a9622a7c5ea9
Author: abmdocrt <yukang.lian2...@gmail.com>
AuthorDate: Wed Sep 20 18:07:07 2023 +0800

    [Fix](point query) Fix point query unstable (#24570)
---
 be/src/olap/compaction.cpp | 9 +++++++++
 be/src/olap/compaction.h   | 1 +
 2 files changed, 10 insertions(+)

diff --git a/be/src/olap/compaction.cpp b/be/src/olap/compaction.cpp
index fdcf5a76c5..f62fda89a0 100644
--- a/be/src/olap/compaction.cpp
+++ b/be/src/olap/compaction.cpp
@@ -134,6 +134,7 @@ Status Compaction::do_compaction(int64_t permits) {
                          << ", before=" << checksum_before << ", 
checksum_after=" << checksum_after;
         }
     }
+    _load_segment_to_cache();
     return st;
 }
 
@@ -825,6 +826,14 @@ int64_t Compaction::get_compaction_permits() {
     return permits;
 }
 
+Status Compaction::_load_segment_to_cache() {
+    // Load new rowset's segments to cache.
+    SegmentCacheHandle handle;
+    RETURN_IF_ERROR(SegmentLoader::instance()->load_segments(
+            std::static_pointer_cast<BetaRowset>(_output_rowset), &handle, 
true));
+    return Status::OK();
+}
+
 #ifdef BE_TEST
 void Compaction::set_input_rowset(const std::vector<RowsetSharedPtr>& rowsets) 
{
     _input_rowsets = rowsets;
diff --git a/be/src/olap/compaction.h b/be/src/olap/compaction.h
index 859615c036..afb4f27e7f 100644
--- a/be/src/olap/compaction.h
+++ b/be/src/olap/compaction.h
@@ -99,6 +99,7 @@ protected:
 
 private:
     bool _check_if_includes_input_rowsets(const RowsetIdUnorderedSet& 
commit_rowset_ids_set) const;
+    Status _load_segment_to_cache();
 
 protected:
     // the root tracker for this compaction


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