This is an automated email from the ASF dual-hosted git repository.
liaoxin 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 74eb6a0c42b [fix](regression-case) Fix case s3_load_profile_test, send
query to master FE (#60046)
74eb6a0c42b is described below
commit 74eb6a0c42bd86823696aa4a15f99d268125d7de
Author: Refrain <[email protected]>
AuthorDate: Fri Jan 23 09:51:13 2026 +0800
[fix](regression-case) Fix case s3_load_profile_test, send query to master
FE (#60046)
profile query should send to master Fe but not observe Fe
---
.../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]
