This is an automated email from the ASF dual-hosted git repository. forwardxu pushed a commit to branch release-0.12.1 in repository https://gitbox.apache.org/repos/asf/hudi.git
commit 553bb9eab475a05bb91e150ced3dc9c18df1cd7e Author: XuQianJin-Stars <forwar...@apache.com> AuthorDate: Tue Aug 23 18:55:25 2022 +0800 [HUDI-4475] fix create table with not exists hoodie properties file --- .../main/scala/org/apache/spark/sql/hudi/HoodieSqlCommonUtils.scala | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/spark/sql/hudi/HoodieSqlCommonUtils.scala b/hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/spark/sql/hudi/HoodieSqlCommonUtils.scala index 025a224373..775f90dae1 100644 --- a/hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/spark/sql/hudi/HoodieSqlCommonUtils.scala +++ b/hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/spark/sql/hudi/HoodieSqlCommonUtils.scala @@ -24,7 +24,7 @@ import org.apache.hudi.common.config.{DFSPropertiesConfiguration, HoodieMetadata import org.apache.hudi.common.fs.FSUtils import org.apache.hudi.common.model.HoodieRecord import org.apache.hudi.common.table.timeline.{HoodieActiveTimeline, HoodieInstantTimeGenerator} -import org.apache.hudi.common.table.{HoodieTableMetaClient, TableSchemaResolver} +import org.apache.hudi.common.table.{HoodieTableConfig, HoodieTableMetaClient, TableSchemaResolver} import org.apache.hudi.common.util.PartitionPathEncodeUtils import org.apache.hudi.{AvroConversionUtils, DataSourceOptionsHelper, DataSourceReadOptions, SparkAdapterSupport} import org.apache.spark.api.java.JavaSparkContext @@ -227,7 +227,9 @@ object HoodieSqlCommonUtils extends SparkAdapterSupport { val basePath = new Path(tablePath) val fs = basePath.getFileSystem(conf) val metaPath = new Path(basePath, HoodieTableMetaClient.METAFOLDER_NAME) - fs.exists(metaPath) + val cfgPath = new Path(metaPath, HoodieTableConfig.HOODIE_PROPERTIES_FILE) + val backupCfgPath = new Path(metaPath, HoodieTableConfig.HOODIE_PROPERTIES_FILE_BACKUP) + fs.exists(metaPath) && (fs.exists(cfgPath) || fs.exists(backupCfgPath)) } /**