Skip to content

Commit

Permalink
[chore](branch-1.2) remove unnecessary deserialize in tablet sink (#2…
Browse files Browse the repository at this point in the history
  • Loading branch information
xy720 authored Dec 29, 2023
1 parent a996eea commit df66b1e
Showing 1 changed file with 0 additions and 4 deletions.
4 changes: 0 additions & 4 deletions be/src/vec/sink/vtablet_sink.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand Down

0 comments on commit df66b1e

Please sign in to comment.