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 f137d4ea4c2 [temporary](log) Add temporary log for debug insert into
lost result (#30140)
f137d4ea4c2 is described below
commit f137d4ea4c2bb7037cad23d033df72d5765b74a7
Author: HappenLee <[email protected]>
AuthorDate: Mon Jan 22 13:24:02 2024 +0800
[temporary](log) Add temporary log for debug insert into lost result
(#30140)
---
be/src/vec/exec/vunion_node.cpp | 4 +++-
be/src/vec/sink/writer/vtablet_writer.cpp | 4 +++-
2 files changed, 6 insertions(+), 2 deletions(-)
diff --git a/be/src/vec/exec/vunion_node.cpp b/be/src/vec/exec/vunion_node.cpp
index 8ee258ca056..e77fd9fee90 100644
--- a/be/src/vec/exec/vunion_node.cpp
+++ b/be/src/vec/exec/vunion_node.cpp
@@ -235,7 +235,9 @@ Status VUnionNode::get_next_const(RuntimeState* state,
Block* block) {
}
}
block->set_columns(std::move(mblock.mutable_columns()));
-
+ LOG(INFO) << "temporary log query id: " << print_id(state->query_id())
+ << ", instance id: " << print_id(state->fragment_instance_id())
+ << ", block rows: " << block->rows();
// some insert query like "insert into string_test select 1, repeat('a',
1024 * 1024);"
// the const expr will be in output expr cause the union node return a
empty block. so here we
// need add one row to make sure the union node exec const expr return at
least one row
diff --git a/be/src/vec/sink/writer/vtablet_writer.cpp
b/be/src/vec/sink/writer/vtablet_writer.cpp
index 7af7b115c43..0ca2f7d8ffb 100644
--- a/be/src/vec/sink/writer/vtablet_writer.cpp
+++ b/be/src/vec/sink/writer/vtablet_writer.cpp
@@ -1603,7 +1603,9 @@ Status VTabletWriter::write(doris::vectorized::Block&
input_block) {
if (_state->query_options().dry_run_query) {
return status;
}
-
+ LOG(INFO) << "temporary log query id: " << print_id(_state->query_id())
+ << ", instance id: " << print_id(_state->fragment_instance_id())
+ << ", block rows: " << input_block.rows();
// check out of limit
RETURN_IF_ERROR(_send_new_partition_batch());
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
