lanyuanxiaoyao/hudi
1
0
Fork 0
Code Activity

[HUDI-3253] preferred to use the table's own location (#4608)

Browse Source
This commit is contained in:
Yann Byron
2022-01-29 16:39:42 +08:00
committed by GitHub
parent ed7aa138e8
commit ecbad9526a
1 changed files with 1 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/spark/sql/hudi/HoodieSqlCommonUtils.scala
View File

@@ -201,10 +201,8 @@ object HoodieSqlCommonUtils extends SparkAdapterSupport {
} }
def getTableLocation(table: CatalogTable, sparkSession: SparkSession): String = { 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)) Some(sparkSession.sessionState.catalog.defaultTablePath(table.identifier))
} else {
table.storage.locationUri
} }
val conf = sparkSession.sessionState.newHadoopConf() val conf = sparkSession.sessionState.newHadoopConf()
uri.map(makePathQualified(_, conf)) uri.map(makePathQualified(_, conf))