This is an automated email from the ASF dual-hosted git repository. kxiao pushed a commit to branch branch-2.0 in repository https://gitbox.apache.org/repos/asf/doris.git
commit 247e0eb503ac058e2ae37ab64b7f6605171c411c Author: TengJianPing <[email protected]> AuthorDate: Mon Aug 28 15:54:12 2023 +0800 [fix](tablet sink) check data valid of tablet sink data (#23530) Co-authored-by: Yongqiang YANG <[email protected]> --- be/src/runtime/tablets_channel.cpp | 3 +++ be/src/vec/sink/vtablet_sink.cpp | 2 ++ 2 files changed, 5 insertions(+) diff --git a/be/src/runtime/tablets_channel.cpp b/be/src/runtime/tablets_channel.cpp index fb35c57a9a..dd1822e557 100644 --- a/be/src/runtime/tablets_channel.cpp +++ b/be/src/runtime/tablets_channel.cpp @@ -468,6 +468,9 @@ Status TabletsChannel::add_batch(const PTabletWriterAddBlockRequest& request, auto get_send_data = [&]() { return vectorized::Block(request.block()); }; auto send_data = get_send_data(); + CHECK(send_data.rows() == request.tablet_ids_size()) + << "block rows: " << send_data.rows() + << ", tablet_ids_size: " << request.tablet_ids_size(); auto write_tablet_data = [&](uint32_t tablet_id, std::function<Status(DeltaWriter * writer)> write_func) { diff --git a/be/src/vec/sink/vtablet_sink.cpp b/be/src/vec/sink/vtablet_sink.cpp index a880d255aa..6e8ceb508b 100644 --- a/be/src/vec/sink/vtablet_sink.cpp +++ b/be/src/vec/sink/vtablet_sink.cpp @@ -679,6 +679,8 @@ void VNodeChannel::try_send_block(RuntimeState* state) { // tablet_ids has already set when add row request.set_packet_seq(_next_packet_seq); auto block = mutable_block->to_block(); + CHECK(block.rows() == request.tablet_ids_size()) + << "block rows: " << block.rows() << ", tablet_ids_size: " << request.tablet_ids_size(); if (block.rows() > 0) { SCOPED_ATOMIC_TIMER(&_serialize_batch_ns); size_t uncompressed_bytes = 0, compressed_bytes = 0; --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
