diff --git a/be/src/pipeline/pipeline_fragment_context.cpp b/be/src/pipeline/pipeline_fragment_context.cpp index 7957983366..034fbaf295 100644 --- a/be/src/pipeline/pipeline_fragment_context.cpp +++ b/be/src/pipeline/pipeline_fragment_context.cpp @@ -963,4 +963,11 @@ bool PipelineFragmentContext::_has_inverted_index_or_partial_update(TOlapTableSi return false; } +std::string PipelineFragmentContext::debug_string() { + fmt::memory_buffer debug_string_buffer; + fmt::format_to(debug_string_buffer, "PipelineFragmentContext Info: QueryId = {}\n", + print_id(_query_ctx->query_id())); + return fmt::to_string(debug_string_buffer); +} + } // namespace doris::pipeline diff --git a/be/src/pipeline/pipeline_fragment_context.h b/be/src/pipeline/pipeline_fragment_context.h index 99aac70b1e..5009bde9b2 100644 --- a/be/src/pipeline/pipeline_fragment_context.h +++ b/be/src/pipeline/pipeline_fragment_context.h @@ -148,7 +148,7 @@ public: } void refresh_next_report_time(); - virtual std::string debug_string() { return ""; } + virtual std::string debug_string(); uint64_t create_time() const { return _create_time; } diff --git a/be/src/pipeline/pipeline_x/pipeline_x_fragment_context.cpp b/be/src/pipeline/pipeline_x/pipeline_x_fragment_context.cpp index 86440051a9..b628e998f8 100644 --- a/be/src/pipeline/pipeline_x/pipeline_x_fragment_context.cpp +++ b/be/src/pipeline/pipeline_x/pipeline_x_fragment_context.cpp @@ -1310,6 +1310,7 @@ bool PipelineXFragmentContext::_has_inverted_index_or_partial_update(TOlapTableS std::string PipelineXFragmentContext::debug_string() { fmt::memory_buffer debug_string_buffer; + fmt::format_to(debug_string_buffer, "PipelineXFragmentContext Info:\n"); for (size_t j = 0; j < _tasks.size(); j++) { fmt::format_to(debug_string_buffer, "Tasks in instance {}:\n", j); for (size_t i = 0; i < _tasks[j].size(); i++) {