fix

apache · Jul 29, 2024 · 4ae1282 · 4ae1282
1 parent 2292abe
commit 4ae1282
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 8 deletions.
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
@@ -83,13 +83,6 @@ public CachingCatalog(Catalog wrapped, Duration expirationInterval, Ticker ticke
                         .build();
     }
 
-    @Override
-    public void createDatabase(String name, boolean ignoreIfExists, Map<String, String> properties)
-            throws DatabaseAlreadyExistException {
-        super.createDatabase(name, ignoreIfExists, properties);
-        databaseCache.put(name, properties);
-    }
-
     @Override
     public Map<String, String> loadDatabaseProperties(String databaseName)
             throws DatabaseNotExistException {

diff --git a/.../test/java/org/apache/paimon/flink/action/cdc/mysql/MySqlSyncDatabaseTableListITCase.java b/.../test/java/org/apache/paimon/flink/action/cdc/mysql/MySqlSyncDatabaseTableListITCase.java
@@ -45,7 +45,7 @@ public static void startContainers() {
     }
 
     @Test
-    @Timeout(120)
+    @Timeout(180)
     public void testActionRunResult() throws Exception {
         Map<String, String> mySqlConfig = getBasicMySqlConfig();
         mySqlConfig.put(