andygrove opened a new issue, #1983:
URL: https://github.com/apache/datafusion-comet/issues/1983
### Describe the bug
During fuzz testing, I am seeing errors reading decimals.
```
## SQL
```
SELECT c7, cast(c7 as SMALLINT), try_cast(c7 as SMALLINT) FROM
local.db.test0 ORDER BY c7;
```
### Spark Plan
```
AdaptiveSparkPlan isFinalPlan=true
+- == Final Plan ==
*(2) Sort [c7#6669 ASC NULLS FIRST], true, 0
+- AQEShuffleRead coalesced
+- ShuffleQueryStage 0
+- Exchange rangepartitioning(c7#6669 ASC NULLS FIRST, 200),
ENSURE_REQUIREMENTS, [plan_id=8959]
+- *(1) Project [c7#6669, cast(c7#6669 as smallint) AS c7#6675,
try_cast(c7#6669 as smallint) AS c7#6676]
+- *(1) ColumnarToRow
+- BatchScan local.db.test0[c7#6669] local.db.test0
(branch=null) [filters=, groupedBy=] RuntimeFilters: []
+- == Initial Plan ==
Sort [c7#6669 ASC NULLS FIRST], true, 0
+- Exchange rangepartitioning(c7#6669 ASC NULLS FIRST, 200),
ENSURE_REQUIREMENTS, [plan_id=8946]
+- Project [c7#6669, cast(c7#6669 as smallint) AS c7#6675,
try_cast(c7#6669 as smallint) AS c7#6676]
+- BatchScan local.db.test0[c7#6669] local.db.test0 (branch=null)
[filters=, groupedBy=] RuntimeFilters: []
```
### Comet Plan
```
AdaptiveSparkPlan isFinalPlan=true
+- == Final Plan ==
*(1) CometColumnarToRow
+- CometSort [c7#6697, c7#6703, c7#6704], [c7#6697 ASC NULLS FIRST]
+- AQEShuffleRead coalesced
+- ShuffleQueryStage 0
+- CometColumnarExchange rangepartitioning(c7#6697 ASC NULLS
FIRST, 200), ENSURE_REQUIREMENTS, CometColumnarShuffle, [plan_id=9021]
+- CometProject [c7#6697, c7#6703, c7#6704], [c7#6697,
cast(c7#6697 as smallint) AS c7#6703, try_cast(c7#6697 as smallint) AS c7#6704]
+- CometBatchScan local.db.test0[c7#6697] local.db.test0
(branch=null) [filters=, groupedBy=] RuntimeFilters: []
+- == Initial Plan ==
CometSort [c7#6697, c7#6703, c7#6704], [c7#6697 ASC NULLS FIRST]
+- CometColumnarExchange rangepartitioning(c7#6697 ASC NULLS FIRST, 200),
ENSURE_REQUIREMENTS, CometColumnarShuffle, [plan_id=9008]
+- CometProject [c7#6697, c7#6703, c7#6704], [c7#6697, cast(c7#6697 as
smallint) AS c7#6703, try_cast(c7#6697 as smallint) AS c7#6704]
+- CometBatchScan local.db.test0[c7#6697] local.db.test0
(branch=null) [filters=, groupedBy=] RuntimeFilters: []
```
First difference at row 1:
Spark: `0.01,0,0`
Comet: `0.00,0,0`
### Steps to reproduce
_No response_
### Expected behavior
_No response_
### Additional context
_No response_
--
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.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
