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 <[email protected]>
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: [email protected]
For additional commands, e-mail: [email protected]
