Skip to content

Commit

Permalink
fix
Browse files Browse the repository at this point in the history
  • Loading branch information
7mming7 committed Apr 23, 2024
1 parent 10eafbf commit 4000f61
Showing 1 changed file with 0 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -32,7 +32,6 @@ import org.apache.parquet.format.converter.ParquetMetadataConverter.SKIP_ROW_GRO
import org.apache.parquet.hadoop._

import org.apache.spark.TaskContext
import org.apache.spark.deploy.SparkHadoopUtil
import org.apache.spark.internal.{Logging, MDC}
import org.apache.spark.internal.LogKey.{PATH, SCHEMA}
import org.apache.spark.sql._
Expand Down Expand Up @@ -208,7 +207,6 @@ class ParquetFileFormat
assert(supportBatch(sparkSession, resultSchema))
}

val sparkConf = sparkSession.sparkContext.conf
(file: PartitionedFile) => {
assert(file.partitionValues.numFields == partitionSchema.size)

Expand Down

0 comments on commit 4000f61

Please sign in to comment.