-
Notifications
You must be signed in to change notification settings - Fork 251
Closed
Labels
bugSomething isn't workingSomething isn't working
Description
Describe the bug
SQL
SELECT c28, abs(c28) AS x FROM test1 ORDER BY c28;
Spark Plan
AdaptiveSparkPlan isFinalPlan=true
+- == Final Plan ==
*(2) Sort [c28#228L ASC NULLS FIRST], true, 0
+- AQEShuffleRead coalesced
+- ShuffleQueryStage 0
+- Exchange rangepartitioning(c28#228L ASC NULLS FIRST, 200), ENSURE_REQUIREMENTS, [plan_id=24514]
+- *(1) Project [c28#228L, abs(c28#228L) AS x#25310L]
+- *(1) ColumnarToRow
+- FileScan parquet [c28#228L] Batched: true, DataFilters: [], Format: Parquet, Location: InMemoryFileIndex(1 paths)[file:/home/andy/git/apache/datafusion-comet/fuzz-testing/test1.parquet], PartitionFilters: [], PushedFilters: [], ReadSchema: struct<c28:bigint>
+- == Initial Plan ==
Sort [c28#228L ASC NULLS FIRST], true, 0
+- Exchange rangepartitioning(c28#228L ASC NULLS FIRST, 200), ENSURE_REQUIREMENTS, [plan_id=24500]
+- Project [c28#228L, abs(c28#228L) AS x#25310L]
+- FileScan parquet [c28#228L] Batched: true, DataFilters: [], Format: Parquet, Location: InMemoryFileIndex(1 paths)[file:/home/andy/git/apache/datafusion-comet/fuzz-testing/test1.parquet], PartitionFilters: [], PushedFilters: [], ReadSchema: struct<c28:bigint>
Comet Plan
AdaptiveSparkPlan isFinalPlan=true
+- == Final Plan ==
*(2) Sort [c28#228L ASC NULLS FIRST], true, 0
+- AQEShuffleRead coalesced
+- ShuffleQueryStage 0
+- Exchange rangepartitioning(c28#228L ASC NULLS FIRST, 200), ENSURE_REQUIREMENTS, [plan_id=24579]
+- *(1) ColumnarToRow
+- CometProject [c28#228L, x#25316L], [c28#228L, abs(c28#228L) AS x#25316L]
+- CometScan parquet [c28#228L] Batched: true, DataFilters: [], Format: CometParquet, Location: InMemoryFileIndex(1 paths)[file:/home/andy/git/apache/datafusion-comet/fuzz-testing/test1.parquet], PartitionFilters: [], PushedFilters: [], ReadSchema: struct<c28:bigint>
+- == Initial Plan ==
Sort [c28#228L ASC NULLS FIRST], true, 0
+- Exchange rangepartitioning(c28#228L ASC NULLS FIRST, 200), ENSURE_REQUIREMENTS, [plan_id=24559]
+- CometProject [c28#228L, x#25316L], [c28#228L, abs(c28#228L) AS x#25316L]
+- CometScan parquet [c28#228L] Batched: true, DataFilters: [], Format: CometParquet, Location: InMemoryFileIndex(1 paths)[file:/home/andy/git/apache/datafusion-comet/fuzz-testing/test1.parquet], PartitionFilters: [], PushedFilters: [], ReadSchema: struct<c28:bigint>
First difference at row 11:
Spark: -8779944534083813778,8779944534083813778
Comet: -8779944534083813778,-8779944534083813778
Steps to reproduce
No response
Expected behavior
No response
Additional context
No response
Metadata
Metadata
Assignees
Labels
bugSomething isn't workingSomething isn't working