Skip to content

Commit bf0a868

Browse files
committed
Fixing Hive conf usage in HoodieSparkSqlWriter
1 parent 9e8664f commit bf0a868

1 file changed

Lines changed: 1 addition & 5 deletions

File tree

hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/HoodieSparkSqlWriter.scala

Lines changed: 1 addition & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -21,7 +21,6 @@ import org.apache.avro.Schema
2121
import org.apache.avro.generic.GenericRecord
2222
import org.apache.hadoop.conf.Configuration
2323
import org.apache.hadoop.fs.{FileSystem, Path}
24-
import org.apache.hadoop.hive.conf.HiveConf
2524
import org.apache.hudi.DataSourceWriteOptions._
2625
import org.apache.hudi.HoodieConversionUtils.toProperties
2726
import org.apache.hudi.HoodieWriterUtils._
@@ -619,11 +618,8 @@ object HoodieSparkSqlWriter {
619618
properties.put(HoodieSyncConfig.META_SYNC_SPARK_VERSION.key, SPARK_VERSION)
620619
properties.put(HoodieSyncConfig.META_SYNC_USE_FILE_LISTING_FROM_METADATA.key, hoodieConfig.getBoolean(HoodieMetadataConfig.ENABLE))
621620

622-
val hiveConf: HiveConf = new HiveConf()
623-
hiveConf.addResource(fs.getConf)
624-
625621
syncClientToolClassSet.foreach(impl => {
626-
SyncUtilHelpers.runHoodieMetaSync(impl.trim, properties, hiveConf, fs, basePath.toString, baseFileFormat)
622+
SyncUtilHelpers.runHoodieMetaSync(impl.trim, properties, fs.getConf, fs, basePath.toString, baseFileFormat)
627623
})
628624
}
629625
true

0 commit comments

Comments
 (0)