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 afb85a59e09 branch-4.0: [fix](regression-case) Fix case
s3_load_profile_test, send query to master FE #60046 (#60161)
afb85a59e09 is described below
commit afb85a59e098112e32ffb38d94a5e1f70e7e0a0c
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Fri Jan 23 16:50:23 2026 +0800
branch-4.0: [fix](regression-case) Fix case s3_load_profile_test, send
query to master FE #60046 (#60161)
Cherry-picked from #60046
Co-authored-by: Refrain <[email protected]>
---
.../suites/query_profile/s3_load_profile_test.groovy | 16 ++++++++++++++--
1 file changed, 14 insertions(+), 2 deletions(-)
diff --git a/regression-test/suites/query_profile/s3_load_profile_test.groovy
b/regression-test/suites/query_profile/s3_load_profile_test.groovy
index ce71c49d7b9..9692efde734 100644
--- a/regression-test/suites/query_profile/s3_load_profile_test.groovy
+++ b/regression-test/suites/query_profile/s3_load_profile_test.groovy
@@ -18,6 +18,16 @@
import groovy.json.JsonSlurper
import org.apache.doris.regression.action.ProfileAction
+def getProfile = { masterHTTPAddr, id ->
+ def dst = 'http://' + masterHTTPAddr
+ def conn = new URL(dst +
"/api/profile/text/?query_id=$id").openConnection()
+ conn.setRequestMethod("GET")
+ def encoding =
Base64.getEncoder().encodeToString((context.config.feHttpUser + ":" +
+ (context.config.feHttpPassword == null ? "" :
context.config.feHttpPassword)).getBytes("UTF-8"))
+ conn.setRequestProperty("Authorization", "Basic ${encoding}")
+ return conn.getInputStream().getText()
+}
+
// ref
https://github.com/apache/doris/blob/3525a03815814f66ec78aa2ad6bbd9225b0e7a6b/regression-test/suites/load_p0/broker_load/test_s3_load.groovy
suite('s3_load_profile_test') {
sql "set enable_profile=true;"
@@ -181,11 +191,13 @@ PROPERTIES (
break
}
}
+ if (masterIP == "" || masterHTTPPort == "") {
+ assertTrue(false, "Cannot find master FE from show frontends result:
$allFrontends")
+ }
def masterAddress = masterIP + ":" + masterHTTPPort
logger.info("masterIP:masterHTTPPort is:${masterAddress}")
- def profileAction = new ProfileAction(context)
- def profileString = profileAction.getProfile(jobId.toString())
+ def profileString = getProfile(masterAddress, jobId.toString())
logger.info("profileDataString:" + profileString)
assertTrue(profileString.contains("NumScanners"))
assertTrue(profileString.contains("RowsProduced"))
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
