Skip to content

Commit b9f8eb2

Browse files
committed
use readDataSchema instead of dataSchema
1 parent fb01c3f commit b9f8eb2

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/parquet/ParquetScanBuilder.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -50,7 +50,7 @@ case class ParquetScanBuilder(
5050
val pushDownInFilterThreshold = sqlConf.parquetFilterPushDownInFilterThreshold
5151
val isCaseSensitive = sqlConf.caseSensitiveAnalysis
5252
val parquetSchema =
53-
new SparkToParquetSchemaConverter(sparkSession.sessionState.conf).convert(dataSchema)
53+
new SparkToParquetSchemaConverter(sparkSession.sessionState.conf).convert(readDataSchema())
5454
val parquetFilters = new ParquetFilters(parquetSchema, pushDownDate, pushDownTimestamp,
5555
pushDownDecimal, pushDownStringStartWith, pushDownInFilterThreshold, isCaseSensitive)
5656
parquetFilters.convertibleFilters(this.filters).toArray

0 commit comments

Comments
 (0)