This is an automated email from the ASF dual-hosted git repository.
morrysnow pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/master by this push:
new a83c0ea56fb [fix](sql cache) fix failed test
external_table_p0/hive/test_hive_query_cache.groovy (#56507)
a83c0ea56fb is described below
commit a83c0ea56fb06697157fffd3fe3fedb0bf278661
Author: 924060929 <[email protected]>
AuthorDate: Fri Oct 10 15:23:20 2025 +0800
[fix](sql cache) fix failed test
external_table_p0/hive/test_hive_query_cache.groovy (#56507)
introduced by #55513
---
fe/fe-core/src/main/java/org/apache/doris/qe/ConnectProcessor.java | 6 ++++++
.../suites/external_table_p0/hive/test_hive_query_cache.groovy | 4 ++++
2 files changed, 10 insertions(+)
diff --git a/fe/fe-core/src/main/java/org/apache/doris/qe/ConnectProcessor.java
b/fe/fe-core/src/main/java/org/apache/doris/qe/ConnectProcessor.java
index 1f9e0bb49a0..5b8ea1dd1e2 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/qe/ConnectProcessor.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/qe/ConnectProcessor.java
@@ -406,6 +406,12 @@ public abstract class ConnectProcessor {
logicalPlanAdapter.setOrigStmt(statementContext.getOriginStatement());
logicalPlanAdapter.setUserInfo(ctx.getCurrentUserIdentity());
return ImmutableList.of(logicalPlanAdapter);
+ } else {
+ if
(!ctx.getSessionVariable().testQueryCacheHit.equals("none")) {
+ throw new UserException("The variable test_query_cache_hit
is set to "
+ +
ConnectContext.get().getSessionVariable().testQueryCacheHit
+ + ", but the query cache is not hit.");
+ }
}
} catch (Throwable t) {
LOG.warn("Parse from sql cache failed: " + t.getMessage(), t);
diff --git
a/regression-test/suites/external_table_p0/hive/test_hive_query_cache.groovy
b/regression-test/suites/external_table_p0/hive/test_hive_query_cache.groovy
index 3676903b2bd..7faaaa83516 100644
--- a/regression-test/suites/external_table_p0/hive/test_hive_query_cache.groovy
+++ b/regression-test/suites/external_table_p0/hive/test_hive_query_cache.groovy
@@ -72,6 +72,7 @@ suite("test_hive_query_cache",
"p0,external,hive,external_docker,external_docker
sql """set enable_fallback_to_original_planner=false"""
sql """set enable_sql_cache=false;"""
+ sql """set enable_hive_sql_cache=false"""
def tpch_1sf_q09 = """
select
@@ -113,6 +114,7 @@ suite("test_hive_query_cache",
"p0,external,hive,external_docker,external_docker
// test sql cache with empty result
try {
sql """set enable_sql_cache=true;"""
+ sql """set enable_hive_sql_cache=true"""
sql """set test_query_cache_hit="none";"""
sql """select * from lineitem where l_suppkey="abc";""" // non
exist l_suppkey;
sql """select * from lineitem where l_suppkey="abc";"""
@@ -124,6 +126,7 @@ suite("test_hive_query_cache",
"p0,external,hive,external_docker,external_docker
// test more sql cache
sql """use `default`"""
sql """set enable_sql_cache=true;"""
+ sql """set enable_hive_sql_cache=true"""
sql """set test_query_cache_hit="none";"""
// 1. first query, because we need to init the schema of
table_with_x01 to update the table's update time
// then sleep 2 seconds to wait longer than
Config.cache_last_version_interval_second,
@@ -139,6 +142,7 @@ suite("test_hive_query_cache",
"p0,external,hive,external_docker,external_docker
// test not hit
try {
sql """set enable_sql_cache=true;"""
+ sql """set enable_hive_sql_cache=true"""
sql """set test_query_cache_hit="sql";"""
def r = UUID.randomUUID().toString();
// using a random sql
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
