This is an automated email from the ASF dual-hosted git repository.
yiguolei pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/master by this push:
new 7e7cfd17bf [fix](tablet sink) check data valid of tablet sink data
(#23530)
7e7cfd17bf is described below
commit 7e7cfd17bffc934b3a091ed5c07ecc5f32583b89
Author: TengJianPing <18241664+jackte...@users.noreply.github.com>
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
<98214048+dataroar...@users.noreply.github.com>
---
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 300a7a40e9..66adca7948 100644
--- a/be/src/runtime/tablets_channel.cpp
+++ b/be/src/runtime/tablets_channel.cpp
@@ -439,6 +439,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 0b6a2e7a32..1fbfbb5470 100644
--- a/be/src/vec/sink/vtablet_sink.cpp
+++ b/be/src/vec/sink/vtablet_sink.cpp
@@ -757,6 +757,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: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
