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; }