fix empty-table panic for IcebergPartitionedScan

toutane · toutane · commit 61968dff3db4 · 2026-03-24T16:20:02.000+01:00
diff --git a/crates/integrations/datafusion/src/physical_plan/partitioned_scan.rs b/crates/integrations/datafusion/src/physical_plan/partitioned_scan.rs
@@ -44,7 +44,7 @@ impl IcebergPartitionedScan {
     fn compute_properties(schema: ArrowSchemaRef, n_partitions: usize) -> PlanProperties {
         PlanProperties::new(
             EquivalenceProperties::new(schema),
-            Partitioning::UnknownPartitioning(n_partitions.max(1)),
+            Partitioning::UnknownPartitioning(n_partitions),
             EmissionType::Incremental,
             Boundedness::Bounded,
         )

Original file line number	Diff line number	Diff line change
`@@ -44,7 +44,7 @@ impl IcebergPartitionedScan {`
`44`	`44`	`fn compute_properties(schema: ArrowSchemaRef, n_partitions: usize) -> PlanProperties {`
`45`	`45`	`PlanProperties::new(`
`46`	`46`	`EquivalenceProperties::new(schema),`
`47`		`- Partitioning::UnknownPartitioning(n_partitions.max(1)),`
	`47`	`+ Partitioning::UnknownPartitioning(n_partitions),`
`48`	`48`	`EmissionType::Incremental,`
`49`	`49`	`Boundedness::Bounded,`
`50`	`50`	`)`