Add a startup filter for limit

2023-09-20 14:45:59 +00:00
parent a4cf5ecbd2
commit b78a9ca5a0
7 changed files with 72 additions and 3 deletions
--- a/src/sql/optimizer/ob_logical_operator.cpp
+++ b/src/sql/optimizer/ob_logical_operator.cpp
@ -4292,7 +4292,7 @@ int ObLogicalOperator::allocate_startup_expr_post(int64_t child_idx)
      }
    }
    if (OB_SUCC(ret)) {
-      if (OB_FAIL(append_array_no_dup(get_startup_exprs(), new_startup_exprs))) {
+      if (OB_FAIL(ObOptimizerUtil::append_exprs_no_dup(get_startup_exprs(), new_startup_exprs))) {
        LOG_WARN("failed to add startup exprs", K(ret));
      } else {
        //exchange out上面的startup filter保留，用于控制当前dfo提前终止