Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
38 commits
Select commit Hold shift + click to select a range
d6a32e8
Move DF52 work to shared branch (#3469)
comphead Feb 10, 2026
b787094
fix: use Spark date_add/date_sub UDFs for Date32 +/- Int arithmetic (…
andygrove Feb 10, 2026
9a266d0
Fix fuzz shuffle tests
comphead Feb 10, 2026
ac49b47
chore: [df52] fix index out of bounds for `native_datafusion` scan (#…
comphead Feb 11, 2026
89b0f1a
fix: handle complex nested type casts in schema adapter for DF52 (#3475)
andygrove Feb 11, 2026
9a047ce
fix: [df52] make relabel_array recursive for nested type mismatches (…
andygrove Feb 11, 2026
9becdb0
fix: [df52] route timestamp timezone mismatches through spark_parquet…
andygrove Feb 12, 2026
6383c1c
fix: [df52] handle case-insensitive column matching in PhysicalExprAd…
andygrove Feb 12, 2026
d102a32
fix: update dictionary unpack tests for DF52 stream polling changes (…
andygrove Feb 12, 2026
adced48
clippy
andygrove Feb 12, 2026
acfef5a
fix: [df52] timestamp nanos precision loss with nanosAsLong (#3502)
andygrove Feb 12, 2026
7e89db2
Df52 migration - ignore `width_bucket` (#3501)
comphead Feb 12, 2026
d189195
fix: [df52] schema pruning crash on complex nested types (#3500)
andygrove Feb 12, 2026
f973bd0
fix: [df52] skip ParquetVariantShreddingSuite for Spark 4.0 (#3503)
andygrove Feb 12, 2026
8ee18cc
Df52 migration - get failed tests
comphead Feb 12, 2026
627bf1c
[df52] miri
comphead Feb 12, 2026
724b35e
[df52] miri
comphead Feb 12, 2026
6aa7db2
[df52] miri
comphead Feb 12, 2026
af3486c
[df52] miri
comphead Feb 12, 2026
aa406d3
[df52] tests ignore
comphead Feb 13, 2026
8374149
[df52] tests ignore
comphead Feb 13, 2026
787e09f
DataFusion 52 migration
comphead Feb 13, 2026
7344da6
[df52] tests ignore
comphead Feb 13, 2026
17fd791
DataFusion 52 migration
comphead Feb 14, 2026
0764960
[df52] tests ignore
comphead Feb 14, 2026
001cee5
DataFusion 52 migration
comphead Feb 14, 2026
3953b1b
DataFusion 52 migration
comphead Feb 14, 2026
267e202
DataFusion 52 migration
comphead Feb 16, 2026
a19feb3
DataFusion 52 migration
comphead Feb 18, 2026
70bbc88
DataFusion 52 migration
comphead Feb 18, 2026
5d0f9e8
DataFusion 52 migration
comphead Feb 20, 2026
c38e71a
[df52] tests
comphead Feb 20, 2026
9cf5e2f
[df52] tests
comphead Feb 20, 2026
d7efd9e
Df52 migration
comphead Feb 24, 2026
bc83b8e
DataFusion 52 migration
comphead Feb 24, 2026
eae808e
DataFusion 52 migration
comphead Feb 24, 2026
591507f
Df52 migration
comphead Feb 24, 2026
7e028b4
Df52 migration
comphead Feb 24, 2026
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
24 changes: 24 additions & 0 deletions dev/diffs/4.0.1.diff
Original file line number Diff line number Diff line change
Expand Up @@ -2960,6 +2960,30 @@ index 09ed6955a51..236a4e99824 100644
)
}
test(s"parquet widening conversion $fromType -> $toType") {
diff --git a/sql/core/src/test/scala/org/apache/spark/sql/execution/datasources/parquet/ParquetVariantShreddingSuite.scala b/sql/core/src/test/scala/org/apache/spark/sql/execution/datasources/parquet/ParquetVariantShreddingSuite.scala
index 458b5dfc0f4..d209f3c85bc 100644
--- a/sql/core/src/test/scala/org/apache/spark/sql/execution/datasources/parquet/ParquetVariantShreddingSuite.scala
+++ b/sql/core/src/test/scala/org/apache/spark/sql/execution/datasources/parquet/ParquetVariantShreddingSuite.scala
@@ -26,7 +26,7 @@ import org.apache.parquet.hadoop.util.HadoopInputFile
import org.apache.parquet.schema.{LogicalTypeAnnotation, PrimitiveType}
import org.apache.parquet.schema.PrimitiveType.PrimitiveTypeName

-import org.apache.spark.sql.{QueryTest, Row}
+import org.apache.spark.sql.{IgnoreCometSuite, QueryTest, Row}
import org.apache.spark.sql.internal.SQLConf
import org.apache.spark.sql.internal.SQLConf.ParquetOutputTimestampType
import org.apache.spark.sql.test.SharedSparkSession
@@ -35,7 +35,9 @@ import org.apache.spark.unsafe.types.VariantVal
/**
* Test shredding Variant values in the Parquet reader/writer.
*/
-class ParquetVariantShreddingSuite extends QueryTest with ParquetTest with SharedSparkSession {
+class ParquetVariantShreddingSuite extends QueryTest with ParquetTest with SharedSparkSession
+ // TODO enable tests once https://github.com/apache/datafusion-comet/issues/2209 is fixed
+ with IgnoreCometSuite {

private def testWithTempDir(name: String)(block: File => Unit): Unit = test(name) {
withTempDir { dir =>
diff --git a/sql/core/src/test/scala/org/apache/spark/sql/execution/debug/DebuggingSuite.scala b/sql/core/src/test/scala/org/apache/spark/sql/execution/debug/DebuggingSuite.scala
index b8f3ea3c6f3..bbd44221288 100644
--- a/sql/core/src/test/scala/org/apache/spark/sql/execution/debug/DebuggingSuite.scala
Expand Down
Loading
Loading