We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent c30f5ae commit 445d205Copy full SHA for 445d205
1 file changed
backends-velox/src/test/scala/org/apache/gluten/execution/MiscOperatorSuite.scala
@@ -753,7 +753,11 @@ class MiscOperatorSuite extends VeloxWholeStageTransformerSuite with AdaptiveSpa
753
val df = sql("SELECT 1")
754
checkAnswer(df, Row(1))
755
val plan = df.queryExecution.executedPlan
756
- assert(plan.find(_.isInstanceOf[RDDScanExec]).isDefined)
+ if (isSparkVersionGE("4.1")) {
757
+ assert(plan.find(_.getClass.getSimpleName == "OneRowRelationExec").isDefined)
758
+ } else {
759
+ assert(plan.find(_.isInstanceOf[RDDScanExec]).isDefined)
760
+ }
761
assert(plan.find(_.isInstanceOf[ProjectExecTransformer]).isDefined)
762
assert(plan.find(_.isInstanceOf[RowToVeloxColumnarExec]).isDefined)
763
}
0 commit comments