remove debug code

Author: huaxingao

native/core/src/execution/datafusion/planner.rs

@@ -1663,7 +1663,6 @@ impl PhysicalPlanner {
                 let child = self.create_expr(expr.child.as_ref().unwrap(), schema.clone())?;
                 let datatype = to_arrow_datatype(expr.datatype.as_ref().unwrap());
                 let child = Arc::new(CastExpr::new(child, datatype.clone(), None));
-                println!("&child: {:?}", &child);
                 Ok(("sum".to_string(), vec![child]))
             }
             other => Err(ExecutionError::GeneralError(format!(

spark/src/test/scala/org/apache/comet/exec/CometExecSuite.scala

@@ -1503,6 +1503,38 @@ class CometExecSuite extends CometTestBase {
     })
   }
 
+  test("Windows decimal support") {
+    Seq("false").foreach(aqeEnabled =>
+      withSQLConf(
+        CometConf.COMET_EXEC_SHUFFLE_ENABLED.key -> "true",
+        SQLConf.ADAPTIVE_EXECUTION_ENABLED.key -> aqeEnabled) {
+
+        val table = "sales_data"
+        withTable(table) {
+          sql(
+            "CREATE TABLE sales_data ( " +
+              "item_id INT, " +
+              "item_category VARCHAR(50), " +
+              "item_class VARCHAR(50), " +
+              "sale_price DECIMAL(7,2)) using parquet")
+          sql(
+            "INSERT INTO sales_data VALUES " +
+              "(1, 'Sports', 'Outdoor', 300.00), " +
+              "(1, 'Sports', 'Outdoor', 200.00), " +
+              "(2, 'Books', 'Fiction', 30.00), " +
+              "(3, 'Home', 'Furniture', 90.00)")
+
+          val df = sql(
+            "SELECT " +
+              "item_class, " +
+              "1 / SUM(SUM(sale_price)) OVER () AS nested_sum " +
+              "FROM sales_data " +
+              "GROUP BY item_class")
+          df.rdd.collect()
+        }
+      })
+  }
+
   test("Windows support") {
     Seq("true", "false").foreach(aqeEnabled =>
       withSQLConf(

spark/src/test/scala/org/apache/spark/sql/CometSQLQueryTestHelper.scala

@@ -62,10 +62,6 @@ trait CometSQLQueryTestHelper {
 
     val df = session.sql(sql)
     val schema = df.schema.catalogString
-    // scalastyle:off println
-    println("schema0 schema0 schema0: " + schema)
-    println("sql sql sql: " + sql)
-    // scalastyle:on println
 
     // Get answer, but also get rid of the #1234 expression ids that show up in explain plans
     val answer = SQLExecution.withNewExecutionId(df.queryExecution, Some(sql)) {
@@ -88,49 +84,25 @@ trait CometSQLQueryTestHelper {
       result
     } catch {
       case e: SparkThrowable with Throwable if e.getErrorClass != null =>
-        // scalastyle:off println
-        println("1111111")
-        e.printStackTrace()
-        println("e.getClass.getName: " + e.getClass.getName)
-        println("e.getMessage: " + e.getMessage)
-        // scalastyle:on println
         (emptySchema, Seq(e.getClass.getName, e.getMessage))
       case a: AnalysisException =>
         // Do not output the logical plan tree which contains expression IDs.
         // Also implement a crude way of masking expression IDs in the error message
         // with a generic pattern "###".
 
         val msg = a.getMessage
-        // scalastyle:off println
-        println("222222")
-        a.printStackTrace()
-        println("e.getClass.getName: " + a.getClass.getName)
-        println("e.getMessage: " + a.getMessage)
-        // scalastyle:on println
         (emptySchema, Seq(a.getClass.getName, msg.replaceAll("#\\d+", "#x")))
       case s: SparkException if s.getCause != null =>
         // For a runtime exception, it is hard to match because its message contains
         // information of stage, task ID, etc.
         // To make result matching simpler, here we match the cause of the exception if it exists.
-        // scalastyle:off println
-        println("3333333")
-        s.printStackTrace()
-        println("e.getClass.getName: " + s.getClass.getName)
-        println("e.getMessage: " + s.getMessage)
-        // scalastyle:on println
         s.getCause match {
           case e: SparkThrowable with Throwable if e.getErrorClass != null =>
             (emptySchema, Seq(e.getClass.getName, e.getMessage))
           case cause =>
             (emptySchema, Seq(cause.getClass.getName, cause.getMessage))
         }
       case NonFatal(e) =>
-        // scalastyle:off println
-        println("44444")
-        e.printStackTrace()
-        println("e.getClass.getName: " + e.getClass.getName)
-        println("e.getMessage: " + e.getMessage)
-        // scalastyle:on println
         // If there is an exception, put the exception class followed by the message.
         (emptySchema, Seq(e.getClass.getName, e.getMessage))
     }

spark/src/test/scala/org/apache/spark/sql/CometTPCDSQueryTestSuite.scala

@@ -128,10 +128,6 @@ class CometTPCDSQueryTestSuite extends QueryTest with TPCDSBase with CometSQLQue
           (segments(1).trim, segments(2).replaceAll("\\s+$", ""))
         }
 
-        // scalastyle:off println
-        println("schema schema schema: " + schema)
-        println("expected schema expected schema expected schema: " + expectedSchema)
-        // scalastyle:on println
         val notMatchedSchemaOutput = if (schema == emptySchema) {
           // There might be exception. See `handleExceptions`.
           s"Schema did not match\n$queryString\nOutput/Exception: $outputString"