From aae6bf662aff7f318608b7ce524808b8c3848644 Mon Sep 17 00:00:00 2001 From: lucky-sinx <2549261744@qq.com> Date: Wed, 25 Dec 2024 15:44:58 +0000 Subject: [PATCH] fix for slicecalc partitionid bug --- src/sql/engine/px/exchange/ob_px_transmit_op.cpp | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/src/sql/engine/px/exchange/ob_px_transmit_op.cpp b/src/sql/engine/px/exchange/ob_px_transmit_op.cpp index 23fb4abaf..fb3dfc78a 100644 --- a/src/sql/engine/px/exchange/ob_px_transmit_op.cpp +++ b/src/sql/engine/px/exchange/ob_px_transmit_op.cpp @@ -2435,13 +2435,12 @@ int ObPxTransmitOp::update_tabletid_batch(const ObExpr *expr,ObRepartSliceIdxCal } else if (OB_FAIL(expr->init_vector_for_write(eval_ctx_, VectorFormat::VEC_FIXED, brs_.size_))) { LOG_WARN("init_vector failed", K(ret)); } else { - ObIVector *src_vec = slice_calc.get_calc_part_id_expr()->get_vector(eval_ctx_); ObIVector *dst_vec = expr->get_vector(eval_ctx_); for (int i = 0; i < brs_.size_; i++) { if (brs_.skip_->at(i)) { continue; } - dst_vec->set_int(i, src_vec->get_int(i)); + dst_vec->set_int(i, tablet_ids[i]); } } return ret;