diff --git a/be/src/runtime/plan_fragment_executor.cpp b/be/src/runtime/plan_fragment_executor.cpp index 9a634096d8ca02..89abf9af3094fd 100644 --- a/be/src/runtime/plan_fragment_executor.cpp +++ b/be/src/runtime/plan_fragment_executor.cpp @@ -537,7 +537,10 @@ void PlanFragmentExecutor::close() { // load_channel_profile()->compute_time_in_profile(); // TODO load channel profile add timer load_channel_profile()->pretty_print(&ss); } - LOG(INFO) << ss.str(); + + LOG(INFO) << "Query : " << print_id(this->_query_id) << " instance " + << print_id(this->runtime_state()->fragment_instance_id()) << '\n' + << ss.str(); } LOG(INFO) << "Close() fragment_instance_id=" << print_id(_runtime_state->fragment_instance_id());