hcq/oceanbase
1
0
Fork 0
Code Issues Pull Requests Actions 1 Packages Projects Releases Wiki Activity

[CP] [CP] fix px drain on non-vec engine

Browse Source
This commit is contained in:
obdev
2023-04-28 01:11:30 +00:00
committed by ob-robot
parent e8270d33f4
commit d48cc591bd
1 changed files with 4 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
src/sql/engine/px/exchange/ob_px_transmit_op.cpp
View File

@ -590,6 +590,10 @@ int ObPxTransmitOp::send_rows_one_by_one(ObSliceIdxCalc &slice_calc)
get_spec().output_, eval_ctx_, slice_idx_array))) { get_spec().output_, eval_ctx_, slice_idx_array))) {
LOG_WARN("fail get slice idx", K(ret)); LOG_WARN("fail get slice idx", K(ret));
} else if (dfc_.all_ch_drained()) { } else if (dfc_.all_ch_drained()) {
int tmp_ret = drain_exch();
if (OB_SUCCESS != tmp_ret) {
LOG_WARN("drain exchange data failed", K(tmp_ret));
}
ret = OB_ITER_END; ret = OB_ITER_END;
LOG_DEBUG("all channel has been drained"); LOG_DEBUG("all channel has been drained");
} else if (NULL != spec.tablet_id_expr_ } else if (NULL != spec.tablet_id_expr_