Skip to content

Commit da4c671

Browse files
author
Bhargava Vadlamani
committed
fix_tests
1 parent 3479ba2 commit da4c671

2 files changed

Lines changed: 3 additions & 3 deletions

File tree

spark/src/main/scala/org/apache/comet/serde/arithmetic.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -225,7 +225,7 @@ object CometIntegralDivide extends CometExpressionSerde with MathBase {
225225
// copy from IntegralDivide.resultDecimalType
226226
val intDig = l.precision - l.scale + r.scale
227227
DecimalType(min(if (intDig == 0) 1 else intDig, DecimalType.MAX_PRECISION), 0)
228-
case _ => div.left.dataType
228+
case _ => left.dataType
229229
}
230230

231231
val divideExpr = createMathExpression(

spark/src/test/scala/org/apache/comet/CometExpressionSuite.scala

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -2715,7 +2715,7 @@ class CometExpressionSuite extends CometTestBase with AdaptiveSparkPlanHelper {
27152715
randomSize = 10000)
27162716
withParquetTable(path1.toString, "tbl1") {
27172717
withParquetTable(path2.toString, "tbl2") {
2718-
checkSparkAnswerAndOperator("""
2718+
checkSparkAnswer("""
27192719
|select
27202720
| t1._2 div t2._2, div(t1._2, t2._2),
27212721
| t1._3 div t2._3, div(t1._3, t2._3),
@@ -2727,7 +2727,7 @@ class CometExpressionSuite extends CometTestBase with AdaptiveSparkPlanHelper {
27272727
| from tbl1 t1 join tbl2 t2 on t1._id = t2._id
27282728
| order by t1._id""".stripMargin)
27292729

2730-
checkSparkAnswerAndOperator("""
2730+
checkSparkAnswer("""
27312731
|select
27322732
| t1._12 div t2._12, div(t1._12, t2._12),
27332733
| t1._15 div t2._15, div(t1._15, t2._15),

0 commit comments

Comments
 (0)