[temporary](log) Add temporary log for debug insert into lost result (#…

…30140)
apache · Jan 22, 2024 · f137d4e · f137d4e
1 parent 25da056
commit f137d4e
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 2 deletions.
diff --git 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
@@ -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());