This is an automated email from the ASF dual-hosted git repository.
yiguolei pushed a commit to branch branch-4.0
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-4.0 by this push:
new f6b583c5db9 branch-4.0: [fix](sql cache) fix failed test
external_table_p0/hive/test_hive_query_cache.groovy #56507 (#56789)
f6b583c5db9 is described below
commit f6b583c5db9a79c120b0263d04f44b887fa1d16b
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Sun Oct 12 16:06:49 2025 +0800
branch-4.0: [fix](sql cache) fix failed test
external_table_p0/hive/test_hive_query_cache.groovy #56507 (#56789)
Cherry-picked from #56507
Co-authored-by: 924060929 <[email protected]>
---
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]
