This is an automated email from the ASF dual-hosted git repository.
yihua pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/hudi.git
The following commit(s) were added to refs/heads/master by this push:
new d2b50040418b feat: Use Storage from catalog table in drop table
command (#14390)
d2b50040418b is described below
commit d2b50040418bf79a96c05c73402e2b09a40644b4
Author: Shawn Chang <[email protected]>
AuthorDate: Sun Nov 30 21:08:26 2025 -0800
feat: Use Storage from catalog table in drop table command (#14390)
---
.../org/apache/spark/sql/hudi/command/DropHoodieTableCommand.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/command/DropHoodieTableCommand.scala
b/hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/spark/sql/hudi/command/DropHoodieTableCommand.scala
index 92cd4230c8d9..3c684b051d1b 100644
---
a/hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/spark/sql/hudi/command/DropHoodieTableCommand.scala
+++
b/hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/spark/sql/hudi/command/DropHoodieTableCommand.scala
@@ -86,9 +86,7 @@ case class DropHoodieTableCommand(
logInfo("Clean up " + basePath)
val targetPath = new StoragePath(basePath)
val engineContext = new
HoodieSparkEngineContext(sparkSession.sparkContext)
- val storage = HoodieStorageUtils.getStorage(basePath,
-
HadoopFSUtils.getStorageConf(sparkSession.sparkContext.hadoopConfiguration))
- FSUtils.deleteDir(engineContext, storage, targetPath,
sparkSession.sparkContext.defaultParallelism)
+ FSUtils.deleteDir(engineContext, hoodieCatalogTable.storage, targetPath,
sparkSession.sparkContext.defaultParallelism)
}
}