Skip to content

Commit 85f6ece

Browse files
committed
fix: prevent delete default database
1 parent 56dc6de commit 85f6ece

1 file changed

Lines changed: 6 additions & 0 deletions

File tree

fluss-server/src/main/java/org/apache/fluss/server/coordinator/MetadataManager.java

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -24,6 +24,7 @@
2424
import org.apache.fluss.exception.DatabaseNotExistException;
2525
import org.apache.fluss.exception.FlussRuntimeException;
2626
import org.apache.fluss.exception.InvalidAlterTableException;
27+
import org.apache.fluss.exception.InvalidDatabaseException;
2728
import org.apache.fluss.exception.InvalidPartitionException;
2829
import org.apache.fluss.exception.LakeTableAlreadyExistException;
2930
import org.apache.fluss.exception.PartitionAlreadyExistsException;
@@ -314,6 +315,11 @@ public Map<String, PartitionRegistration> listPartitions(
314315

315316
public void dropDatabase(String name, boolean ignoreIfNotExists, boolean cascade)
316317
throws DatabaseNotExistException, DatabaseNotEmptyException {
318+
if (CoordinatorServer.DEFAULT_DATABASE.equals(name)) {
319+
throw new UnsupportedOperationException(
320+
"Cannot drop the default database '" + name
321+
+ "'. The default database is required for cluster operation.");
322+
}
317323
if (!databaseExists(name)) {
318324
if (ignoreIfNotExists) {
319325
return;

0 commit comments

Comments
 (0)