From d2c293ae2b0598ff7bf7f2a8b881d73f1e3d87c4 Mon Sep 17 00:00:00 2001 From: lamb Date: Thu, 28 Dec 2023 05:24:44 +0800 Subject: [PATCH] save --- 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