This is an automated email from the ASF dual-hosted git repository.
dataroaring 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 d7203657e00 [fix(cloud-merge) Modify the cluster name in ttl test
(#33279)
d7203657e00 is described below
commit d7203657e00dc2d9fc1373b79433320864014a6b
Author: Lightman <31928846+lchangli...@users.noreply.github.com>
AuthorDate: Sat Apr 6 14:53:14 2024 +0800
[fix(cloud-merge) Modify the cluster name in ttl test (#33279)
---
.../data/cloud_p0/cache/ttl/test_show_ttl.out | 16 ++++++++++++++++
.../cloud_p0/cache/compaction/test_stale_rowset.groovy | 10 +++++-----
.../cloud_p0/cache/http/test_cache_metrics_format.groovy | 4 ++--
.../suites/cloud_p0/cache/http/test_clear_cache.groovy | 4 ++--
.../cloud_p0/cache/http/test_clear_cache_async.groovy | 4 ++--
.../suites/cloud_p0/cache/ttl/alter_ttl_1.groovy | 4 ++--
.../suites/cloud_p0/cache/ttl/alter_ttl_2.groovy | 4 ++--
.../suites/cloud_p0/cache/ttl/alter_ttl_3.groovy | 4 ++--
.../suites/cloud_p0/cache/ttl/alter_ttl_4.groovy | 4 ++--
.../suites/cloud_p0/cache/ttl/alter_ttl_error.groovy | 4 ++--
.../suites/cloud_p0/cache/ttl/alter_ttl_max_int64.groovy | 4 ++--
.../suites/cloud_p0/cache/ttl/alter_ttl_random.groovy | 4 ++--
.../suites/cloud_p0/cache/ttl/alter_ttl_seconds.groovy | 4 ++--
.../cloud_p0/cache/ttl/create_table_as_select.groovy | 4 ++--
.../suites/cloud_p0/cache/ttl/create_table_like.groovy | 4 ++--
.../suites/cloud_p0/cache/ttl/test_ttl.groovy | 4 ++--
.../suites/cloud_p0/cache/ttl/test_ttl_preempt.groovy | 4 ++--
17 files changed, 51 insertions(+), 35 deletions(-)
diff --git a/regression-test/data/cloud_p0/cache/ttl/test_show_ttl.out
b/regression-test/data/cloud_p0/cache/ttl/test_show_ttl.out
new file mode 100644
index 00000000000..e106e5c50ed
--- /dev/null
+++ b/regression-test/data/cloud_p0/cache/ttl/test_show_ttl.out
@@ -0,0 +1,16 @@
+-- This file is automatically generated. You should know what you did if you
want to edit this
+-- !test_show_ttl --
+0
+
+-- !test_show_ttl_2 --
+0
+
+-- !test_show_ttl_3 --
+customer_ttl CREATE TABLE `customer_ttl` (\n `C_CUSTKEY` INT NOT NULL,\n
`C_NAME` VARCHAR(25) NOT NULL,\n `C_ADDRESS` VARCHAR(40) NOT NULL,\n
`C_NATIONKEY` INT NOT NULL,\n `C_PHONE` CHAR(15) NOT NULL,\n `C_ACCTBAL`
DECIMAL(15, 2) NOT NULL,\n `C_MKTSEGMENT` CHAR(10) NOT NULL,\n `C_COMMENT`
VARCHAR(117) NOT NULL\n) ENGINE=OLAP\nDUPLICATE KEY(`C_CUSTKEY`,
`C_NAME`)\nCOMMENT 'OLAP'\nDISTRIBUTED BY HASH(`C_CUSTKEY`) BUCKETS
32\nPROPERTIES (\n"file_cache_ttl_seconds" = "300",\n"is_bein [...]
+
+-- !test_show_ttl_4 --
+0
+
+-- !test_show_ttl_5 --
+customer_ttl CREATE TABLE `customer_ttl` (\n `C_CUSTKEY` INT NOT NULL,\n
`C_NAME` VARCHAR(25) NOT NULL,\n `C_ADDRESS` VARCHAR(40) NOT NULL,\n
`C_NATIONKEY` INT NOT NULL,\n `C_PHONE` CHAR(15) NOT NULL,\n `C_ACCTBAL`
DECIMAL(15, 2) NOT NULL,\n `C_MKTSEGMENT` CHAR(10) NOT NULL,\n `C_COMMENT`
VARCHAR(117) NOT NULL\n) ENGINE=OLAP\nDUPLICATE KEY(`C_CUSTKEY`,
`C_NAME`)\nCOMMENT 'OLAP'\nDISTRIBUTED BY HASH(`C_CUSTKEY`) BUCKETS
32\nPROPERTIES (\n"file_cache_ttl_seconds" = "0",\n"is_being_ [...]
+
diff --git
a/regression-test/suites/cloud_p0/cache/compaction/test_stale_rowset.groovy
b/regression-test/suites/cloud_p0/cache/compaction/test_stale_rowset.groovy
index df62aeff41b..d5bc9fbadfc 100644
--- a/regression-test/suites/cloud_p0/cache/compaction/test_stale_rowset.groovy
+++ b/regression-test/suites/cloud_p0/cache/compaction/test_stale_rowset.groovy
@@ -18,7 +18,7 @@
import org.codehaus.groovy.runtime.IOGroovyMethods
suite("test_stale_rowset") {
- sql """ use @compute_cluster """
+ sql """ use @regression_cluster_name1 """
//BackendId,Cluster,IP,HeartbeatPort,BePort,HttpPort,BrpcPort,LastStartTime,LastHeartbeat,Alive,SystemDecommissioned,ClusterDecommissioned,TabletNum,DataUsedCapacity,AvailCapacity,TotalCapacity,UsedPct,MaxDiskUsedPct,Tag,ErrMsg,Version,Status
String[][] backends = sql """ show backends """
assertTrue(backends.size() > 0)
@@ -27,7 +27,7 @@ suite("test_stale_rowset") {
def backendId_to_backendHttpPort = [:]
def backendId_to_backendBrpcPort = [:]
for (String[] backend in backends) {
- if (backend[9].equals("true") &&
backend[19].contains("compute_cluster")) {
+ if (backend[9].equals("true") &&
backend[19].contains("regression_cluster_name1")) {
backendId_to_backendIP.put(backend[0], backend[1])
backendId_to_backendHttpPort.put(backend[0], backend[4])
backendId_to_backendBrpcPort.put(backend[0], backend[5])
@@ -117,7 +117,7 @@ suite("test_stale_rowset") {
def getCurCacheSize = {
backendIdToCacheSize = [:]
for (String[] backend in backends) {
- if (backend[9].equals("true") &&
backend[19].contains("compute_cluster")) {
+ if (backend[9].equals("true") &&
backend[19].contains("regression_cluster_name1")) {
StringBuilder sb = new StringBuilder();
sb.append("curl http://";)
sb.append(backendId_to_backendIP.get(backend[0]))
@@ -148,7 +148,7 @@ suite("test_stale_rowset") {
sleep(30000);
def backendIdToAfterLoadCacheSize = getCurCacheSize()
for (String[] backend in backends) {
- if (backend[9].equals("true") &&
backend[19].contains("compute_cluster")) {
+ if (backend[9].equals("true") &&
backend[19].contains("regression_cluster_name1")) {
logger.info(backend[0] + " size: " +
backendIdToAfterLoadCacheSize.get(backend[0]))
}
}
@@ -224,7 +224,7 @@ suite("test_stale_rowset") {
sleep(60000);
def backendIdToAfterCompactionCacheSize = getCurCacheSize()
for (String[] backend in backends) {
- if (backend[9].equals("true") &&
backend[19].contains("compute_cluster")) {
+ if (backend[9].equals("true") &&
backend[19].contains("regression_cluster_name1")) {
assertTrue(backendIdToAfterLoadCacheSize.get(backend[0]) >
backendIdToAfterCompactionCacheSize.get(backend[0]))
}
diff --git
a/regression-test/suites/cloud_p0/cache/http/test_cache_metrics_format.groovy
b/regression-test/suites/cloud_p0/cache/http/test_cache_metrics_format.groovy
index bbcabb7700f..7341c111a6b 100644
---
a/regression-test/suites/cloud_p0/cache/http/test_cache_metrics_format.groovy
+++
b/regression-test/suites/cloud_p0/cache/http/test_cache_metrics_format.groovy
@@ -19,14 +19,14 @@ import org.codehaus.groovy.runtime.IOGroovyMethods
suite("test_cache_metrics_format") {
def ttlProperties = """ PROPERTIES("file_cache_ttl_seconds"="180") """
- sql """ use @compute_cluster """
+ sql """ use @regression_cluster_name1 """
String[][] backends = sql """ show backends """
String backendId;
def backendIdToBackendIP = [:]
def backendIdToBackendHttpPort = [:]
def backendIdToBackendBrpcPort = [:]
for (String[] backend in backends) {
- if (backend[9].equals("true") &&
backend[19].contains("compute_cluster")) {
+ if (backend[9].equals("true") &&
backend[19].contains("regression_cluster_name1")) {
backendIdToBackendIP.put(backend[0], backend[1])
backendIdToBackendHttpPort.put(backend[0], backend[4])
backendIdToBackendBrpcPort.put(backend[0], backend[5])
diff --git a/regression-test/suites/cloud_p0/cache/http/test_clear_cache.groovy
b/regression-test/suites/cloud_p0/cache/http/test_clear_cache.groovy
index 659257b44a0..d7a8f641193 100644
--- a/regression-test/suites/cloud_p0/cache/http/test_clear_cache.groovy
+++ b/regression-test/suites/cloud_p0/cache/http/test_clear_cache.groovy
@@ -18,7 +18,7 @@
import org.codehaus.groovy.runtime.IOGroovyMethods
suite("test_clear_cache") {
- sql """ use @compute_cluster """
+ sql """ use @regression_cluster_name1 """
def ttlProperties = """ PROPERTIES("file_cache_ttl_seconds"="180") """
String[][] backends = sql """ show backends """
String backendId;
@@ -26,7 +26,7 @@ suite("test_clear_cache") {
def backendIdToBackendHttpPort = [:]
def backendIdToBackendBrpcPort = [:]
for (String[] backend in backends) {
- if (backend[9].equals("true") &&
backend[19].contains("compute_cluster")) {
+ if (backend[9].equals("true") &&
backend[19].contains("regression_cluster_name1")) {
backendIdToBackendIP.put(backend[0], backend[1])
backendIdToBackendHttpPort.put(backend[0], backend[4])
backendIdToBackendBrpcPort.put(backend[0], backend[5])
diff --git
a/regression-test/suites/cloud_p0/cache/http/test_clear_cache_async.groovy
b/regression-test/suites/cloud_p0/cache/http/test_clear_cache_async.groovy
index f53563e32b0..43e9482e0b9 100644
--- a/regression-test/suites/cloud_p0/cache/http/test_clear_cache_async.groovy
+++ b/regression-test/suites/cloud_p0/cache/http/test_clear_cache_async.groovy
@@ -18,7 +18,7 @@
import org.codehaus.groovy.runtime.IOGroovyMethods
suite("test_clear_cache_async") {
- sql """ use @compute_cluster """
+ sql """ use @regression_cluster_name1 """
sql """ set global enable_auto_analyze = false; """
def ttlProperties = """ PROPERTIES("file_cache_ttl_seconds"="180") """
String[][] backends = sql """ show backends """
@@ -27,7 +27,7 @@ suite("test_clear_cache_async") {
def backendIdToBackendHttpPort = [:]
def backendIdToBackendBrpcPort = [:]
for (String[] backend in backends) {
- if (backend[9].equals("true") &&
backend[19].contains("compute_cluster")) {
+ if (backend[9].equals("true") &&
backend[19].contains("regression_cluster_name1")) {
backendIdToBackendIP.put(backend[0], backend[1])
backendIdToBackendHttpPort.put(backend[0], backend[4])
backendIdToBackendBrpcPort.put(backend[0], backend[5])
diff --git a/regression-test/suites/cloud_p0/cache/ttl/alter_ttl_1.groovy
b/regression-test/suites/cloud_p0/cache/ttl/alter_ttl_1.groovy
index 195913ac3b7..26c03e6c3bd 100644
--- a/regression-test/suites/cloud_p0/cache/ttl/alter_ttl_1.groovy
+++ b/regression-test/suites/cloud_p0/cache/ttl/alter_ttl_1.groovy
@@ -18,7 +18,7 @@
import org.codehaus.groovy.runtime.IOGroovyMethods
suite("alter_ttl_1") {
- sql """ use @compute_cluster """
+ sql """ use @regression_cluster_name1 """
def ttlProperties = """ PROPERTIES("file_cache_ttl_seconds"="90") """
String[][] backends = sql """ show backends """
String backendId;
@@ -26,7 +26,7 @@ suite("alter_ttl_1") {
def backendIdToBackendHttpPort = [:]
def backendIdToBackendBrpcPort = [:]
for (String[] backend in backends) {
- if (backend[9].equals("true") &&
backend[19].contains("compute_cluster")) {
+ if (backend[9].equals("true") &&
backend[19].contains("regression_cluster_name1")) {
backendIdToBackendIP.put(backend[0], backend[1])
backendIdToBackendHttpPort.put(backend[0], backend[4])
backendIdToBackendBrpcPort.put(backend[0], backend[5])
diff --git a/regression-test/suites/cloud_p0/cache/ttl/alter_ttl_2.groovy
b/regression-test/suites/cloud_p0/cache/ttl/alter_ttl_2.groovy
index eb8d1a81ebd..c10d44bf7d8 100644
--- a/regression-test/suites/cloud_p0/cache/ttl/alter_ttl_2.groovy
+++ b/regression-test/suites/cloud_p0/cache/ttl/alter_ttl_2.groovy
@@ -18,7 +18,7 @@
import org.codehaus.groovy.runtime.IOGroovyMethods
suite("alter_ttl_2") {
- sql """ use @compute_cluster """
+ sql """ use @regression_cluster_name1 """
def ttlProperties = """ PROPERTIES("file_cache_ttl_seconds"="300") """
String[][] backends = sql """ show backends """
String backendId;
@@ -26,7 +26,7 @@ suite("alter_ttl_2") {
def backendIdToBackendHttpPort = [:]
def backendIdToBackendBrpcPort = [:]
for (String[] backend in backends) {
- if (backend[9].equals("true") &&
backend[19].contains("compute_cluster")) {
+ if (backend[9].equals("true") &&
backend[19].contains("regression_cluster_name1")) {
backendIdToBackendIP.put(backend[0], backend[1])
backendIdToBackendHttpPort.put(backend[0], backend[4])
backendIdToBackendBrpcPort.put(backend[0], backend[5])
diff --git a/regression-test/suites/cloud_p0/cache/ttl/alter_ttl_3.groovy
b/regression-test/suites/cloud_p0/cache/ttl/alter_ttl_3.groovy
index c746b4b50c2..bf88d07e9dd 100644
--- a/regression-test/suites/cloud_p0/cache/ttl/alter_ttl_3.groovy
+++ b/regression-test/suites/cloud_p0/cache/ttl/alter_ttl_3.groovy
@@ -18,7 +18,7 @@
import org.codehaus.groovy.runtime.IOGroovyMethods
suite("alter_ttl_3") {
- sql """ use @compute_cluster """
+ sql """ use @regression_cluster_name1 """
def ttlProperties = """ PROPERTIES("file_cache_ttl_seconds"="0") """
String[][] backends = sql """ show backends """
String backendId;
@@ -26,7 +26,7 @@ suite("alter_ttl_3") {
def backendIdToBackendHttpPort = [:]
def backendIdToBackendBrpcPort = [:]
for (String[] backend in backends) {
- if (backend[9].equals("true") &&
backend[19].contains("compute_cluster")) {
+ if (backend[9].equals("true") &&
backend[19].contains("regression_cluster_name1")) {
backendIdToBackendIP.put(backend[0], backend[1])
backendIdToBackendHttpPort.put(backend[0], backend[4])
backendIdToBackendBrpcPort.put(backend[0], backend[5])
diff --git a/regression-test/suites/cloud_p0/cache/ttl/alter_ttl_4.groovy
b/regression-test/suites/cloud_p0/cache/ttl/alter_ttl_4.groovy
index 0b25e3ca0a2..188bfd0a9cb 100644
--- a/regression-test/suites/cloud_p0/cache/ttl/alter_ttl_4.groovy
+++ b/regression-test/suites/cloud_p0/cache/ttl/alter_ttl_4.groovy
@@ -18,7 +18,7 @@
import org.codehaus.groovy.runtime.IOGroovyMethods
suite("alter_ttl_4") {
- sql """ use @compute_cluster """
+ sql """ use @regression_cluster_name1 """
def ttlProperties = """ PROPERTIES("file_cache_ttl_seconds"="0") """
String[][] backends = sql """ show backends """
String backendId;
@@ -26,7 +26,7 @@ suite("alter_ttl_4") {
def backendIdToBackendHttpPort = [:]
def backendIdToBackendBrpcPort = [:]
for (String[] backend in backends) {
- if (backend[9].equals("true") &&
backend[19].contains("compute_cluster")) {
+ if (backend[9].equals("true") &&
backend[19].contains("regression_cluster_name1")) {
backendIdToBackendIP.put(backend[0], backend[1])
backendIdToBackendHttpPort.put(backend[0], backend[4])
backendIdToBackendBrpcPort.put(backend[0], backend[5])
diff --git a/regression-test/suites/cloud_p0/cache/ttl/alter_ttl_error.groovy
b/regression-test/suites/cloud_p0/cache/ttl/alter_ttl_error.groovy
index 8ce9210d29d..3f7a94b4d00 100644
--- a/regression-test/suites/cloud_p0/cache/ttl/alter_ttl_error.groovy
+++ b/regression-test/suites/cloud_p0/cache/ttl/alter_ttl_error.groovy
@@ -18,7 +18,7 @@
import org.codehaus.groovy.runtime.IOGroovyMethods
suite("alter_ttl_error") {
- sql """ use @compute_cluster """
+ sql """ use @regression_cluster_name1 """
def ttlProperties = """ PROPERTIES("file_cache_ttl_seconds"="-1") """
String[][] backends = sql """ show backends """
String backendId;
@@ -26,7 +26,7 @@ suite("alter_ttl_error") {
def backendIdToBackendHttpPort = [:]
def backendIdToBackendBrpcPort = [:]
for (String[] backend in backends) {
- if (backend[9].equals("true") &&
backend[19].contains("compute_cluster")) {
+ if (backend[9].equals("true") &&
backend[19].contains("regression_cluster_name1")) {
backendIdToBackendIP.put(backend[0], backend[1])
backendIdToBackendHttpPort.put(backend[0], backend[4])
backendIdToBackendBrpcPort.put(backend[0], backend[5])
diff --git
a/regression-test/suites/cloud_p0/cache/ttl/alter_ttl_max_int64.groovy
b/regression-test/suites/cloud_p0/cache/ttl/alter_ttl_max_int64.groovy
index 6c3ca313d60..7910c04aeff 100644
--- a/regression-test/suites/cloud_p0/cache/ttl/alter_ttl_max_int64.groovy
+++ b/regression-test/suites/cloud_p0/cache/ttl/alter_ttl_max_int64.groovy
@@ -18,7 +18,7 @@
import org.codehaus.groovy.runtime.IOGroovyMethods
suite("test_ttl_max_int64") {
- sql """ use @compute_cluster """
+ sql """ use @regression_cluster_name1 """
def ttlProperties = """
PROPERTIES("file_cache_ttl_seconds"="9223372036854775807") """
String[][] backends = sql """ show backends """
String backendId;
@@ -26,7 +26,7 @@ suite("test_ttl_max_int64") {
def backendIdToBackendHttpPort = [:]
def backendIdToBackendBrpcPort = [:]
for (String[] backend in backends) {
- if (backend[9].equals("true") &&
backend[19].contains("compute_cluster")) {
+ if (backend[9].equals("true") &&
backend[19].contains("regression_cluster_name1")) {
backendIdToBackendIP.put(backend[0], backend[1])
backendIdToBackendHttpPort.put(backend[0], backend[4])
backendIdToBackendBrpcPort.put(backend[0], backend[5])
diff --git a/regression-test/suites/cloud_p0/cache/ttl/alter_ttl_random.groovy
b/regression-test/suites/cloud_p0/cache/ttl/alter_ttl_random.groovy
index 30598108133..fddeaf82f35 100644
--- a/regression-test/suites/cloud_p0/cache/ttl/alter_ttl_random.groovy
+++ b/regression-test/suites/cloud_p0/cache/ttl/alter_ttl_random.groovy
@@ -18,7 +18,7 @@
import org.codehaus.groovy.runtime.IOGroovyMethods
suite("test_ttl_random") {
- sql """ use @compute_cluster """
+ sql """ use @regression_cluster_name1 """
def ttlProperties = """ PROPERTIES("file_cache_ttl_seconds"="180") """
String[][] backends = sql """ show backends """
String backendId;
@@ -26,7 +26,7 @@ suite("test_ttl_random") {
def backendIdToBackendHttpPort = [:]
def backendIdToBackendBrpcPort = [:]
for (String[] backend in backends) {
- if (backend[9].equals("true") &&
backend[19].contains("compute_cluster")) {
+ if (backend[9].equals("true") &&
backend[19].contains("regression_cluster_name1")) {
backendIdToBackendIP.put(backend[0], backend[1])
backendIdToBackendHttpPort.put(backend[0], backend[4])
backendIdToBackendBrpcPort.put(backend[0], backend[5])
diff --git a/regression-test/suites/cloud_p0/cache/ttl/alter_ttl_seconds.groovy
b/regression-test/suites/cloud_p0/cache/ttl/alter_ttl_seconds.groovy
index 187246feb2a..993c12ce0ef 100644
--- a/regression-test/suites/cloud_p0/cache/ttl/alter_ttl_seconds.groovy
+++ b/regression-test/suites/cloud_p0/cache/ttl/alter_ttl_seconds.groovy
@@ -18,7 +18,7 @@
import org.codehaus.groovy.runtime.IOGroovyMethods
suite("test_ttl_seconds") {
- sql """ use @compute_cluster """
+ sql """ use @regression_cluster_name1 """
def ttlProperties = """ PROPERTIES("file_cache_ttl_seconds"="5") """
String[][] backends = sql """ show backends """
String backendId;
@@ -26,7 +26,7 @@ suite("test_ttl_seconds") {
def backendIdToBackendHttpPort = [:]
def backendIdToBackendBrpcPort = [:]
for (String[] backend in backends) {
- if (backend[9].equals("true") &&
backend[19].contains("compute_cluster")) {
+ if (backend[9].equals("true") &&
backend[19].contains("regression_cluster_name1")) {
backendIdToBackendIP.put(backend[0], backend[1])
backendIdToBackendHttpPort.put(backend[0], backend[4])
backendIdToBackendBrpcPort.put(backend[0], backend[5])
diff --git
a/regression-test/suites/cloud_p0/cache/ttl/create_table_as_select.groovy
b/regression-test/suites/cloud_p0/cache/ttl/create_table_as_select.groovy
index a4dea301ec5..bcfbab1e736 100644
--- a/regression-test/suites/cloud_p0/cache/ttl/create_table_as_select.groovy
+++ b/regression-test/suites/cloud_p0/cache/ttl/create_table_as_select.groovy
@@ -18,14 +18,14 @@
import org.codehaus.groovy.runtime.IOGroovyMethods
suite("create_table_as_select") {
- sql """ use @compute_cluster """
+ sql """ use @regression_cluster_name1 """
String[][] backends = sql """ show backends """
String backendId;
def backendIdToBackendIP = [:]
def backendIdToBackendHttpPort = [:]
def backendIdToBackendBrpcPort = [:]
for (String[] backend in backends) {
- if (backend[9].equals("true") &&
backend[19].contains("compute_cluster")) {
+ if (backend[9].equals("true") &&
backend[19].contains("regression_cluster_name1")) {
backendIdToBackendIP.put(backend[0], backend[1])
backendIdToBackendHttpPort.put(backend[0], backend[4])
backendIdToBackendBrpcPort.put(backend[0], backend[5])
diff --git a/regression-test/suites/cloud_p0/cache/ttl/create_table_like.groovy
b/regression-test/suites/cloud_p0/cache/ttl/create_table_like.groovy
index da5cee65b93..e23742ab425 100644
--- a/regression-test/suites/cloud_p0/cache/ttl/create_table_like.groovy
+++ b/regression-test/suites/cloud_p0/cache/ttl/create_table_like.groovy
@@ -18,14 +18,14 @@
import org.codehaus.groovy.runtime.IOGroovyMethods
suite("create_table_like") {
- sql """ use @compute_cluster """
+ sql """ use @regression_cluster_name1 """
String[][] backends = sql """ show backends """
String backendId;
def backendIdToBackendIP = [:]
def backendIdToBackendHttpPort = [:]
def backendIdToBackendBrpcPort = [:]
for (String[] backend in backends) {
- if (backend[9].equals("true") &&
backend[19].contains("compute_cluster")) {
+ if (backend[9].equals("true") &&
backend[19].contains("regression_cluster_name1")) {
backendIdToBackendIP.put(backend[0], backend[1])
backendIdToBackendHttpPort.put(backend[0], backend[4])
backendIdToBackendBrpcPort.put(backend[0], backend[5])
diff --git a/regression-test/suites/cloud_p0/cache/ttl/test_ttl.groovy
b/regression-test/suites/cloud_p0/cache/ttl/test_ttl.groovy
index 620cb2312e0..e5b796f45a7 100644
--- a/regression-test/suites/cloud_p0/cache/ttl/test_ttl.groovy
+++ b/regression-test/suites/cloud_p0/cache/ttl/test_ttl.groovy
@@ -18,7 +18,7 @@
import org.codehaus.groovy.runtime.IOGroovyMethods
suite("test_ttl") {
- sql """ use @compute_cluster """
+ sql """ use @regression_cluster_name1 """
def ttlProperties = """ PROPERTIES("file_cache_ttl_seconds"="180") """
String[][] backends = sql """ show backends """
String backendId;
@@ -26,7 +26,7 @@ suite("test_ttl") {
def backendIdToBackendHttpPort = [:]
def backendIdToBackendBrpcPort = [:]
for (String[] backend in backends) {
- if (backend[9].equals("true") &&
backend[19].contains("compute_cluster")) {
+ if (backend[9].equals("true") &&
backend[19].contains("regression_cluster_name1")) {
backendIdToBackendIP.put(backend[0], backend[1])
backendIdToBackendHttpPort.put(backend[0], backend[4])
backendIdToBackendBrpcPort.put(backend[0], backend[5])
diff --git a/regression-test/suites/cloud_p0/cache/ttl/test_ttl_preempt.groovy
b/regression-test/suites/cloud_p0/cache/ttl/test_ttl_preempt.groovy
index fdefb386e03..ce68cf24b2e 100644
--- a/regression-test/suites/cloud_p0/cache/ttl/test_ttl_preempt.groovy
+++ b/regression-test/suites/cloud_p0/cache/ttl/test_ttl_preempt.groovy
@@ -18,7 +18,7 @@
import org.codehaus.groovy.runtime.IOGroovyMethods
suite("test_ttl_preempt") {
- sql """ use @compute_cluster """
+ sql """ use @regression_cluster_name1 """
def ttlProperties = """ PROPERTIES("file_cache_ttl_seconds"="120") """
String[][] backends = sql """ show backends """
String backendId;
@@ -26,7 +26,7 @@ suite("test_ttl_preempt") {
def backendIdToBackendHttpPort = [:]
def backendIdToBackendBrpcPort = [:]
for (String[] backend in backends) {
- if (backend[9].equals("true") &&
backend[19].contains("compute_cluster")) {
+ if (backend[9].equals("true") &&
backend[19].contains("regression_cluster_name1")) {
backendIdToBackendIP.put(backend[0], backend[1])
backendIdToBackendHttpPort.put(backend[0], backend[4])
backendIdToBackendBrpcPort.put(backend[0], backend[5])
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
