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

[debug string](pipeline) Add necessary debug info (#29119)

Browse Source
This commit is contained in:
Gabriel
2023-12-27 15:57:22 +08:00
committed by GitHub
parent 2d2f14bc75
commit cd1e109cc3
3 changed files with 9 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
be/src/pipeline/pipeline_fragment_context.cpp
View File

@ -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

2
be/src/pipeline/pipeline_fragment_context.h
View File

@ -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; }

1
be/src/pipeline/pipeline_x/pipeline_x_fragment_context.cpp
View File

@ -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++) {