Skip to content

Navigation Menu

Sign in
Appearance settings

Search code, repositories, users, issues, pull requests...

Provide feedback

We read every piece of feedback, and take your input very seriously.

Saved searches

Use saved searches to filter your results more quickly

Appearance settings

Commit 1320116

Browse filesBrowse files
authored
[fix](cache) fix mtmv cache can not use test (#46537)
fix mtmv can not use sql cache, introduced by #46443
1 parent 95d7d88 commit 1320116
Copy full SHA for 1320116

File tree

2 files changed

+4
-2
lines changed
Filter options

2 files changed

+4
-2
lines changed

‎fe/fe-core/src/main/java/org/apache/doris/common/cache/NereidsSqlCacheManager.java

Copy file name to clipboardExpand all lines: fe/fe-core/src/main/java/org/apache/doris/common/cache/NereidsSqlCacheManager.java
+1-1Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -325,7 +325,7 @@ private boolean tablesOrDataChanged(Env env, SqlCacheContext sqlCacheContext) {
325325
// check table type and version
326326
for (Entry<FullTableName, TableVersion> scanTable : sqlCacheContext.getUsedTables().entrySet()) {
327327
TableVersion tableVersion = scanTable.getValue();
328-
if (tableVersion.type != TableType.OLAP) {
328+
if (tableVersion.type != TableType.OLAP && tableVersion.type != TableType.MATERIALIZED_VIEW) {
329329
return true;
330330
}
331331
TableIf tableIf = findTableIf(env, scanTable.getKey());

‎regression-test/suites/mtmv_p0/test_mtmv_sql_cache_and_profile.groovy

Copy file name to clipboardExpand all lines: regression-test/suites/mtmv_p0/test_mtmv_sql_cache_and_profile.groovy
+3-1Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -63,12 +63,13 @@ suite("test_mtmv_sql_cache_and_profile", "mtmv") {
6363
waitingMTMVTaskFinished(jobName)
6464

6565
sql """set enable_sql_cache=true;"""
66+
sql "ADMIN SET FRONTEND CONFIG ('cache_last_version_interval_second' = '10')"
67+
sleep(10 * 1000)
6668

6769
long startTime = System.currentTimeMillis()
6870
long timeoutTimestamp = startTime + 5 * 60 * 1000
6971
def explain_res = ""
7072
while (System.currentTimeMillis() < timeoutTimestamp) {
71-
sleep(5 * 1000)
7273
sql """select k2 from ${mvName} group by k2;"""
7374
try {
7475
explain_res = sql """explain plan select k2 from ${mvName} group by k2;"""
@@ -79,6 +80,7 @@ suite("test_mtmv_sql_cache_and_profile", "mtmv") {
7980
if (explain_res.toString().indexOf("LogicalSqlCache") != -1 || explain_res.toString().indexOf("PhysicalSqlCache") != -1) {
8081
break
8182
}
83+
sleep(5 * 1000)
8284
}
8385
assertTrue(explain_res.toString().indexOf("LogicalSqlCache") != -1 || explain_res.toString().indexOf("PhysicalSqlCache") != -1)
8486

0 commit comments

Comments
0 (0)
Morty Proxy This is a proxified and sanitized view of the page, visit original site.