From 3f4ae002a8cf932dced6166353b7bdbe5b99354f Mon Sep 17 00:00:00 2001
From: Xin Liao <liaoxinbit@126.com>
Date: Wed, 13 Mar 2024 15:52:31 +0800
Subject: [PATCH] [fix](merge-cloud) fix no cluster for common user (#32097)

---
 .../tvf/test_insert_from_tvf_with_common_user.groovy      | 8 ++++++++
 .../suites/load_p0/stream_load/test_stream_load.groovy    | 8 ++++++++
 2 files changed, 16 insertions(+)

diff --git a/regression-test/suites/external_table_p0/tvf/test_insert_from_tvf_with_common_user.groovy b/regression-test/suites/external_table_p0/tvf/test_insert_from_tvf_with_common_user.groovy
index 1d76ee15f3..56cc6aa40c 100644
--- a/regression-test/suites/external_table_p0/tvf/test_insert_from_tvf_with_common_user.groovy
+++ b/regression-test/suites/external_table_p0/tvf/test_insert_from_tvf_with_common_user.groovy
@@ -88,6 +88,14 @@ suite("test_insert_from_tvf_with_common_user", "p0") {
     sql """create user ${common_user} identified by '12345'"""
     sql """GRANT SELECT_PRIV,LOAD_PRIV,ALTER_PRIV,CREATE_PRIV,DROP_PRIV ON *.*.* TO '${common_user}'@'%';"""
 
+     //cloud-mode
+    if (isCloudMode()) {
+        def clusters = sql " SHOW CLUSTERS; "
+        assertTrue(!clusters.isEmpty())
+        def validCluster = clusters[0][0]
+        sql """GRANT USAGE_PRIV ON CLUSTER ${validCluster} TO ${common_user}""";
+    }
+
     connect(user = "${common_user}", password = '12345', url = context.config.jdbcUrl) {
         sql """ use regression_test_external_table_p0_tvf """
 
diff --git a/regression-test/suites/load_p0/stream_load/test_stream_load.groovy b/regression-test/suites/load_p0/stream_load/test_stream_load.groovy
index 6c002b2d29..628fe278d5 100644
--- a/regression-test/suites/load_p0/stream_load/test_stream_load.groovy
+++ b/regression-test/suites/load_p0/stream_load/test_stream_load.groovy
@@ -1024,6 +1024,14 @@ suite("test_stream_load", "p0") {
     sql """create USER common_user@'%' IDENTIFIED BY '123456test!'"""
     sql """GRANT LOAD_PRIV ON *.* TO 'common_user'@'%';"""
 
+     //cloud-mode
+    if (isCloudMode()) {
+        def clusters = sql " SHOW CLUSTERS; "
+        assertTrue(!clusters.isEmpty())
+        def validCluster = clusters[0][0]
+        sql """GRANT USAGE_PRIV ON CLUSTER ${validCluster} TO common_user""";
+    }
+
     streamLoad {
         table "${tableName13}"