From ecbad9526ae2c4531c00618f178fd34e10a21db3 Mon Sep 17 00:00:00 2001 From: Yann Byron Date: Sat, 29 Jan 2022 16:39:42 +0800 Subject: [PATCH] [HUDI-3253] preferred to use the table's own location (#4608) --- .../org/apache/spark/sql/hudi/HoodieSqlCommonUtils.scala | 4 +--- 1 file changed, 1 insertion(+), 3 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 d9180591c..a094e90b1 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 @@ -201,10 +201,8 @@ object HoodieSqlCommonUtils extends SparkAdapterSupport { } def getTableLocation(table: CatalogTable, sparkSession: SparkSession): String = { - val uri = if (table.tableType == CatalogTableType.MANAGED && isHoodieTable(table)) { + val uri = table.storage.locationUri.orElse { Some(sparkSession.sessionState.catalog.defaultTablePath(table.identifier)) - } else { - table.storage.locationUri } val conf = sparkSession.sessionState.newHadoopConf() uri.map(makePathQualified(_, conf))