diff --git a/paimon-core/src/main/java/org/apache/paimon/catalog/CachingCatalog.java b/paimon-core/src/main/java/org/apache/paimon/catalog/CachingCatalog.java index eb1110bb78c0..1384cef0d61c 100644 --- a/paimon-core/src/main/java/org/apache/paimon/catalog/CachingCatalog.java +++ b/paimon-core/src/main/java/org/apache/paimon/catalog/CachingCatalog.java @@ -178,7 +178,8 @@ public void dropTable(Identifier identifier, boolean ignoreIfNotExists) // clear all branch tables of this table for (Identifier i : tableCache.asMap().keySet()) { - if (identifier.getTableName().equals(i.getTableName())) { + if (identifier.getTableName().equals(i.getTableName()) + && identifier.getDatabaseName().equals(i.getDatabaseName())) { tableCache.invalidate(i); } }