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 94ef7380036 branch-3.0: [case](auth)Fix test_dml_stream_load_auth
#54682 (#54836)
94ef7380036 is described below
commit 94ef7380036a5ed82d0c134e33dd42b9a04f68cc
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Fri Aug 15 21:22:02 2025 +0800
branch-3.0: [case](auth)Fix test_dml_stream_load_auth #54682 (#54836)
Cherry-picked from #54682
Co-authored-by: zhangdong <[email protected]>
---
.../auth_call/test_dml_stream_load_auth.groovy | 23 +++++++---------------
1 file changed, 7 insertions(+), 16 deletions(-)
diff --git a/regression-test/suites/auth_call/test_dml_stream_load_auth.groovy
b/regression-test/suites/auth_call/test_dml_stream_load_auth.groovy
index 8531a193da7..c0e7748fa3e 100644
--- a/regression-test/suites/auth_call/test_dml_stream_load_auth.groovy
+++ b/regression-test/suites/auth_call/test_dml_stream_load_auth.groovy
@@ -70,7 +70,7 @@ suite("test_dml_stream_load_auth","p0,auth_call") {
proc.consumeProcessOutput(sout, serr)
proc.waitForOrKill(7200000)
logger.info("std out: " + sout + "std err: " + serr)
- assertTrue(sout.toString().indexOf("Success") == -1)
+ assertTrue(sout.toString().indexOf("denied") != -1)
sql """grant load_priv on ${dbName}.${tableName} to ${user}"""
@@ -81,31 +81,22 @@ suite("test_dml_stream_load_auth","p0,auth_call") {
proc.consumeProcessOutput(sout, serr)
proc.waitForOrKill(7200000)
logger.info("std out: " + sout + "std err: " + serr)
- assertTrue(sout.toString().indexOf("Success") != -1)
-
- int pos1 = sout.indexOf("TxnId")
- int pos2 = sout.indexOf(",", pos1)
- int pos3 = sout.indexOf(":", pos1)
- def tsc_id = sout.substring(pos3+2, pos2)
+ assertTrue(sout.toString().indexOf("denied") == -1)
connect(user, "${pwd}", context.config.jdbcUrl) {
test {
- sql """SHOW TRANSACTION FROM ${dbName} WHERE ID=${tsc_id};"""
+ sql """SHOW TRANSACTION FROM ${dbName} WHERE ID=111;"""
exception "denied"
}
}
- def res = sql """select count() from ${dbName}.${tableName}"""
- assertTrue(res[0][0] == 3)
-
- def stream_res = sql """SHOW STREAM LOAD FROM ${dbName};"""
- logger.info("stream_res: " + stream_res)
-
sql """grant admin_priv on *.*.* to ${user}"""
connect(user, "${pwd}", context.config.jdbcUrl) {
- def transaction_res = sql """SHOW TRANSACTION FROM ${dbName} WHERE
ID=${tsc_id};"""
- assertTrue(transaction_res.size() == 1)
+ test {
+ sql """SHOW TRANSACTION FROM ${dbName} WHERE ID=111;"""
+ exception "exist"
+ }
}
sql """drop database if exists ${dbName}"""
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
