@@ -2698,7 +2698,7 @@ class CometExpressionSuite extends CometTestBase with AdaptiveSparkPlanHelper {
26982698
26992699 test(" test integral divide" ) {
27002700 // this test requires native_comet scan due to unsigned u8/u16 issue
2701- withSQLConf(CometConf .COMET_NATIVE_SCAN_IMPL .key -> CometConf .SCAN_NATIVE_COMET ) {
2701+ withSQLConf(CometConf .COMET_NATIVE_SCAN_IMPL .key -> CometConf .SCAN_NATIVE_COMET , CometConf . COMET_CAST_ALLOW_INCOMPATIBLE .key -> " true " ) {
27022702 Seq (true , false ).foreach { dictionaryEnabled =>
27032703 withTempDir { dir =>
27042704 val path1 = new Path (dir.toURI.toString, " test1.parquet" )
@@ -2717,7 +2717,7 @@ class CometExpressionSuite extends CometTestBase with AdaptiveSparkPlanHelper {
27172717 randomSize = 10000 )
27182718 withParquetTable(path1.toString, " tbl1" ) {
27192719 withParquetTable(path2.toString, " tbl2" ) {
2720- checkSparkAnswer ("""
2720+ checkSparkAnswerAndOperator ("""
27212721 |select
27222722 | t1._2 div t2._2, div(t1._2, t2._2),
27232723 | t1._3 div t2._3, div(t1._3, t2._3),
@@ -2729,7 +2729,7 @@ class CometExpressionSuite extends CometTestBase with AdaptiveSparkPlanHelper {
27292729 | from tbl1 t1 join tbl2 t2 on t1._id = t2._id
27302730 | order by t1._id""" .stripMargin)
27312731
2732- checkSparkAnswer ("""
2732+ checkSparkAnswerAndOperator ("""
27332733 |select
27342734 | t1._12 div t2._12, div(t1._12, t2._12),
27352735 | t1._15 div t2._15, div(t1._15, t2._15),
0 commit comments