You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hudi.apache.org by si...@apache.org on 2022/04/22 00:36:54 UTC
[hudi] 07/15: Fallback to pick ctors positionally as opposed to looking them up
This is an automated email from the ASF dual-hosted git repository.
sivabalan pushed a commit to branch release-0.11-0-apr21-5378-patched
in repository https://gitbox.apache.org/repos/asf/hudi.git
commit 286628908191740765319043664697df8e1877ec
Author: Alexey Kudinkin <al...@infinilake.com>
AuthorDate: Wed Apr 20 15:32:48 2022 -0700
Fallback to pick ctors positionally as opposed to looking them up
---
.../datasources/parquet/Spark32HoodieParquetFileFormat.scala | 7 +++++--
1 file changed, 5 insertions(+), 2 deletions(-)
diff --git a/hudi-spark-datasource/hudi-spark3/src/main/scala/org/apache/spark/sql/execution/datasources/parquet/Spark32HoodieParquetFileFormat.scala b/hudi-spark-datasource/hudi-spark3/src/main/scala/org/apache/spark/sql/execution/datasources/parquet/Spark32HoodieParquetFileFormat.scala
index 351203ca58..ccd93b6fd3 100644
--- a/hudi-spark-datasource/hudi-spark3/src/main/scala/org/apache/spark/sql/execution/datasources/parquet/Spark32HoodieParquetFileFormat.scala
+++ b/hudi-spark-datasource/hudi-spark3/src/main/scala/org/apache/spark/sql/execution/datasources/parquet/Spark32HoodieParquetFileFormat.scala
@@ -411,8 +411,11 @@ object Spark32HoodieParquetFileFormat {
.asInstanceOf[ParquetReadSupport]
}
- private def createVectorizedParquetRecordReader(args: Any*): VectorizedParquetRecordReader =
- ReflectionUtils.newInstanceUnchecked(classOf[VectorizedParquetRecordReader], args.map(_.asInstanceOf[AnyRef]): _*)
+ private def createVectorizedParquetRecordReader(args: Any*): VectorizedParquetRecordReader = {
+ val ctor = classOf[VectorizedParquetRecordReader].getConstructors.head
+ ctor.newInstance(args.map(_.asInstanceOf[AnyRef]): _*)
+ .asInstanceOf[VectorizedParquetRecordReader]
+ }
def pruneInternalSchema(internalSchemaStr: String, requiredSchema: StructType): String = {
val querySchemaOption = SerDeHelper.fromJson(internalSchemaStr)