This is an automated email from the ASF dual-hosted git repository.
mingliang 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 4395ccf80e [MINOR] Override `outputPartitioning` in
`GenerateExecTransformerBase` (#10768)
4395ccf80e is described below
commit 4395ccf80ed61ebb75a7cd693f3beda714b81396
Author: jiangjiangtian <[email protected]>
AuthorDate: Wed Sep 24 09:39:36 2025 +0800
[MINOR] Override `outputPartitioning` in `GenerateExecTransformerBase`
(#10768)
---
.../org/apache/gluten/execution/GenerateExecTransformerBase.scala | 3 +++
1 file changed, 3 insertions(+)
diff --git
a/gluten-substrait/src/main/scala/org/apache/gluten/execution/GenerateExecTransformerBase.scala
b/gluten-substrait/src/main/scala/org/apache/gluten/execution/GenerateExecTransformerBase.scala
index 6fba949627..44c08757e1 100644
---
a/gluten-substrait/src/main/scala/org/apache/gluten/execution/GenerateExecTransformerBase.scala
+++
b/gluten-substrait/src/main/scala/org/apache/gluten/execution/GenerateExecTransformerBase.scala
@@ -26,6 +26,7 @@ import
org.apache.gluten.substrait.extensions.{AdvancedExtensionNode, ExtensionB
import org.apache.gluten.substrait.rel.RelNode
import org.apache.spark.sql.catalyst.expressions._
+import org.apache.spark.sql.catalyst.plans.physical.Partitioning
import org.apache.spark.sql.execution.SparkPlan
import scala.collection.JavaConverters._
@@ -62,6 +63,8 @@ abstract class GenerateExecTransformerBase(
override def output: Seq[Attribute] = requiredChildOutput ++ generatorOutput
+ override def outputPartitioning: Partitioning = child.outputPartitioning
+
override def producedAttributes: AttributeSet = AttributeSet(generatorOutput)
override protected def doValidateInternal(): ValidationResult = {
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
