Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
19 commits
Select commit Hold shift + click to select a range
1366047
Move DF52 work to shared branch (#3469)
comphead Feb 10, 2026
451ae69
fix: use Spark date_add/date_sub UDFs for Date32 +/- Int arithmetic (…
andygrove Feb 10, 2026
ad18b1c
Fix fuzz shuffle tests
comphead Feb 10, 2026
2dd8909
chore: [df52] fix index out of bounds for `native_datafusion` scan (#…
comphead Feb 11, 2026
24f3e4f
Merge remote-tracking branch 'apache/main' into df52
andygrove Feb 11, 2026
8c76d2f
fix: handle complex nested type casts in schema adapter for DF52 (#3475)
andygrove Feb 11, 2026
2482c43
fix: [df52] make relabel_array recursive for nested type mismatches (…
andygrove Feb 11, 2026
f0652aa
fix: [df52] route timestamp timezone mismatches through spark_parquet…
andygrove Feb 12, 2026
847c1b9
fix: [df52] handle case-insensitive column matching in PhysicalExprAd…
andygrove Feb 12, 2026
b293294
fix: update dictionary unpack tests for DF52 stream polling changes (…
andygrove Feb 12, 2026
a72d277
upmerge
andygrove Feb 12, 2026
c471e1a
fmt
andygrove Feb 12, 2026
dc2b9a4
clippy
andygrove Feb 12, 2026
f3b08bc
fix: [df52] timestamp nanos precision loss with nanosAsLong (#3502)
andygrove Feb 12, 2026
802b794
Df52 migration - ignore `width_bucket` (#3501)
comphead Feb 12, 2026
43c843b
fix: [df52] schema pruning crash on complex nested types (#3500)
andygrove Feb 12, 2026
23a0dd1
fix: [df52] skip ParquetVariantShreddingSuite for Spark 4.0 (#3503)
andygrove Feb 12, 2026
de0e853
trigger CI
andygrove Feb 12, 2026
156af5f
Merge remote-tracking branch 'apache/main' into df52
andygrove Feb 12, 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