This is an automated email from the ASF dual-hosted git repository.
hongze 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 2a4645a56 [GLUTEN-7148][CORE] Remove meaningless plan change log on
TransformPreOverrides rule (#7150)
2a4645a56 is described below
commit 2a4645a56d56f18255b01715c4de76d4bf992bb0
Author: Wechar Yu <[email protected]>
AuthorDate: Mon Sep 9 09:52:40 2024 +0800
[GLUTEN-7148][CORE] Remove meaningless plan change log on
TransformPreOverrides rule (#7150)
Closes #7148
---
.../org/apache/gluten/extension/columnar/MiscColumnarRules.scala | 4 +---
1 file changed, 1 insertion(+), 3 deletions(-)
diff --git
a/gluten-substrait/src/main/scala/org/apache/gluten/extension/columnar/MiscColumnarRules.scala
b/gluten-substrait/src/main/scala/org/apache/gluten/extension/columnar/MiscColumnarRules.scala
index 4e668d7f8..3bfa611ed 100644
---
a/gluten-substrait/src/main/scala/org/apache/gluten/extension/columnar/MiscColumnarRules.scala
+++
b/gluten-substrait/src/main/scala/org/apache/gluten/extension/columnar/MiscColumnarRules.scala
@@ -23,7 +23,7 @@ import org.apache.spark.sql.SparkSession
import org.apache.spark.sql.catalyst.expressions.Expression
import org.apache.spark.sql.catalyst.optimizer.{BuildLeft, BuildRight,
BuildSide}
import org.apache.spark.sql.catalyst.plans.{JoinType, LeftSemi}
-import org.apache.spark.sql.catalyst.rules.{PlanChangeLogger, Rule}
+import org.apache.spark.sql.catalyst.rules.Rule
import org.apache.spark.sql.execution._
import org.apache.spark.sql.execution.adaptive.{AdaptiveSparkPlanExec,
BroadcastQueryStageExec}
import org.apache.spark.sql.execution.exchange.{BroadcastExchangeExec,
BroadcastExchangeLike, ShuffleExchangeLike}
@@ -51,14 +51,12 @@ object MiscColumnarRules {
bottomUpRules: Seq[OffloadSingleNode])
extends Rule[SparkPlan]
with LogLevelUtil {
- @transient private val planChangeLogger = new PlanChangeLogger[SparkPlan]()
def apply(plan: SparkPlan): SparkPlan = {
val plan0 =
topDownRules.foldLeft(plan)((p, rule) => p.transformDown { case p =>
rule.offload(p) })
val plan1 =
bottomUpRules.foldLeft(plan0)((p, rule) => p.transformUp { case p =>
rule.offload(p) })
- planChangeLogger.logRule(ruleName, plan, plan1)
plan1
}
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
