fix shims

mbutrovich · mbutrovich · commit cd6539c2831d · 2026-02-09T20:29:55.000-05:00
diff --git a/spark/src/main/spark-3.4/org/apache/spark/sql/comet/shims/ShimCometScanExec.scala b/spark/src/main/spark-3.4/org/apache/spark/sql/comet/shims/ShimCometScanExec.scala
@@ -152,7 +152,7 @@ trait ShimCometScanExec {
         Seq.tabulate(bucketSpec.numBuckets) { bucketId =>
           FilePartition(
             bucketId,
-            prunedFilesGroupedToBuckets.getOrElse(bucketId, Seq.empty).toArray)
+            prunedFilesGroupedToBuckets.getOrElse(bucketId, Array.empty[PartitionedFile]))
         }
     }
   }
diff --git a/spark/src/main/spark-3.5/org/apache/spark/sql/comet/shims/ShimCometScanExec.scala b/spark/src/main/spark-3.5/org/apache/spark/sql/comet/shims/ShimCometScanExec.scala
@@ -154,7 +154,7 @@ trait ShimCometScanExec {
         Seq.tabulate(bucketSpec.numBuckets) { bucketId =>
           FilePartition(
             bucketId,
-            prunedFilesGroupedToBuckets.getOrElse(bucketId, Seq.empty).toArray)
+            prunedFilesGroupedToBuckets.getOrElse(bucketId, Array.empty[PartitionedFile]))
         }
     }
   }

Original file line number	Diff line number	Diff line change
`@@ -152,7 +152,7 @@ trait ShimCometScanExec {`
`152`	`152`	`Seq.tabulate(bucketSpec.numBuckets) { bucketId =>`
`153`	`153`	`FilePartition(`
`154`	`154`	`bucketId,`
`155`		`- prunedFilesGroupedToBuckets.getOrElse(bucketId, Seq.empty).toArray)`
	`155`	`+ prunedFilesGroupedToBuckets.getOrElse(bucketId, Array.empty[PartitionedFile]))`
`156`	`156`	`}`
`157`	`157`	`}`
`158`	`158`	`}`
Original file line number	Diff line number	Diff line change
`@@ -154,7 +154,7 @@ trait ShimCometScanExec {`
`154`	`154`	`Seq.tabulate(bucketSpec.numBuckets) { bucketId =>`
`155`	`155`	`FilePartition(`
`156`	`156`	`bucketId,`
`157`		`- prunedFilesGroupedToBuckets.getOrElse(bucketId, Seq.empty).toArray)`
	`157`	`+ prunedFilesGroupedToBuckets.getOrElse(bucketId, Array.empty[PartitionedFile]))`
`158`	`158`	`}`
`159`	`159`	`}`
`160`	`160`	`}`