cast_operands_to_decimal_integral_division

Author: Bhargava Vadlamani

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

@@ -213,10 +213,10 @@ object CometIntegralDivide extends CometExpressionSerde with MathBase {
 
     val left =
       if (div.left.dataType.isInstanceOf[DecimalType]) div.left
-      else Cast(div.left, DecimalType(DecimalType.MAX_PRECISION, DecimalType.MAX_SCALE))
+      else Cast(div.left, DecimalType(19, 0))
     val right =
       if (div.right.dataType.isInstanceOf[DecimalType]) div.right
-      else Cast(div.right, DecimalType(DecimalType.MAX_PRECISION, DecimalType.MAX_SCALE))
+      else Cast(div.right, DecimalType(19, 0))
 
     val rightExpr = nullIfWhenPrimitive(right)
 

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

@@ -115,11 +115,13 @@ class CometExpressionSuite extends CometTestBase with AdaptiveSparkPlanHelper {
 
   test("Integral Division Overflow Handling Matches Spark Behavior") {
     withTable("t1") {
+    withSQLConf(CometConf.COMET_CAST_ALLOW_INCOMPATIBLE.key -> "true"){
       val value = Long.MinValue
       sql("create table t1(c1 long, c2 short) using parquet")
       sql(s"insert into t1 values($value, -1)")
       val res = sql("select c1 div c2 from t1 order by c1")
-      checkSparkAnswer(res)
+      checkSparkAnswerAndOperator(res)
+    }
     }
   }