support_ansi_sum_decimal_input_fix_scala

coderfender · coderfender · commit ac6b49372863 · 2025-11-28T18:12:39.000-08:00
diff --git a/spark/src/test/scala/org/apache/comet/exec/CometExecSuite.scala b/spark/src/test/scala/org/apache/comet/exec/CometExecSuite.scala
@@ -469,7 +469,7 @@ class CometExecSuite extends CometTestBase {
     val dayTimeDf = Seq(106751991L, 106751991L, 2L)
       .map(Duration.ofDays)
       .toDF("v")
-    Seq(longDf).foreach { df =>
+    Seq(longDf, yearMonthDf, dayTimeDf).foreach { df =>
       checkSparkAnswer(df.repartitionByRange(2, col("v")).selectExpr("try_sum(v)"))
     }
   }

Original file line number	Diff line number	Diff line change
`@@ -469,7 +469,7 @@ class CometExecSuite extends CometTestBase {`
`469`	`469`	`val dayTimeDf = Seq(106751991L, 106751991L, 2L)`
`470`	`470`	`.map(Duration.ofDays)`
`471`	`471`	`.toDF("v")`
`472`		`- Seq(longDf).foreach { df =>`
	`472`	`+ Seq(longDf, yearMonthDf, dayTimeDf).foreach { df =>`
`473`	`473`	`checkSparkAnswer(df.repartitionByRange(2, col("v")).selectExpr("try_sum(v)"))`
`474`	`474`	`}`
`475`	`475`	`}`