This is an automated email from the ASF dual-hosted git repository.
chengchengjin 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 a3ef3bc215 [VL] Minor: Print Velox plan before execution (#9498)
a3ef3bc215 is described below
commit a3ef3bc215ae88ca6cb52f8a66bb4027aab6d993
Author: Jin Chengcheng <[email protected]>
AuthorDate: Fri May 9 14:50:29 2025 +0100
[VL] Minor: Print Velox plan before execution (#9498)
---
cpp/velox/compute/VeloxPlanConverter.cc | 4 +---
cpp/velox/compute/VeloxRuntime.cc | 3 +++
2 files changed, 4 insertions(+), 3 deletions(-)
diff --git a/cpp/velox/compute/VeloxPlanConverter.cc
b/cpp/velox/compute/VeloxPlanConverter.cc
index ed2545c781..8f97aa5fb9 100644
--- a/cpp/velox/compute/VeloxPlanConverter.cc
+++ b/cpp/velox/compute/VeloxPlanConverter.cc
@@ -124,9 +124,7 @@ std::shared_ptr<const facebook::velox::core::PlanNode>
VeloxPlanConverter::toVel
parseLocalFileNodes(&substraitVeloxPlanConverter_, localFiles);
}
- auto veloxPlan = substraitVeloxPlanConverter_.toVeloxPlan(substraitPlan);
- DLOG(INFO) << "Plan Node: " << std::endl << veloxPlan->toString(true, true);
- return veloxPlan;
+ return substraitVeloxPlanConverter_.toVeloxPlan(substraitPlan);
}
std::string VeloxPlanConverter::nextPlanNodeId() {
diff --git a/cpp/velox/compute/VeloxRuntime.cc
b/cpp/velox/compute/VeloxRuntime.cc
index b9276311a2..5ab32d5aa9 100644
--- a/cpp/velox/compute/VeloxRuntime.cc
+++ b/cpp/velox/compute/VeloxRuntime.cc
@@ -159,6 +159,9 @@ std::shared_ptr<ResultIterator>
VeloxRuntime::createResultIterator(
VeloxPlanConverter veloxPlanConverter(
inputs, memoryManager()->getLeafMemoryPool().get(), sessionConf,
*localWriteFilesTempPath());
veloxPlan_ = veloxPlanConverter.toVeloxPlan(substraitPlan_,
std::move(localFiles_));
+ LOG_IF(INFO, debugModeEnabled_ && taskInfo_.has_value())
+ << "############### Velox plan for task " << taskInfo_.value() << "
###############" << std::endl
+ << veloxPlan_->toString(true, true);
// Scan node can be required.
std::vector<std::shared_ptr<SplitInfo>> scanInfos;
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
