From 053e3dc8edb136ebf4712ef1305838195c08645b Mon Sep 17 00:00:00 2001 From: xiaohongbo Date: Mon, 13 Jan 2025 13:43:44 +0800 Subject: [PATCH 1/2] [core] Fix invalidate tables with same tableNames in other db issue --- .../src/main/java/org/apache/paimon/catalog/CachingCatalog.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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..a55558bb2b56 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,7 @@ 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); } } From 28f000b0f7053b575a15be84954b40e1ea26959a Mon Sep 17 00:00:00 2001 From: xiaohongbo Date: Mon, 13 Jan 2025 13:56:01 +0800 Subject: [PATCH 2/2] [core] fix format --- .../main/java/org/apache/paimon/catalog/CachingCatalog.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) 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 a55558bb2b56..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()) && identifier.getDatabaseName().equals(i.getDatabaseName())) { + if (identifier.getTableName().equals(i.getTableName()) + && identifier.getDatabaseName().equals(i.getDatabaseName())) { tableCache.invalidate(i); } }