This is an automated email from the ASF dual-hosted git repository.
yuanzhou pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/gluten.git
The following commit(s) were added to refs/heads/main by this push:
new cda0405aa2 [VL] Refine logs in BHJ optimization (#11870)
cda0405aa2 is described below
commit cda0405aa2ccc80cfe67c6395c3473e252cf33cf
Author: JiaKe <[email protected]>
AuthorDate: Thu Apr 2 17:25:24 2026 +0100
[VL] Refine logs in BHJ optimization (#11870)
Clean up redundant logging.
fixes: #11863
---
.../scala/org/apache/gluten/execution/HashJoinExecTransformer.scala | 3 ---
.../org/apache/gluten/execution/VeloxBroadcastBuildSideCache.scala | 2 --
.../src/main/scala/org/apache/spark/rpc/GlutenDriverEndpoint.scala | 2 --
3 files changed, 7 deletions(-)
diff --git
a/backends-velox/src/main/scala/org/apache/gluten/execution/HashJoinExecTransformer.scala
b/backends-velox/src/main/scala/org/apache/gluten/execution/HashJoinExecTransformer.scala
index d79a3cae04..fb57848e54 100644
---
a/backends-velox/src/main/scala/org/apache/gluten/execution/HashJoinExecTransformer.scala
+++
b/backends-velox/src/main/scala/org/apache/gluten/execution/HashJoinExecTransformer.scala
@@ -133,9 +133,6 @@ case class BroadcastHashJoinExecTransformer(
val streamedRDD = getColumnarInputRDDs(streamedPlan)
val executionId =
sparkContext.getLocalProperty(SQLExecution.EXECUTION_ID_KEY)
if (executionId != null) {
- logWarning(
- s"Trace broadcast table data $buildBroadcastTableId" + " " +
- "and the execution id is " + executionId)
GlutenDriverEndpoint.collectResources(executionId, buildBroadcastTableId)
} else {
logWarning(
diff --git
a/backends-velox/src/main/scala/org/apache/gluten/execution/VeloxBroadcastBuildSideCache.scala
b/backends-velox/src/main/scala/org/apache/gluten/execution/VeloxBroadcastBuildSideCache.scala
index 2705f3b34c..eadcb0f349 100644
---
a/backends-velox/src/main/scala/org/apache/gluten/execution/VeloxBroadcastBuildSideCache.scala
+++
b/backends-velox/src/main/scala/org/apache/gluten/execution/VeloxBroadcastBuildSideCache.scala
@@ -70,7 +70,6 @@ object VeloxBroadcastBuildSideCache
unsafe.buildHashTable(broadcastContext)
}
- logWarning(s"Create bhj $broadcast_id = $pointer")
BroadcastHashTable(pointer, relation)
}
)
@@ -96,7 +95,6 @@ object VeloxBroadcastBuildSideCache
override def onRemoval(key: String, value: BroadcastHashTable, cause:
RemovalCause): Unit = {
synchronized {
- logWarning(s"Remove bhj $key = ${value.pointer}")
if (value.relation != null) {
value.relation match {
case columnar: ColumnarBuildSideRelation =>
diff --git
a/backends-velox/src/main/scala/org/apache/spark/rpc/GlutenDriverEndpoint.scala
b/backends-velox/src/main/scala/org/apache/spark/rpc/GlutenDriverEndpoint.scala
index af635addf3..be0701ea59 100644
---
a/backends-velox/src/main/scala/org/apache/spark/rpc/GlutenDriverEndpoint.scala
+++
b/backends-velox/src/main/scala/org/apache/spark/rpc/GlutenDriverEndpoint.scala
@@ -49,8 +49,6 @@ class GlutenDriverEndpoint extends IsolatedRpcEndpoint with
Logging {
}
case GlutenOnExecutionEnd(executionId) =>
- logWarning(s"Execution Id is $executionId end.")
-
GlutenDriverEndpoint.executionResourceRelation.invalidate(executionId)
case GlutenExecutorRemoved(executorId) =>
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
