force check status for get_next_row

2024-02-07 11:33:59 +00:00 · 2024-02-07 11:33:59 +00:00 · 2585b814c8
commit 2585b814c8
parent 080c1da397
1 changed files with 2 additions and 0 deletions
--- a/src/sql/engine/ob_operator.cpp
+++ b/src/sql/engine/ob_operator.cpp
@ -1151,6 +1151,8 @@ int ObOperator::get_next_row()
            LOG_WARN("inner get next row failed", K(ret), "type", spec_.type_, "op", op_name(),
              "op_id", spec_.id_);
          }
+        } else if (OB_FAIL(try_check_status())) {
+          LOG_WARN("check status failed", K(ret));
        } else {
          bool filtered = false;
          if (!spec_.filters_.empty()) {