diff --git a/fluss-server/src/main/java/org/apache/fluss/server/coordinator/TableManager.java b/fluss-server/src/main/java/org/apache/fluss/server/coordinator/TableManager.java index 2381447bcb..c085cc42b0 100644 --- a/fluss-server/src/main/java/org/apache/fluss/server/coordinator/TableManager.java +++ b/fluss-server/src/main/java/org/apache/fluss/server/coordinator/TableManager.java @@ -272,8 +272,8 @@ private void resumePartitionDeletions() { private void completeDeleteTable(long tableId) { Set replicas = coordinatorContext.getAllReplicasForTable(tableId); replicaStateMachine.handleStateChanges(replicas, ReplicaState.NonExistentReplica); - asyncDeleteRemoteDirectory(tableId); asyncDeleteTableMetadata(tableId); + asyncDeleteRemoteDirectory(tableId); coordinatorContext.removeTable(tableId); // Release the manager's in-flight tracking so the next batch can be submitted. lifecycleThrottler.onTableDropCompleted(tableId); @@ -284,8 +284,8 @@ private void completeDeletePartition(TablePartition tablePartition) { coordinatorContext.getAllReplicasForPartition( tablePartition.getTableId(), tablePartition.getPartitionId()); replicaStateMachine.handleStateChanges(replicas, ReplicaState.NonExistentReplica); - asyncDeleteRemoteDirectory(tablePartition); asyncDeletePartitionMetadata(tablePartition.getPartitionId()); + asyncDeleteRemoteDirectory(tablePartition); coordinatorContext.removePartition(tablePartition); lifecycleThrottler.onPartitionDropCompleted(tablePartition); }