diff --git a/hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/DataSourceOptions.scala b/hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/DataSourceOptions.scala index aba86ed708e5..1825110bd1a4 100644 --- a/hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/DataSourceOptions.scala +++ b/hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/DataSourceOptions.scala @@ -964,10 +964,10 @@ object DataSourceOptionsHelper { def translateConfigurations(optParams: Map[String, String]): Map[String, String] = { val translatedOpt = scala.collection.mutable.Map[String, String]() ++= optParams - if (!translatedOpt.contains(HoodieTableConfig.HOODIE_TABLE_NAME_KEY) && - translatedOpt.contains(HoodieTableConfig.HOODIE_WRITE_TABLE_NAME_KEY)) { - translatedOpt.put(HoodieTableConfig.HOODIE_TABLE_NAME_KEY, - translatedOpt(HoodieTableConfig.HOODIE_WRITE_TABLE_NAME_KEY)) + if (!translatedOpt.contains(HoodieTableConfig.NAME.key()) && + translatedOpt.contains(DataSourceWriteOptions.TABLE_NAME.key())) { + translatedOpt.put(HoodieTableConfig.NAME.key(), + translatedOpt(DataSourceWriteOptions.TABLE_NAME.key())) } optParams.keySet.foreach(opt => { if (allAlternatives.contains(opt) && !optParams.contains(allAlternatives(opt))) {