From 6734fb10f9a459f2cf14dfa7d5fdfba84d81c0de Mon Sep 17 00:00:00 2001 From: HappenLee Date: Thu, 25 Jan 2024 21:38:46 +0800 Subject: [PATCH] Revert "[temporary](log) Add temporary log for debug insert into lost result (#30140)" (#30382) This reverts commit f137d4ea4c2bb7037cad23d033df72d5765b74a7. --- be/src/vec/exec/vunion_node.cpp | 4 +--- be/src/vec/sink/writer/vtablet_writer.cpp | 4 +--- 2 files changed, 2 insertions(+), 6 deletions(-) diff --git a/be/src/vec/exec/vunion_node.cpp b/be/src/vec/exec/vunion_node.cpp index eac8aa1b16..08b6f8c5bb 100644 --- a/be/src/vec/exec/vunion_node.cpp +++ b/be/src/vec/exec/vunion_node.cpp @@ -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 diff --git a/be/src/vec/sink/writer/vtablet_writer.cpp b/be/src/vec/sink/writer/vtablet_writer.cpp index 8eb1c4d743..b256ec5210 100644 --- a/be/src/vec/sink/writer/vtablet_writer.cpp +++ b/be/src/vec/sink/writer/vtablet_writer.cpp @@ -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());