This is an automated email from the ASF dual-hosted git repository.
morningman 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 9c9ee9c5a1a [fix](cloud) add load.groovy for cache cases (#33287)
9c9ee9c5a1a is described below
commit 9c9ee9c5a1a4d6ba96823fce48d1c01f112f474f
Author: Yongqiang YANG <[email protected]>
AuthorDate: Sun Apr 7 00:39:10 2024 +0800
[fix](cloud) add load.groovy for cache cases (#33287)
---
regression-test/suites/cloud_p0/cache/load.groovy | 57 +++++++++++++++++++++++
1 file changed, 57 insertions(+)
diff --git a/regression-test/suites/cloud_p0/cache/load.groovy
b/regression-test/suites/cloud_p0/cache/load.groovy
index 86836f69fec..8dc85541426 100644
--- a/regression-test/suites/cloud_p0/cache/load.groovy
+++ b/regression-test/suites/cloud_p0/cache/load.groovy
@@ -19,4 +19,61 @@ import org.codehaus.groovy.runtime.IOGroovyMethods
suite("load") {
sql """ set global enable_auto_analyze = false; """
+
+ def table = "customer"
+
+ def token = context.config.metaServiceToken;
+ def instance_id = context.config.multiClusterInstance
+
+ List<String> ipList = new ArrayList<>();
+ List<String> hbPortList = new ArrayList<>()
+ List<String> httpPortList = new ArrayList<>()
+ List<String> brpcPortList = new ArrayList<>()
+ List<String> beUniqueIdList = new ArrayList<>()
+
+ String[] bes = context.config.multiClusterBes.split(',');
+ println("the value is " + context.config.multiClusterBes);
+ int num = 0
+ for(String values : bes) {
+ if (num++ == 2) break;
+ println("the value is " + values);
+ String[] beInfo = values.split(':');
+ ipList.add(beInfo[0]);
+ hbPortList.add(beInfo[1]);
+ httpPortList.add(beInfo[2]);
+ beUniqueIdList.add(beInfo[3]);
+ brpcPortList.add(beInfo[4]);
+ }
+
+ println("the ip is " + ipList);
+ println("the heartbeat port is " + hbPortList);
+ println("the http port is " + httpPortList);
+ println("the be unique id is " + beUniqueIdList);
+ println("the brpc port is " + brpcPortList);
+
+ for (unique_id : beUniqueIdList) {
+ resp = get_cluster.call(unique_id);
+ for (cluster : resp) {
+ if (cluster.type == "COMPUTE") {
+ drop_cluster.call(cluster.cluster_name, cluster.cluster_id);
+ }
+ }
+ }
+ sleep(20000)
+
+ List<List<Object>> result = sql "show clusters"
+ assertEquals(result.size(), 0);
+
+ add_cluster.call(beUniqueIdList[0], ipList[0], hbPortList[0],
+ "regression_cluster_name0", "regression_cluster_id0");
+ add_cluster.call(beUniqueIdList[1], ipList[1], hbPortList[1],
+ "regression_cluster_name1", "regression_cluster_id1");
+ sleep(20000)
+
+ result = sql "show clusters"
+ sql """ SET PROPERTY 'default_cloud_cluster' = "regression_cluster_name0";
"""
+ assertEquals(result.size(), 2);
+ sql """ set global enable_auto_analyze = false; """
+ sql """ drop table if exists __internal_schema.column_statistics; """
+ sql """ drop table if exists __internal_schema.histogram_statistics; """
}
\ No newline at end of file
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
