From 0cf2f103e07483f24b904b45f348bcc041e0c7ad Mon Sep 17 00:00:00 2001 From: Yann Byron Date: Wed, 24 Nov 2021 11:46:48 +0800 Subject: [PATCH] [HUDI-2838] refresh table after drop partition (#4084) --- .../sql/hudi/command/AlterHoodieTableDropPartitionCommand.scala | 1 + 1 file changed, 1 insertion(+) diff --git a/hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/AlterHoodieTableDropPartitionCommand.scala b/hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/AlterHoodieTableDropPartitionCommand.scala index f12f43d38..84e5961c4 100644 --- a/hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/AlterHoodieTableDropPartitionCommand.scala +++ b/hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/AlterHoodieTableDropPartitionCommand.scala @@ -59,6 +59,7 @@ extends RunnableCommand { parameters, sparkSession.emptyDataFrame) + sparkSession.catalog.refreshTable(tableIdentifier.unquotedString) Seq.empty[Row] }