This is an automated email from the ASF dual-hosted git repository.
gabriellee pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/master by this push:
new cd1e109cc3b [debug string](pipeline) Add necessary debug info (#29119)
cd1e109cc3b is described below
commit cd1e109cc3b29cf8214712543d3606aa6476a4f9
Author: Gabriel <[email protected]>
AuthorDate: Wed Dec 27 15:57:22 2023 +0800
[debug string](pipeline) Add necessary debug info (#29119)
---
be/src/pipeline/pipeline_fragment_context.cpp | 7 +++++++
be/src/pipeline/pipeline_fragment_context.h | 2 +-
be/src/pipeline/pipeline_x/pipeline_x_fragment_context.cpp | 1 +
3 files changed, 9 insertions(+), 1 deletion(-)
diff --git a/be/src/pipeline/pipeline_fragment_context.cpp
b/be/src/pipeline/pipeline_fragment_context.cpp
index 79579833663..034fbaf2951 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 99aac70b1e5..5009bde9b20 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 86440051a90..b628e998f89 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++) {
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
