File tree Expand file tree Collapse file tree 1 file changed +3
-4
lines changed
spark/src/test/scala/org/apache/comet Expand file tree Collapse file tree 1 file changed +3
-4
lines changed Original file line number Diff line number Diff line change @@ -292,14 +292,13 @@ class CometArrayExpressionSuite extends CometTestBase with AdaptiveSparkPlanHelp
292292 generateMap = false ))
293293 }
294294 val table = spark.read.parquet(filename)
295+ table.createOrReplaceTempView(" t2" )
295296 for (field <- table.schema.fields) {
296297 val typeName = field.dataType.typeName
297- checkSparkAnswerAndOperator(
298- sql(s " SELECT array_contains(cast(null as array< $typeName>), b) FROM t2 " ))
299298 checkSparkAnswerAndOperator(sql(
300- s " SELECT array_contains(cast(array() as array< $typeName>), cast(null as $typeName)) FROM t2 " ))
301- checkSparkAnswerAndOperator(sql(" SELECT array_contains(array(), 1) FROM t2" ))
299+ s " SELECT array_contains(cast(null as array< $typeName>), cast(null as $typeName)) FROM t2 " ))
302300 }
301+ checkSparkAnswerAndOperator(sql(" SELECT array_contains(array(), 1) FROM t2" ))
303302 }
304303 }
305304
You can’t perform that action at this time.
0 commit comments