fix override ret code

2024-09-19 07:57:59 +00:00
parent 84fdb89acf
commit 1bed7050ba
1 changed files with 3 additions and 1 deletions
--- a/src/storage/column_store/ob_cg_aggregated_scanner.cpp
+++ b/src/storage/column_store/ob_cg_aggregated_scanner.cpp
@ -140,7 +140,9 @@ int ObCGAggregatedScanner::get_next_rows(uint64_t &count, const uint64_t capacit
  }
  if (OB_UNLIKELY(OB_ITER_END != ret)) {
    LOG_WARN("Unexpected, ret should be OB_ITER_END", K(ret));
+    if (OB_SUCCESS == ret) {
      ret = OB_ERR_UNEXPECTED;
+    }
  } else {
    count = cur_processed_row_count_;
    cur_processed_row_count_ = 0;