This is an automated email from the ASF dual-hosted git repository.
yiguolei pushed a commit to branch branch-2.1
in repository https://gitbox.apache.org/repos/asf/doris.git
commit 31a03e7183c97ba3c7de1f9e7dbc1c13b4db6de4
Author: deardeng <565620...@qq.com>
AuthorDate: Mon Mar 4 20:30:43 2024 +0800
[fix](cloud) Fix regression case `test_nereids_row_policy` run in cloud
mode (#31726)
---
.../suites/account_p0/test_nereids_row_policy.groovy | 20 ++++++++++++++++++++
1 file changed, 20 insertions(+)
diff --git a/regression-test/suites/account_p0/test_nereids_row_policy.groovy
b/regression-test/suites/account_p0/test_nereids_row_policy.groovy
index 6104416f49a..c071d88306c 100644
--- a/regression-test/suites/account_p0/test_nereids_row_policy.groovy
+++ b/regression-test/suites/account_p0/test_nereids_row_policy.groovy
@@ -21,6 +21,18 @@ suite("test_nereids_row_policy") {
def user='row_policy_user'
def tokens = context.config.jdbcUrl.split('/')
def url=tokens[0] + "//" + tokens[2] + "/" + dbName + "?"
+ def isCloudMode = {
+ def ret = sql_return_maparray """show backends"""
+ ret.Tag[0].contains("cloud_cluster_name")
+ }
+ def cloudMode = isCloudMode.call()
+ //cloud-mode
+ if (cloudMode) {
+ def clusters = sql " SHOW CLUSTERS; "
+ assertTrue(!clusters.isEmpty())
+ def validCluster = clusters[0][0]
+ sql """GRANT USAGE_PRIV ON CLUSTER ${validCluster} TO ${user}""";
+ }
def assertQueryResult = { size ->
def result1 = connect(user=user, password='123abc!@#', url=url) {
@@ -83,6 +95,14 @@ suite("test_nereids_row_policy") {
sql 'sync'
+ //cloud-mode
+ if (cloudMode) {
+ def clusters = sql " SHOW CLUSTERS; "
+ assertTrue(!clusters.isEmpty())
+ def validCluster = clusters[0][0]
+ sql """GRANT USAGE_PRIV ON CLUSTER ${validCluster} TO ${user}""";
+ }
+
// no policy
assertQueryResult 3
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
