From cd61bf182e5b7d6362e0842a27a6ad576cc8b131 Mon Sep 17 00:00:00 2001 From: DengzhiLiu Date: Tue, 21 Nov 2023 11:44:39 +0000 Subject: [PATCH] Clear evaluate flag in multiple merge --- src/storage/access/ob_multiple_merge.cpp | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/src/storage/access/ob_multiple_merge.cpp b/src/storage/access/ob_multiple_merge.cpp index 4ec8509300..c9667fa31c 100644 --- a/src/storage/access/ob_multiple_merge.cpp +++ b/src/storage/access/ob_multiple_merge.cpp @@ -380,6 +380,9 @@ int ObMultipleMerge::get_next_row(ObDatumRow *&row) int ObMultipleMerge::get_next_rows(int64_t &count, int64_t capacity) { int ret = OB_SUCCESS; + if (OB_NOT_NULL(access_param_->get_op())) { + access_param_->get_op()->clear_evaluated_flag(); + } count = 0; if (access_param_->iter_param_.enable_pd_aggregate()) { ObDatumRow *row = nullptr; @@ -408,6 +411,9 @@ int ObMultipleMerge::get_next_rows(int64_t &count, int64_t capacity) } else { ret = get_next_normal_rows(count, capacity); } + if (OB_NOT_NULL(access_param_->get_op())) { + access_param_->get_op()->clear_evaluated_flag(); + } return ret; }