Skip to content

Commit

Permalink
Update spark/src/main/spark-3.x/org/apache/comet/shims/ShimCometScanE…
Browse files Browse the repository at this point in the history
…xec.scala
  • Loading branch information
viirya authored May 18, 2024
1 parent 7def1ea commit bd24b31
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -70,7 +70,7 @@ trait ShimCometScanExec {
options: ParquetOptions): FileScanRDD =
classOf[FileScanRDD].getDeclaredConstructors
// Prevent to pick up incorrect constructors from any custom Spark forks.
.filter(c => List(3,5,6).contains(c.getParameterCount()) )
.filter(c => List(3, 5, 6).contains(c.getParameterCount()) )
.map { c =>
c.getParameterCount match {
case 3 => c.newInstance(sparkSession, readFunction, filePartitions)
Expand Down

0 comments on commit bd24b31

Please sign in to comment.