From b05ebbbabbd03703f471ac417a449712676f41ec Mon Sep 17 00:00:00 2001 From: morningman Date: Thu, 25 Jul 2024 12:25:58 +0800 Subject: [PATCH] [fix](test) fix unstable refresh catalog/db ut --- .../test/java/org/apache/doris/catalog/RefreshDbTest.java | 3 +++ .../org/apache/doris/datasource/RefreshCatalogTest.java | 7 +++++-- 2 files changed, 8 insertions(+), 2 deletions(-) diff --git a/fe/fe-core/src/test/java/org/apache/doris/catalog/RefreshDbTest.java b/fe/fe-core/src/test/java/org/apache/doris/catalog/RefreshDbTest.java index fd920e9632c481..fd7a6b1a24bdab 100644 --- a/fe/fe-core/src/test/java/org/apache/doris/catalog/RefreshDbTest.java +++ b/fe/fe-core/src/test/java/org/apache/doris/catalog/RefreshDbTest.java @@ -91,6 +91,9 @@ public void testRefreshDatabase() throws Exception { } long l3 = db1.getLastUpdateTime(); Assertions.assertTrue(l3 == l2); + // when use_meta_cache is true, the table will be recreated after refresh. + // so we need to get table again + table = db1.getTable("tbl11").get(); Assertions.assertFalse(table.isObjectCreated()); test1.getDbNullable("db1").getTables(); Assertions.assertFalse(table.isObjectCreated()); diff --git a/fe/fe-core/src/test/java/org/apache/doris/datasource/RefreshCatalogTest.java b/fe/fe-core/src/test/java/org/apache/doris/datasource/RefreshCatalogTest.java index 87906261b24d82..34177f49382744 100644 --- a/fe/fe-core/src/test/java/org/apache/doris/datasource/RefreshCatalogTest.java +++ b/fe/fe-core/src/test/java/org/apache/doris/datasource/RefreshCatalogTest.java @@ -145,9 +145,12 @@ public void testRefreshCatalogLastUpdateTime() throws Exception { // not triggered init method long l3 = test2.getLastUpdateTime(); Assertions.assertTrue(l3 == l2); - // Assertions.assertFalse(table.isObjectCreated()); + // when use_meta_cache is true, the table will be recreated after refresh. + // so we need to get table again + table = (TestExternalTable) test2.getDbNullable("db1").getTable("tbl11").get(); + Assertions.assertFalse(table.isObjectCreated()); test2.getDbNullable("db1").getTables(); - // Assertions.assertFalse(table.isObjectCreated()); + Assertions.assertFalse(table.isObjectCreated()); try { DdlExecutor.execute(Env.getCurrentEnv(), refreshCatalogStmt); } catch (Exception e) {