diff --git a/src/sql/engine/table/ob_table_scan_op.cpp b/src/sql/engine/table/ob_table_scan_op.cpp index bb63ba7e87..d6ccce76cf 100644 --- a/src/sql/engine/table/ob_table_scan_op.cpp +++ b/src/sql/engine/table/ob_table_scan_op.cpp @@ -1418,10 +1418,10 @@ int ObTableScanOp::fill_storage_feedback_info() int ObTableScanOp::inner_rescan() { int ret = OB_SUCCESS; - if (OB_SUCC(ret) && MY_SPEC.is_global_index_back()) { - if (OB_FAIL(ObOperator::inner_rescan())) { - LOG_WARN("failed to exec inner rescan",K(ret)); - } else if (OB_ISNULL(global_index_lookup_op_)) { + if (OB_FAIL(ObOperator::inner_rescan())) { + LOG_WARN("failed to exec inner rescan"); + } else if (MY_SPEC.is_global_index_back()) { + if (OB_ISNULL(global_index_lookup_op_)) { ret = OB_INVALID_ARGUMENT; LOG_WARN("invalid arguments",K(ret)); } else { @@ -1447,9 +1447,7 @@ int ObTableScanOp::inner_rescan_for_tsc() MY_INPUT.key_ranges_.reuse(); MY_INPUT.ss_key_ranges_.reuse(); MY_INPUT.mbr_filters_.reuse(); - if (OB_FAIL(ObOperator::inner_rescan())) { - LOG_WARN("rescan operator failed", K(ret)); - } else if (OB_FAIL(build_bnlj_params())) { + if (OB_FAIL(build_bnlj_params())) { // At start of each round of batch rescan, NLJ will fill param_store with // batch parameters. After each right operator rescan, NLJ will fill // param_store with current rescan's parameters.