diff --git a/hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/BaseFileOnlyRelation.scala b/hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/BaseFileOnlyRelation.scala index 65bb8881455a4..aa1209e67fa1d 100644 --- a/hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/BaseFileOnlyRelation.scala +++ b/hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/BaseFileOnlyRelation.scala @@ -77,14 +77,6 @@ case class BaseFileOnlyRelation(override val sqlContext: SQLContext, override def updatePrunedDataSchema(prunedSchema: StructType): Relation = this.copy(prunedDataSchema = Some(prunedSchema)) - override def imbueConfigs(sqlContext: SQLContext): Unit = { - super.imbueConfigs(sqlContext) - // TODO Issue with setting this to true in spark 332 - if (HoodieSparkUtils.gteqSpark3_4 || !HoodieSparkUtils.gteqSpark3_3_2) { - sqlContext.sparkSession.sessionState.conf.setConfString("spark.sql.parquet.enableVectorizedReader", "true") - } - } - protected override def composeRDD(fileSplits: Seq[HoodieBaseFileSplit], tableSchema: HoodieTableSchema, requiredSchema: HoodieTableSchema, diff --git a/hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/HoodieBootstrapMORRelation.scala b/hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/HoodieBootstrapMORRelation.scala index 94f8cbfc433f2..d7d24577ba53c 100644 --- a/hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/HoodieBootstrapMORRelation.scala +++ b/hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/HoodieBootstrapMORRelation.scala @@ -67,12 +67,6 @@ case class HoodieBootstrapMORRelation(override val sqlContext: SQLContext, override lazy val mandatoryFields: Seq[String] = mandatoryFieldsForMerging - override def imbueConfigs(sqlContext: SQLContext): Unit = { - super.imbueConfigs(sqlContext) - sqlContext.sparkSession.sessionState.conf.setConfString("spark.sql.parquet.enableVectorizedReader", "true") - } - - protected override def getFileSlices(partitionFilters: Seq[Expression], dataFilters: Seq[Expression]): Seq[FileSlice] = { if (globPaths.isEmpty) { fileIndex.listFileSlices(HoodieFileIndex.