You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@doris.apache.org by ai...@apache.org on 2025/11/07 03:09:29 UTC
(doris) branch master updated: [fix](case) catch profile HTTP request failure to avoid flaky test (#57678)
This is an automated email from the ASF dual-hosted git repository.
airborne 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 ab0ef01f22d [fix](case) catch profile HTTP request failure to avoid flaky test (#57678)
ab0ef01f22d is described below
commit ab0ef01f22daac2babba90bb6f3b0e6853429d96
Author: zzzxl <ya...@selectdb.com>
AuthorDate: Fri Nov 7 11:09:21 2025 +0800
[fix](case) catch profile HTTP request failure to avoid flaky test (#57678)
---
.../test_inverted_index_io_timer.groovy | 48 +++++++++++++---------
1 file changed, 28 insertions(+), 20 deletions(-)
diff --git a/regression-test/suites/inverted_index_p0/test_inverted_index_io_timer.groovy b/regression-test/suites/inverted_index_p0/test_inverted_index_io_timer.groovy
index 54f9c25f8a0..43bbe78ba12 100644
--- a/regression-test/suites/inverted_index_p0/test_inverted_index_io_timer.groovy
+++ b/regression-test/suites/inverted_index_p0/test_inverted_index_io_timer.groovy
@@ -103,29 +103,37 @@ suite('test_inverted_index_io_timer', 'p0') {
// Execute query with inverted index using profile
def queryId = "test_inverted_index_io_timer_${System.currentTimeMillis()}"
- profile("${queryId}") {
- run {
- sql "/* ${queryId} */ select * from ${indexTbName1} where request match 'images' order by `@timestamp` limit 10"
- }
-
- check { profileString, exception ->
- def local = 0
- def remote = 0
-
- def localMatcher = Pattern.compile("InvertedIndexNumLocalIOTotal:\\s*(\\d+)").matcher(profileString)
- if (localMatcher.find()) {
- local = Integer.parseInt(localMatcher.group(1))
- log.info("InvertedIndexNumLocalIOTotal: {}", local)
+ try {
+ profile("${queryId}") {
+ run {
+ sql "/* ${queryId} */ select * from ${indexTbName1} where request match 'images' order by `@timestamp` limit 10"
}
+
+ check { profileString, exception ->
+ def local = 0
+ def remote = 0
- def remoteMatcher = Pattern.compile("InvertedIndexNumRemoteIOTotal:\\s*(\\d+)").matcher(profileString)
- if (remoteMatcher.find()) {
- remote = Integer.parseInt(remoteMatcher.group(1))
- log.info("InvertedIndexNumRemoteIOTotal: {}", remote)
- }
+ def localMatcher = Pattern.compile("InvertedIndexNumLocalIOTotal:\\s*(\\d+)").matcher(profileString)
+ if (localMatcher.find()) {
+ local = Integer.parseInt(localMatcher.group(1))
+ log.info("InvertedIndexNumLocalIOTotal: {}", local)
+ }
- def total = local + remote
- assertTrue(total > 0, "InvertedIndexNumLocalIOTotal + InvertedIndexNumRemoteIOTotal should be > 0, got: ${total} (local=${local}, remote=${remote})")
+ def remoteMatcher = Pattern.compile("InvertedIndexNumRemoteIOTotal:\\s*(\\d+)").matcher(profileString)
+ if (remoteMatcher.find()) {
+ remote = Integer.parseInt(remoteMatcher.group(1))
+ log.info("InvertedIndexNumRemoteIOTotal: {}", remote)
+ }
+
+ def total = local + remote
+ assertTrue(total > 0, "InvertedIndexNumLocalIOTotal + InvertedIndexNumRemoteIOTotal should be > 0, got: ${total} (local=${local}, remote=${remote})")
+ }
+ }
+ } catch (IllegalStateException e) {
+ if (e.message?.contains("HttpCliAction failed")) {
+ log.warn("Profile HTTP request failed, skipping profile check: {}", e.message)
+ } else {
+ throw e
}
}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@doris.apache.org
For additional commands, e-mail: commits-help@doris.apache.org