avro: disable repartition scan and update sqllogictest

getChan · getChan · commit d363ef9257fb · 2026-03-01T18:46:02.000+09:00
diff --git a/datafusion/datasource-avro/src/source.rs b/datafusion/datasource-avro/src/source.rs
@@ -118,6 +118,11 @@ impl FileSource for AvroSource {
     fn file_type(&self) -> &str {
         "avro"
     }
+
+    fn supports_repartitioning(&self) -> bool {
+        // Avro OCF does not support safe byte-range splitting in this reader path.
+        false
+    }
 }
 
 mod private {
diff --git a/datafusion/sqllogictest/test_files/repartition_scan.slt b/datafusion/sqllogictest/test_files/repartition_scan.slt
@@ -283,7 +283,7 @@ query TT
 EXPLAIN SELECT * FROM avro_table
 ----
 logical_plan TableScan: avro_table projection=[f1, f2, f3]
-physical_plan DataSourceExec: file_groups={4 groups: [[WORKSPACE_ROOT/testing/data/avro/simple_enum.avro:0..103], [WORKSPACE_ROOT/testing/data/avro/simple_enum.avro:103..206], [WORKSPACE_ROOT/testing/data/avro/simple_enum.avro:206..309], [WORKSPACE_ROOT/testing/data/avro/simple_enum.avro:309..411]]}, projection=[f1, f2, f3], file_type=avro
+physical_plan DataSourceExec: file_groups={1 group: [[WORKSPACE_ROOT/testing/data/avro/simple_enum.avro]]}, projection=[f1, f2, f3], file_type=avro
 
 # Cleanup
 statement ok

Original file line number	Diff line number	Diff line change
`@@ -118,6 +118,11 @@ impl FileSource for AvroSource {`
`118`	`118`	`fn file_type(&self) -> &str {`
`119`	`119`	`"avro"`
`120`	`120`	`}`
	`121`	`+`
	`122`	`+ fn supports_repartitioning(&self) -> bool {`
	`123`	`+ // Avro OCF does not support safe byte-range splitting in this reader path.`
	`124`	`+ false`
	`125`	`+ }`
`121`	`126`	`}`
`122`	`127`
`123`	`128`	`mod private {`