coderfender commented on PR #2136:
URL:
https://github.com/apache/datafusion-comet/pull/2136#issuecomment-3193840124
After some debugging early exception raising (from datafusion custom ANSI
kernel) seems to be the issue . Below is the exact test which is causing a
failure in Spark4.0
```
test("fix ANSI support for divide") {
val data = Seq((Integer.MIN_VALUE, 0))
withSQLConf(
SQLConf.ANSI_ENABLED.key -> "true",
CometConf.COMET_ANSI_MODE_ENABLED.key -> "true",
"spark.comet.explainFallback.enabled" -> "true") {
withParquetTable(data, "tbl") {
spark.sql("CREATE TABLE conditional_t USING PARQUET AS SELECT c1, c2
FROM VALUES(1d, 0),(2d, 1),(null, 1),(CAST('NaN' AS DOUBLE), 0) AS t(c1, c2);")
val res = spark.sql("""
|SELECT coalesce(c2, 1/0) from conditional_t;
| """.stripMargin)
res.explain()
checkSparkAnswerAndOperator(res)
}
}
}
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: github-unsubscr...@datafusion.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
---------------------------------------------------------------------
To unsubscribe, e-mail: github-unsubscr...@datafusion.apache.org
For additional commands, e-mail: github-h...@datafusion.apache.org
