From 412758453f4b161114c3d413db3db50c1d06e21e Mon Sep 17 00:00:00 2001 From: 924060929 Date: Tue, 7 Jan 2025 15:54:16 +0800 Subject: [PATCH 1/2] fix --- .../org/apache/doris/common/cache/NereidsSqlCacheManager.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/fe/fe-core/src/main/java/org/apache/doris/common/cache/NereidsSqlCacheManager.java b/fe/fe-core/src/main/java/org/apache/doris/common/cache/NereidsSqlCacheManager.java index 2aca4d5f1efac7..bf82795450048a 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/common/cache/NereidsSqlCacheManager.java +++ b/fe/fe-core/src/main/java/org/apache/doris/common/cache/NereidsSqlCacheManager.java @@ -325,7 +325,7 @@ private boolean tablesOrDataChanged(Env env, SqlCacheContext sqlCacheContext) { // check table type and version for (Entry scanTable : sqlCacheContext.getUsedTables().entrySet()) { TableVersion tableVersion = scanTable.getValue(); - if (tableVersion.type != TableType.OLAP) { + if (tableVersion.type != TableType.OLAP && tableVersion.type != TableType.MATERIALIZED_VIEW) { return true; } TableIf tableIf = findTableIf(env, scanTable.getKey()); From f09c4a239cfadcd8b9ffde254a206c5711cd0c30 Mon Sep 17 00:00:00 2001 From: 924060929 Date: Tue, 7 Jan 2025 16:06:16 +0800 Subject: [PATCH 2/2] fix --- .../suites/mtmv_p0/test_mtmv_sql_cache_and_profile.groovy | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/regression-test/suites/mtmv_p0/test_mtmv_sql_cache_and_profile.groovy b/regression-test/suites/mtmv_p0/test_mtmv_sql_cache_and_profile.groovy index 02191f0d4cd7d4..846c42f138f3cf 100644 --- a/regression-test/suites/mtmv_p0/test_mtmv_sql_cache_and_profile.groovy +++ b/regression-test/suites/mtmv_p0/test_mtmv_sql_cache_and_profile.groovy @@ -63,12 +63,13 @@ suite("test_mtmv_sql_cache_and_profile", "mtmv") { waitingMTMVTaskFinished(jobName) sql """set enable_sql_cache=true;""" + sql "ADMIN SET FRONTEND CONFIG ('cache_last_version_interval_second' = '10')" + sleep(10 * 1000) long startTime = System.currentTimeMillis() long timeoutTimestamp = startTime + 5 * 60 * 1000 def explain_res = "" while (System.currentTimeMillis() < timeoutTimestamp) { - sleep(5 * 1000) sql """select k2 from ${mvName} group by k2;""" try { explain_res = sql """explain plan select k2 from ${mvName} group by k2;""" @@ -79,6 +80,7 @@ suite("test_mtmv_sql_cache_and_profile", "mtmv") { if (explain_res.toString().indexOf("LogicalSqlCache") != -1 || explain_res.toString().indexOf("PhysicalSqlCache") != -1) { break } + sleep(5 * 1000) } assertTrue(explain_res.toString().indexOf("LogicalSqlCache") != -1 || explain_res.toString().indexOf("PhysicalSqlCache") != -1)