This is an automated email from the ASF dual-hosted git repository.
morrysnow pushed a commit to branch branch-3.1
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-3.1 by this push:
new df5744faf42 branch-3.1: [Fix](case) try fix
test_warmup_delay_compaction_query_tolerance #56553 (#57499)
df5744faf42 is described below
commit df5744faf4276f07d2b114b26ddb71b82a11f0fe
Author: bobhan1 <[email protected]>
AuthorDate: Mon Nov 3 11:28:30 2025 +0800
branch-3.1: [Fix](case) try fix
test_warmup_delay_compaction_query_tolerance #56553 (#57499)
pick #56553
---
.../warmup/test_warmup_delay_compaction_query_tolerance.groovy | 9 +++++++--
1 file changed, 7 insertions(+), 2 deletions(-)
diff --git
a/regression-test/suites/cloud_p0/read_cluster_cache/warmup/test_warmup_delay_compaction_query_tolerance.groovy
b/regression-test/suites/cloud_p0/read_cluster_cache/warmup/test_warmup_delay_compaction_query_tolerance.groovy
index 3ce4ee58f4b..d8cacef24e3 100644
---
a/regression-test/suites/cloud_p0/read_cluster_cache/warmup/test_warmup_delay_compaction_query_tolerance.groovy
+++
b/regression-test/suites/cloud_p0/read_cluster_cache/warmup/test_warmup_delay_compaction_query_tolerance.groovy
@@ -237,6 +237,7 @@ suite('test_warmup_delay_compaction_query_tolerance',
'docker') {
sql """insert into test values (5, 5)"""
sql """insert into test values (6, 6)"""
sleep(3000)
+ sql "select * from test"
def tablets = sql_return_maparray """ show tablets from test; """
logger.info("tablets: " + tablets)
@@ -266,8 +267,8 @@ suite('test_warmup_delay_compaction_query_tolerance',
'docker') {
waitForBrpcMetricValue(be.ip, be.rpc_port,
"file_cache_warm_up_rowset_wait_for_compaction_num", 1, /*timeout*/10000)
logFileCacheDownloadMetrics(clusterName2)
logWarmUpRowsetMetrics(clusterName2)
- assertEquals(num_submitted + 1, getBrpcMetrics(be.ip, be.rpc_port,
"file_cache_event_driven_warm_up_submitted_segment_num"))
- assertEquals(num_finished, getBrpcMetrics(be.ip, be.rpc_port,
"file_cache_event_driven_warm_up_finished_segment_num"))
+ assert num_submitted + 1 == getBrpcMetrics(be.ip, be.rpc_port,
"file_cache_event_driven_warm_up_submitted_segment_num")
+ assert num_finished == getBrpcMetrics(be.ip, be.rpc_port,
"file_cache_event_driven_warm_up_finished_segment_num")
// a new insert will trigger the sync rowset operation in the
following query
@@ -307,6 +308,10 @@ suite('test_warmup_delay_compaction_query_tolerance',
'docker') {
logWarmUpRowsetMetrics(clusterName2)
future.get()
+
+ sleep(1000)
+ logFileCacheDownloadMetrics(clusterName2)
+ logWarmUpRowsetMetrics(clusterName2)
assert num_finished + 2 == getBrpcMetrics(be.ip, be.rpc_port,
"file_cache_event_driven_warm_up_finished_segment_num")
assert 0 == getBrpcMetrics(be.ip, be.rpc_port,
"file_cache_warm_up_rowset_wait_for_compaction_timeout_num")
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
