This is an automated email from the ASF dual-hosted git repository. changchen pushed a commit to branch feature/41 in repository https://gitbox.apache.org/repos/asf/incubator-gluten.git
commit 445d2051ffaa19537b49bf5574ae6b86002830d0 Author: Chang chen <[email protected]> AuthorDate: Fri Dec 26 15:02:31 2025 +0800 [Fix] Fix MiscOperatorSuite to support OneRowRelationExec plan Spark 4.1 see https://github.com/apache/spark/pull/50849 --- .../test/scala/org/apache/gluten/execution/MiscOperatorSuite.scala | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/backends-velox/src/test/scala/org/apache/gluten/execution/MiscOperatorSuite.scala b/backends-velox/src/test/scala/org/apache/gluten/execution/MiscOperatorSuite.scala index c313242091..cfddfb8e21 100644 --- a/backends-velox/src/test/scala/org/apache/gluten/execution/MiscOperatorSuite.scala +++ b/backends-velox/src/test/scala/org/apache/gluten/execution/MiscOperatorSuite.scala @@ -753,7 +753,11 @@ class MiscOperatorSuite extends VeloxWholeStageTransformerSuite with AdaptiveSpa val df = sql("SELECT 1") checkAnswer(df, Row(1)) val plan = df.queryExecution.executedPlan - assert(plan.find(_.isInstanceOf[RDDScanExec]).isDefined) + if (isSparkVersionGE("4.1")) { + assert(plan.find(_.getClass.getSimpleName == "OneRowRelationExec").isDefined) + } else { + assert(plan.find(_.isInstanceOf[RDDScanExec]).isDefined) + } assert(plan.find(_.isInstanceOf[ProjectExecTransformer]).isDefined) assert(plan.find(_.isInstanceOf[RowToVeloxColumnarExec]).isDefined) } --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
