don't unwrap copy, we need to original so that the hadoopconf gets mo…

…dified by build
apache · May 30, 2024 · 63737ca · 63737ca
1 parent f126475
commit 63737ca
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...spark/sql/execution/datasources/parquet/HoodieFileGroupReaderBasedParquetFileFormat.scala b/...spark/sql/execution/datasources/parquet/HoodieFileGroupReaderBasedParquetFileFormat.scala
@@ -134,7 +134,7 @@ class HoodieFileGroupReaderBasedParquetFileFormat(tableState: HoodieTableState,
  val requestedAvroSchema = AvroConversionUtils.convertStructTypeToAvroSchema(requiredSchema, sanitizedTableName)
  val dataAvroSchema = AvroConversionUtils.convertStructTypeToAvroSchema(dataSchema, sanitizedTableName)
  val parquetFileReader = spark.sparkContext.broadcast(sparkAdapter.createParquetFileReader(supportBatchResult,
- spark.sessionState.conf, options, augmentedStorageConf.unwrapCopy()))
+ spark.sessionState.conf, options, augmentedStorageConf.unwrap()))
  val broadcastedStorageConf = spark.sparkContext.broadcast(augmentedStorageConf)
  val broadcastedDataSchema = spark.sparkContext.broadcast(dataAvroSchema)
  val broadcastedRequestedSchema = spark.sparkContext.broadcast(requestedAvroSchema)