force check status for get_next_row

2023-12-06 06:42:31 +00:00
parent 1f8a222b14
commit dc76ede33e
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()) {