This is an automated email from the ASF dual-hosted git repository.
dataroaring 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 e5a88ca80b4 [log](insertadd log in parse insert into values data
(#29903)
e5a88ca80b4 is described below
commit e5a88ca80b495ea70a434c2806b81d4f2b4835a9
Author: HHoflittlefish777 <77738092+hhoflittlefish...@users.noreply.github.com>
AuthorDate: Sat Jan 13 09:26:50 2024 +0800
[log](insertadd log in parse insert into values data (#29903)
---
be/src/pipeline/exec/union_source_operator.cpp | 6 ++++++
be/src/vec/exec/vunion_node.cpp | 6 ++++++
regression-test/pipeline/p0/conf/be.conf | 2 +-
3 files changed, 13 insertions(+), 1 deletion(-)
diff --git a/be/src/pipeline/exec/union_source_operator.cpp
b/be/src/pipeline/exec/union_source_operator.cpp
index e8ef1ba7207..31806d7242c 100644
--- a/be/src/pipeline/exec/union_source_operator.cpp
+++ b/be/src/pipeline/exec/union_source_operator.cpp
@@ -223,6 +223,9 @@ Status UnionSourceOperatorX::get_next_const(RuntimeState*
state, vectorized::Blo
&result_list[i]));
}
tmp_block.erase_not_in(result_list);
+ VLOG_ROW << "query id: " << print_id(state->query_id())
+ << ", instance id: " <<
print_id(state->fragment_instance_id())
+ << ", tmp_block rows: " << tmp_block.rows();
if (tmp_block.rows() > 0) {
RETURN_IF_ERROR(mblock.merge(tmp_block));
tmp_block.clear();
@@ -232,6 +235,9 @@ Status UnionSourceOperatorX::get_next_const(RuntimeState*
state, vectorized::Blo
// 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
+ VLOG_ROW << "query id: " << print_id(state->query_id())
+ << ", instance id: " << print_id(state->fragment_instance_id())
+ << ", tmp_block rows: " << block->rows();
if (block->rows() == 0) {
block->insert({vectorized::ColumnUInt8::create(1),
std::make_shared<vectorized::DataTypeUInt8>(), ""});
diff --git a/be/src/vec/exec/vunion_node.cpp b/be/src/vec/exec/vunion_node.cpp
index 8ee258ca056..77f9c0a40f2 100644
--- a/be/src/vec/exec/vunion_node.cpp
+++ b/be/src/vec/exec/vunion_node.cpp
@@ -229,12 +229,18 @@ Status VUnionNode::get_next_const(RuntimeState* state,
Block* block) {
&result_list[i]));
}
tmp_block.erase_not_in(result_list);
+ VLOG_ROW << "query id: " << print_id(state->query_id())
+ << ", instance id: " <<
print_id(state->fragment_instance_id())
+ << ", tmp_block rows: " << tmp_block.rows();
if (tmp_block.rows() > 0) {
RETURN_IF_ERROR(mblock.merge(tmp_block));
tmp_block.clear();
}
}
block->set_columns(std::move(mblock.mutable_columns()));
+ VLOG_ROW << "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
diff --git a/regression-test/pipeline/p0/conf/be.conf
b/regression-test/pipeline/p0/conf/be.conf
index 0aca39d4f13..59060adb285 100644
--- a/regression-test/pipeline/p0/conf/be.conf
+++ b/regression-test/pipeline/p0/conf/be.conf
@@ -59,7 +59,7 @@ chunk_reserved_bytes_limit = 134217728
# sys_log_dir = ${DORIS_HOME}/log
# sys_log_roll_mode = SIZE-MB-1024
# sys_log_roll_num = 10
-# sys_log_verbose_modules = *
+sys_log_verbose_modules = fragment_mgr,vunion_node,union_source_operator
log_buffer_level = -1
enable_stream_load_record = true
# palo_cgroups
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
