use configs instead of constants

apache · Apr 11, 2024 · e7e5139 · e7e5139
1 parent ea501ae
commit e7e5139
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/...spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/DataSourceOptions.scala b/...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))) {