You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@gluten.apache.org by ch...@apache.org on 2025/05/09 13:50:34 UTC
(incubator-gluten) branch main updated: [VL] Minor: Print Velox plan before execution (#9498)
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 <ch...@intel.com>
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: commits-unsubscribe@gluten.apache.org
For additional commands, e-mail: commits-help@gluten.apache.org