This is an automated email from the ASF dual-hosted git repository.
dataroaring pushed a commit to branch branch-3.0
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-3.0 by this push:
new d7caf815d85 [fix](case) Fix profile case
adaptive_pipeline_task_serial_read_on_limit (#49667)
d7caf815d85 is described below
commit d7caf815d85f9eaaaa04ffd91b9f8e4a775da902
Author: zhiqiang <[email protected]>
AuthorDate: Thu May 29 15:53:08 2025 +0800
[fix](case) Fix profile case adaptive_pipeline_task_serial_read_on_limit
(#49667)
Fix case failed in multiple bes env.
---
...daptive_pipeline_task_serial_read_on_limit.groovy | 20 +++++++++++++++++++-
1 file changed, 19 insertions(+), 1 deletion(-)
diff --git
a/regression-test/suites/query_profile/adaptive_pipeline_task_serial_read_on_limit.groovy
b/regression-test/suites/query_profile/adaptive_pipeline_task_serial_read_on_limit.groovy
index 28d69734eba..f36e95f6546 100644
---
a/regression-test/suites/query_profile/adaptive_pipeline_task_serial_read_on_limit.groovy
+++
b/regression-test/suites/query_profile/adaptive_pipeline_task_serial_read_on_limit.groovy
@@ -58,6 +58,7 @@ def verifyProfileContent = { stmt, serialReadOnLimit ->
logger.error("Profile ID of ${stmt} is not found")
return false
}
+
// Get profile content by using getProfile
def String profileContent = getProfile(profileId).toString()
logger.info("Profile content of ${stmt} is\n${profileContent}")
@@ -65,11 +66,28 @@ def verifyProfileContent = { stmt, serialReadOnLimit ->
if (serialReadOnLimit) {
return profileContent.contains("- MaxScannerThreadNum: 1") == true
} else {
- return !profileContent.contains("- MaxScannerThreadNum: 1") == true
+ if (!(profileContent.contains("- MaxScannerThreadNum: 1"))) {
+ return true
+ }
+ // Split profileContext by using "\n"
+ // Count the number of lines that contains "MaxScannerThreadNum"
+ def lines = profileContent.split("\n")
+ def count = 0
+ for (def line : lines) {
+ if (line.contains("MaxScannerThreadNum")) {
+ count++
+ }
+ }
+ // For multiple backends, there should be more than one line that
contains "MaxScannerThreadNum".
+ return count > 1
}
}
suite('adaptive_pipeline_task_serial_read_on_limit') {
+ sql """
+ UNSET VARIABLE ALL;
+ """
+
sql """
DROP TABLE IF EXISTS adaptive_pipeline_task_serial_read_on_limit;
"""
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
