Merge branch 'main' into memory_leakage_in_parquet_datasource

apache · Jul 16, 2024 · 5d881f7 · 5d881f7
2 parents c7a2e3b + 90e0087
commit 5d881f7
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 1 deletion.
diff --git a/.../src/main/scala/org/apache/gluten/extension/columnar/enumerated/EnumeratedTransform.scala b/.../src/main/scala/org/apache/gluten/extension/columnar/enumerated/EnumeratedTransform.scala
@@ -63,7 +63,6 @@ case class EnumeratedTransform(session: SparkSession, outputsColumnar: Boolean)
         OffloadOthers())
       .toRule,
     RasOffload.from[CoalesceExec](OffloadOthers()).toRule,
-    RasOffload.from[ProjectExec](OffloadOthers()).toRule,
     RasOffload.from[SortAggregateExec](OffloadOthers()).toRule,
     RasOffload.from[ObjectHashAggregateExec](OffloadOthers()).toRule,
     RasOffload.from[UnionExec](OffloadOthers()).toRule,

diff --git a/...re/src/main/scala/org/apache/gluten/extension/columnar/enumerated/RasOffloadProject.scala b/...re/src/main/scala/org/apache/gluten/extension/columnar/enumerated/RasOffloadProject.scala
@@ -20,6 +20,7 @@ import org.apache.gluten.execution.ProjectExecTransformer
 
 import org.apache.spark.sql.execution.{ProjectExec, SparkPlan}
 
+/** TODO: Map [[org.apache.gluten.extension.columnar.OffloadProject]] to RAS. */
 object RasOffloadProject extends RasOffload {
   override def offload(node: SparkPlan): SparkPlan = node match {
     case ProjectExec(projectList, child) =>