From df66b1e33be1b932b210de3877d07920eaad4701 Mon Sep 17 00:00:00 2001 From: xy720 <22125576+xy720@users.noreply.github.com> Date: Fri, 29 Dec 2023 13:09:49 +0800 Subject: [PATCH] [chore](branch-1.2) remove unnecessary deserialize in tablet sink (#29191) --- be/src/vec/sink/vtablet_sink.cpp | 4 ---- 1 file changed, 4 deletions(-) diff --git a/be/src/vec/sink/vtablet_sink.cpp b/be/src/vec/sink/vtablet_sink.cpp index 8f55a8ff9fed2d..012cbf0e7cafb9 100644 --- a/be/src/vec/sink/vtablet_sink.cpp +++ b/be/src/vec/sink/vtablet_sink.cpp @@ -300,10 +300,6 @@ void VNodeChannel::try_send_block(RuntimeState* state) { _add_block_closure->clear_in_flight(); return; } - { - vectorized::Block tmp_block(*request.mutable_block()); - CHECK(block.rows() == tmp_block.rows()); - } if (compressed_bytes >= double(config::brpc_max_body_size) * 0.95f) { LOG(WARNING) << "send block too large, this rpc may failed. send size: " << compressed_bytes << ", threshold: " << config::brpc_max_body_size