This is an automated email from the ASF dual-hosted git repository.
vhs pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/hudi.git
The following commit(s) were added to refs/heads/master by this push:
new 35e2bbf9813f refactor: add import (#18428)
35e2bbf9813f is described below
commit 35e2bbf9813f313006c773b92578db6cb93da9ca
Author: voonhous <[email protected]>
AuthorDate: Tue Mar 31 17:34:41 2026 +0800
refactor: add import (#18428)
---
.../execution/datasources/parquet/HoodieParquetFileFormatHelper.scala | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
diff --git
a/hudi-client/hudi-spark-client/src/main/scala/org/apache/spark/sql/execution/datasources/parquet/HoodieParquetFileFormatHelper.scala
b/hudi-client/hudi-spark-client/src/main/scala/org/apache/spark/sql/execution/datasources/parquet/HoodieParquetFileFormatHelper.scala
index 6b1934f5c4bf..6c2133261e77 100644
---
a/hudi-client/hudi-spark-client/src/main/scala/org/apache/spark/sql/execution/datasources/parquet/HoodieParquetFileFormatHelper.scala
+++
b/hudi-client/hudi-spark-client/src/main/scala/org/apache/spark/sql/execution/datasources/parquet/HoodieParquetFileFormatHelper.scala
@@ -21,6 +21,7 @@ package org.apache.spark.sql.execution.datasources.parquet
import org.apache.hadoop.conf.Configuration
import org.apache.hudi.HoodieSparkUtils
+import org.apache.hudi.common.util.collection.Pair
import org.apache.parquet.hadoop.metadata.FileMetaData
import org.apache.parquet.schema.{MessageType, PrimitiveType, Types}
import org.apache.parquet.schema.PrimitiveType.PrimitiveTypeName
@@ -33,7 +34,7 @@ object HoodieParquetFileFormatHelper {
def buildImplicitSchemaChangeInfo(hadoopConf: Configuration,
parquetFileMetaData: FileMetaData,
- requiredSchema: StructType):
(java.util.Map[Integer, org.apache.hudi.common.util.collection.Pair[DataType,
DataType]], StructType) = {
+ requiredSchema: StructType):
(java.util.Map[Integer, Pair[DataType, DataType]], StructType) = {
val originalSchema = parquetFileMetaData.getSchema
// Spark 3.3's ParquetToSparkSchemaConverter throws "Illegal Parquet type:
FIXED_LEN_BYTE_ARRAY"
