This is an automated email from the ASF dual-hosted git repository.
liuneng pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/incubator-gluten.git
The following commit(s) were added to refs/heads/main by this push:
new d3bbf3ca2 [GLUTEN-7202][CH] Fix: local executor cannot dump pipeline
stats #7204
d3bbf3ca2 is described below
commit d3bbf3ca23b4eace9c220ade6a410b9594d858d4
Author: lgbo <[email protected]>
AuthorDate: Thu Sep 12 13:43:23 2024 +0800
[GLUTEN-7202][CH] Fix: local executor cannot dump pipeline stats #7204
What changes were proposed in this pull request?
(Please fill in changes proposed in this fix)
Fixes: #7202
How was this patch tested?
(Please explain how this patch was tested. E.g. unit tests, integration
tests, manual tests)
unit tests
(If this patch involves UI changes, please attach a screenshot; otherwise,
remove this)
---
cpp-ch/local-engine/Parser/LocalExecutor.cpp | 11 ++++++++++-
1 file changed, 10 insertions(+), 1 deletion(-)
diff --git a/cpp-ch/local-engine/Parser/LocalExecutor.cpp
b/cpp-ch/local-engine/Parser/LocalExecutor.cpp
index 68ed2f2f2..1ae60e38e 100644
--- a/cpp-ch/local-engine/Parser/LocalExecutor.cpp
+++ b/cpp-ch/local-engine/Parser/LocalExecutor.cpp
@@ -146,7 +146,16 @@ LocalExecutor::LocalExecutor(QueryPlanPtr query_plan,
QueryPipelineBuilderPtr pi
thread_local LocalExecutor * LocalExecutor::current_executor = nullptr;
std::string LocalExecutor::dumpPipeline() const
{
- const auto & processors = query_pipeline.getProcessors();
+ const DB::Processors * processors_ref = nullptr;
+ if (push_executor)
+ {
+ processors_ref = &(push_executor->getProcessors());
+ }
+ else
+ {
+ processors_ref = &(query_pipeline.getProcessors());
+ }
+ const auto & processors = *processors_ref;
for (auto & processor : processors)
{
WriteBufferFromOwnString buffer;
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
