database/doris
2
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

Revert "[temporary](log) Add temporary log for debug insert into lost result (#30140)" (#30382)

Browse Source 
This reverts commit f137d4ea4c2bb7037cad23d033df72d5765b74a7.
This commit is contained in:
HappenLee
2024-01-25 21:38:46 +08:00
committed by yiguolei
parent 75ba0aa90a
commit 6734fb10f9
2 changed files with 2 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
be/src/vec/exec/vunion_node.cpp
View File

@ -227,9 +227,7 @@ 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

4
be/src/vec/sink/writer/vtablet_writer.cpp
View File

@ -1616,9 +1616,7 @@ 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());