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

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


The following commit(s) were added to refs/heads/compaction_opt by this push:
     new 0b97d7ec95 [bugfix](checksum) checksum task add delete_predict handler 
(#14481)
0b97d7ec95 is described below

commit 0b97d7ec958b28704eb24e03cc3c60c56d208cfc
Author: yixiutt <102007456+yixi...@users.noreply.github.com>
AuthorDate: Tue Nov 22 14:26:43 2022 +0800

    [bugfix](checksum) checksum task add delete_predict handler (#14481)
---
 be/src/olap/task/engine_checksum_task.cpp | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git a/be/src/olap/task/engine_checksum_task.cpp 
b/be/src/olap/task/engine_checksum_task.cpp
index 1c612aeec5..8bb6eb1f9e 100644
--- a/be/src/olap/task/engine_checksum_task.cpp
+++ b/be/src/olap/task/engine_checksum_task.cpp
@@ -56,7 +56,10 @@ Status EngineChecksumTask::_compute_checksum() {
     reader_params.tablet_schema = tablet->tablet_schema();
     reader_params.reader_type = READER_CHECKSUM;
     reader_params.version = Version(0, _version);
-
+    auto& delete_preds = tablet->delete_predicates();
+    std::copy(delete_preds.cbegin(), delete_preds.cend(),
+              std::inserter(reader_params.delete_predicates,
+                            reader_params.delete_predicates.begin()));
     {
         std::shared_lock rdlock(tablet->get_header_lock());
         const RowsetSharedPtr message = tablet->rowset_with_max_version();


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

Reply via email to