support drop partitioned table.
diff --git a/server/cluster/manager.go b/server/cluster/manager.go
index 61e9506..dee9e4c 100644
--- a/server/cluster/manager.go
+++ b/server/cluster/manager.go
@@ -306,6 +306,18 @@
return errors.WithMessage(err, "get table")
}
+ // If the table is partitioned, delete the table metadata directly.
+ if table.IsPartitioned() {
+ _, err = cluster.metadata.DropTableMetadata(ctx,
+ schemaName,
+ tableName,
+ )
+ if err != nil {
+ return errors.WithMessage(err, "cluster drop table")
+ }
+ return nil
+ }
+
getShardNodeResult, err := cluster.metadata.GetShardNodeByTableIDs([]storage.TableID{table.ID})
if err != nil {
return errors.WithMessage(err, "get shard node by tableID")
