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)
     }
   }
 

Reply via email to