diff --git a/src/sql/das/ob_das_extra_data.cpp b/src/sql/das/ob_das_extra_data.cpp index 5cce326897..609a5c7f21 100644 --- a/src/sql/das/ob_das_extra_data.cpp +++ b/src/sql/das/ob_das_extra_data.cpp @@ -136,8 +136,7 @@ int ObDASExtraData::get_next_rows(int64_t &count, int64_t capacity) } } else { got_row = true; - LOG_DEBUG("get next batch from result iter", KR(ret), - "output", ROWEXPR2STR(*eval_ctx_, *output_exprs_)); + PRINT_VECTORIZED_ROWS(SQL, DEBUG, *eval_ctx_, *output_exprs_, count, KR(ret)); } } return ret; diff --git a/src/sql/das/ob_das_scan_op.cpp b/src/sql/das/ob_das_scan_op.cpp index 0b23d2bbc8..f4476f1252 100644 --- a/src/sql/das/ob_das_scan_op.cpp +++ b/src/sql/das/ob_das_scan_op.cpp @@ -527,9 +527,9 @@ int ObDASScanOp::fill_task_result(ObIDASTaskResult &task_result, bool &has_more, has_more = true; } if (OB_SUCC(ret) && has_more) { - LOG_DEBUG("try fill task result", K(simulate_row_cnt), - K(datum_store.get_row_cnt()), K(has_more), - "output_row", ROWEXPR2STR(eval_ctx, result_output)); + PRINT_VECTORIZED_ROWS(SQL, DEBUG, eval_ctx, result_output, remain_row_cnt_, + K(simulate_row_cnt), K(datum_store.get_row_cnt()), + K(has_more)); } } } diff --git a/src/sql/engine/table/ob_index_lookup_op_impl.cpp b/src/sql/engine/table/ob_index_lookup_op_impl.cpp index b0b03b9a31..a3755fd485 100644 --- a/src/sql/engine/table/ob_index_lookup_op_impl.cpp +++ b/src/sql/engine/table/ob_index_lookup_op_impl.cpp @@ -157,7 +157,10 @@ int ObIndexLookupOpImpl::get_next_rows(int64_t &count, int64_t capacity) } else { got_next_row = true; update_state_in_output_rows_state(count); - LOG_DEBUG("got next row from table lookup", K(ret), K(lookup_row_cnt_), K(lookup_rowkey_cnt_), K(lookup_group_cnt_), K(index_group_cnt_), "main table output", ROWEXPR2STR(get_eval_ctx(), get_output_expr()) ); } + PRINT_VECTORIZED_ROWS(SQL, DEBUG, get_eval_ctx(), get_output_expr(), count, + K(ret), K(lookup_row_cnt_), K(lookup_rowkey_cnt_), + K(lookup_group_cnt_), K(index_group_cnt_)); + } break; } case FINISHED: {