This is an automated email from the ASF dual-hosted git repository.
yiguolei 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 05b7c65509 [fix](regression-test) fix multi-thread problem of
regression-test #20322
05b7c65509 is described below
commit 05b7c65509e5244f31ce5418693b231b1d47df28
Author: shuke <37901441+shuke...@users.noreply.github.com>
AuthorDate: Thu Jun 1 18:57:17 2023 +0800
[fix](regression-test) fix multi-thread problem of regression-test #20322
---
.../suites/compaction/test_compacation_with_delete.groovy | 8 ++++----
.../suites/compaction/test_compaction_agg_keys.groovy | 8 ++++----
.../compaction/test_compaction_agg_keys_with_delete.groovy | 8 ++++----
.../suites/compaction/test_compaction_dup_keys.groovy | 8 ++++----
.../compaction/test_compaction_dup_keys_with_delete.groovy | 8 ++++----
.../suites/compaction/test_compaction_uniq_keys.groovy | 10 +++++-----
.../compaction/test_compaction_uniq_keys_row_store.groovy | 8 ++++----
.../compaction/test_compaction_uniq_keys_with_delete.groovy | 8 ++++----
.../suites/compaction/test_vertical_compaction_agg_keys.groovy | 8 ++++----
.../suites/compaction/test_vertical_compaction_dup_keys.groovy | 8 ++++----
.../compaction/test_vertical_compaction_uniq_keys.groovy | 8 ++++----
.../suites/json_p0/test_json_load_and_function.groovy | 4 ++--
.../suites/jsonb_p0/test_jsonb_load_and_function.groovy | 4 ++--
.../load_p0/stream_load/test_map_load_and_compaction.groovy | 6 +++---
.../suites/schema_change/test_number_overflow.groovy | 2 +-
.../datev2/test_agg_keys_schema_change_datev2.groovy | 6 +++---
.../datev2/test_dup_keys_schema_change_datev2.groovy | 6 +++---
.../datev2/test_schema_change_varchar_to_datev2.groovy | 6 +++---
.../decimalv3/test_agg_keys_schema_change_decimalv3.groovy | 6 +++---
.../suites/schema_change_p0/test_agg_keys_schema_change.groovy | 6 +++---
.../suites/schema_change_p0/test_agg_mv_schema_change.groovy | 6 +++---
.../schema_change_p0/test_agg_rollup_schema_change.groovy | 6 +++---
.../suites/schema_change_p0/test_agg_vals_schema_change.groovy | 6 +++---
.../suites/schema_change_p0/test_dup_keys_schema_change.groovy | 6 +++---
.../suites/schema_change_p0/test_dup_mv_schema_change.groovy | 6 +++---
.../schema_change_p0/test_dup_rollup_schema_change.groovy | 6 +++---
.../suites/schema_change_p0/test_dup_vals_schema_change.groovy | 6 +++---
.../schema_change_p0/test_uniq_keys_schema_change.groovy | 6 +++---
.../suites/schema_change_p0/test_uniq_mv_schema_change.groovy | 6 +++---
.../schema_change_p0/test_uniq_rollup_schema_change.groovy | 6 +++---
.../schema_change_p0/test_uniq_vals_schema_change.groovy | 6 +++---
.../suites/schema_change_p0/test_varchar_schema_change.groovy | 6 +++---
.../suites/segcompaction_p2/test_segcompaction_agg_keys.groovy | 2 +-
.../segcompaction_p2/test_segcompaction_agg_keys_index.groovy | 2 +-
.../suites/segcompaction_p2/test_segcompaction_dup_keys.groovy | 2 +-
.../segcompaction_p2/test_segcompaction_dup_keys_index.groovy | 2 +-
.../segcompaction_p2/test_segcompaction_unique_keys.groovy | 2 +-
.../test_segcompaction_unique_keys_index.groovy | 2 +-
.../segcompaction_p2/test_segcompaction_unique_keys_mow.groovy | 2 +-
.../test_segcompaction_unique_keys_mow_index.groovy | 2 +-
40 files changed, 112 insertions(+), 112 deletions(-)
diff --git
a/regression-test/suites/compaction/test_compacation_with_delete.groovy
b/regression-test/suites/compaction/test_compacation_with_delete.groovy
index e9a05e0efb..426abed9a4 100644
--- a/regression-test/suites/compaction/test_compacation_with_delete.groovy
+++ b/regression-test/suites/compaction/test_compacation_with_delete.groovy
@@ -27,7 +27,7 @@ suite("test_compaction_with_delete") {
getBackendIpHttpPort(backendId_to_backendIP,
backendId_to_backendHttpPort);
backend_id = backendId_to_backendIP.keySet()[0]
- (code, out, err) =
show_be_config(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id))
+ def (code, out, err) =
show_be_config(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id))
logger.info("Show config: code=" + code + ", out=" + out + ", err=" +
err)
assertEquals(code, 0)
def configList = parseJson(out.trim())
@@ -102,7 +102,7 @@ suite("test_compaction_with_delete") {
for (String[] tablet in tablets) {
String tablet_id = tablet[0]
backend_id = tablet[2]
- (code, out, err) =
be_run_cumulative_compaction(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id), tablet_id)
+ def (code, out, err) =
be_run_cumulative_compaction(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id), tablet_id)
logger.info("Run compaction: code=" + code + ", out=" + out + ",
err=" + err)
assertEquals(code, 0)
def compactJson = parseJson(out.trim())
@@ -122,7 +122,7 @@ suite("test_compaction_with_delete") {
Thread.sleep(1000)
String tablet_id = tablet[0]
backend_id = tablet[2]
- (code, out, err) =
be_get_compaction_status(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id), tablet_id)
+ def (code, out, err) =
be_get_compaction_status(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id), tablet_id)
logger.info("Get compaction status: code=" + code + ", out=" +
out + ", err=" + err)
assertEquals(code, 0)
def compactionStatus = parseJson(out.trim())
@@ -135,7 +135,7 @@ suite("test_compaction_with_delete") {
for (String[] tablet in tablets) {
String tablet_id = tablet[0]
def compactionStatusUrlIndex = 18
- (code, out, err) = curl("GET", tablet[compactionStatusUrlIndex])
+ def (code, out, err) = curl("GET",
tablet[compactionStatusUrlIndex])
logger.info("Show tablets status: code=" + code + ", out=" + out +
", err=" + err)
assertEquals(code, 0)
def tabletJson = parseJson(out.trim())
diff --git a/regression-test/suites/compaction/test_compaction_agg_keys.groovy
b/regression-test/suites/compaction/test_compaction_agg_keys.groovy
index 4b2397a027..74dbb3ac4c 100644
--- a/regression-test/suites/compaction/test_compaction_agg_keys.groovy
+++ b/regression-test/suites/compaction/test_compaction_agg_keys.groovy
@@ -27,7 +27,7 @@ suite("test_compaction_agg_keys") {
getBackendIpHttpPort(backendId_to_backendIP,
backendId_to_backendHttpPort);
backend_id = backendId_to_backendIP.keySet()[0]
- (code, out, err) =
show_be_config(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id))
+ def (code, out, err) =
show_be_config(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id))
logger.info("Show config: code=" + code + ", out=" + out + ", err=" +
err)
assertEquals(code, 0)
def configList = parseJson(out.trim())
@@ -107,7 +107,7 @@ suite("test_compaction_agg_keys") {
for (String[] tablet in tablets) {
String tablet_id = tablet[0]
backend_id = tablet[2]
- (code, out, err) =
be_run_cumulative_compaction(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id), tablet_id)
+ def (code, out, err) =
be_run_cumulative_compaction(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id), tablet_id)
logger.info("Run compaction: code=" + code + ", out=" + out + ",
err=" + err)
assertEquals(code, 0)
def compactJson = parseJson(out.trim())
@@ -127,7 +127,7 @@ suite("test_compaction_agg_keys") {
Thread.sleep(1000)
String tablet_id = tablet[0]
backend_id = tablet[2]
- (code, out, err) =
be_get_compaction_status(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id), tablet_id)
+ def (code, out, err) =
be_get_compaction_status(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id), tablet_id)
logger.info("Get compaction status: code=" + code + ", out=" +
out + ", err=" + err)
assertEquals(code, 0)
@@ -142,7 +142,7 @@ suite("test_compaction_agg_keys") {
String tablet_id = tablet[0]
def compactionStatusUrlIndex = 18
- (code, out, err) = curl("GET", tablet[compactionStatusUrlIndex])
+ def (code, out, err) = curl("GET",
tablet[compactionStatusUrlIndex])
logger.info("Show tablets status: code=" + code + ", out=" + out +
", err=" + err)
assertEquals(code, 0)
diff --git
a/regression-test/suites/compaction/test_compaction_agg_keys_with_delete.groovy
b/regression-test/suites/compaction/test_compaction_agg_keys_with_delete.groovy
index f463269034..b1939ee473 100644
---
a/regression-test/suites/compaction/test_compaction_agg_keys_with_delete.groovy
+++
b/regression-test/suites/compaction/test_compaction_agg_keys_with_delete.groovy
@@ -26,7 +26,7 @@ suite("test_compaction_agg_keys_with_delete") {
def backendId_to_backendHttpPort = [:]
getBackendIpHttpPort(backendId_to_backendIP,
backendId_to_backendHttpPort);
backend_id = backendId_to_backendIP.keySet()[0]
- (code, out, err) =
show_be_config(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id))
+ def (code, out, err) =
show_be_config(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id))
logger.info("Show config: code=" + code + ", out=" + out + ", err=" +
err)
assertEquals(code, 0)
def configList = parseJson(out.trim())
@@ -118,7 +118,7 @@ suite("test_compaction_agg_keys_with_delete") {
for (String[] tablet in tablets) {
String tablet_id = tablet[0]
backend_id = tablet[2]
- (code, out, err) =
be_run_cumulative_compaction(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id), tablet_id)
+ def (code, out, err) =
be_run_cumulative_compaction(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id), tablet_id)
logger.info("Run compaction: code=" + code + ", out=" + out + ",
err=" + err)
assertEquals(code, 0)
def compactJson = parseJson(out.trim())
@@ -138,7 +138,7 @@ suite("test_compaction_agg_keys_with_delete") {
Thread.sleep(1000)
String tablet_id = tablet[0]
backend_id = tablet[2]
- (code, out, err) =
be_get_compaction_status(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id), tablet_id)
+ def (code, out, err) =
be_get_compaction_status(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id), tablet_id)
logger.info("Get compaction status: code=" + code + ", out=" +
out + ", err=" + err)
assertEquals(code, 0)
def compactionStatus = parseJson(out.trim())
@@ -152,7 +152,7 @@ suite("test_compaction_agg_keys_with_delete") {
String tablet_id = tablet[0]
def compactionStatusUrlIndex = 18
- (code, out, err) = curl("GET", tablet[compactionStatusUrlIndex])
+ def (code, out, err) = curl("GET",
tablet[compactionStatusUrlIndex])
logger.info("Show tablets status: code=" + code + ", out=" + out +
", err=" + err)
assertEquals(code, 0)
diff --git a/regression-test/suites/compaction/test_compaction_dup_keys.groovy
b/regression-test/suites/compaction/test_compaction_dup_keys.groovy
index cf3e96ae7d..62428f35c1 100644
--- a/regression-test/suites/compaction/test_compaction_dup_keys.groovy
+++ b/regression-test/suites/compaction/test_compaction_dup_keys.groovy
@@ -27,7 +27,7 @@ suite("test_compaction_dup_keys") {
getBackendIpHttpPort(backendId_to_backendIP,
backendId_to_backendHttpPort);
backend_id = backendId_to_backendIP.keySet()[0]
- (code, out, err) =
show_be_config(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id))
+ def (code, out, err) =
show_be_config(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id))
logger.info("Show config: code=" + code + ", out=" + out + ", err=" +
err)
assertEquals(code, 0)
@@ -106,7 +106,7 @@ suite("test_compaction_dup_keys") {
for (String[] tablet in tablets) {
String tablet_id = tablet[0]
backend_id = tablet[2]
- (code, out, err) =
be_run_cumulative_compaction(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id), tablet_id)
+ def (code, out, err) =
be_run_cumulative_compaction(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id), tablet_id)
logger.info("Run compaction: code=" + code + ", out=" + out + ",
err=" + err)
assertEquals(code, 0)
@@ -127,7 +127,7 @@ suite("test_compaction_dup_keys") {
Thread.sleep(1000)
String tablet_id = tablet[0]
backend_id = tablet[2]
- (code, out, err) =
be_get_compaction_status(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id), tablet_id)
+ def (code, out, err) =
be_get_compaction_status(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id), tablet_id)
logger.info("Get compaction status: code=" + code + ", out=" +
out + ", err=" + err)
assertEquals(code, 0)
def compactionStatus = parseJson(out.trim())
@@ -141,7 +141,7 @@ suite("test_compaction_dup_keys") {
String tablet_id = tablet[0]
def compactionStatusUrlIndex = 18
- (code, out, err) = curl("GET", tablet[compactionStatusUrlIndex])
+ def (code, out, err) = curl("GET",
tablet[compactionStatusUrlIndex])
logger.info("Show tablets status: code=" + code + ", out=" + out +
", err=" + err)
assertEquals(code, 0)
diff --git
a/regression-test/suites/compaction/test_compaction_dup_keys_with_delete.groovy
b/regression-test/suites/compaction/test_compaction_dup_keys_with_delete.groovy
index 848514017d..3e085abaf7 100644
---
a/regression-test/suites/compaction/test_compaction_dup_keys_with_delete.groovy
+++
b/regression-test/suites/compaction/test_compaction_dup_keys_with_delete.groovy
@@ -27,7 +27,7 @@ suite("test_compaction_dup_keys_with_delete") {
getBackendIpHttpPort(backendId_to_backendIP,
backendId_to_backendHttpPort);
backend_id = backendId_to_backendIP.keySet()[0]
- (code, out, err) =
show_be_config(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id))
+ def (code, out, err) =
show_be_config(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id))
logger.info("Show config: code=" + code + ", out=" + out + ", err=" +
err)
assertEquals(code, 0)
@@ -118,7 +118,7 @@ suite("test_compaction_dup_keys_with_delete") {
for (String[] tablet in tablets) {
String tablet_id = tablet[0]
backend_id = tablet[2]
- (code, out, err) =
be_run_cumulative_compaction(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id), tablet_id)
+ def (code, out, err) =
be_run_cumulative_compaction(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id), tablet_id)
logger.info("Run compaction: code=" + code + ", out=" + out + ",
err=" + err)
assertEquals(code, 0)
@@ -139,7 +139,7 @@ suite("test_compaction_dup_keys_with_delete") {
Thread.sleep(1000)
String tablet_id = tablet[0]
backend_id = tablet[2]
- (code, out, err) =
be_get_compaction_status(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id), tablet_id)
+ def (code, out, err) =
be_get_compaction_status(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id), tablet_id)
logger.info("Get compaction status: code=" + code + ", out=" +
out + ", err=" + err)
assertEquals(code, 0)
@@ -154,7 +154,7 @@ suite("test_compaction_dup_keys_with_delete") {
String tablet_id = tablet[0]
def compactionStatusUrlIndex = 18
- (code, out, err) = curl("GET", tablet[compactionStatusUrlIndex])
+ def (code, out, err) = curl("GET",
tablet[compactionStatusUrlIndex])
logger.info("Show tablets status: code=" + code + ", out=" + out +
", err=" + err)
assertEquals(code, 0)
diff --git a/regression-test/suites/compaction/test_compaction_uniq_keys.groovy
b/regression-test/suites/compaction/test_compaction_uniq_keys.groovy
index 648c7c4af2..5573b3511a 100644
--- a/regression-test/suites/compaction/test_compaction_uniq_keys.groovy
+++ b/regression-test/suites/compaction/test_compaction_uniq_keys.groovy
@@ -27,7 +27,7 @@ suite("test_compaction_uniq_keys") {
getBackendIpHttpPort(backendId_to_backendIP,
backendId_to_backendHttpPort);
backend_id = backendId_to_backendIP.keySet()[0]
- (code, out, err) =
show_be_config(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id))
+ def (code, out, err) =
show_be_config(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id))
logger.info("Show config: code=" + code + ", out=" + out + ", err=" +
err)
assertEquals(code, 0)
@@ -106,8 +106,8 @@ suite("test_compaction_uniq_keys") {
for (String[] tablet in tablets) {
String tablet_id = tablet[0]
backend_id = tablet[2]
- (code, out, err) =
be_run_cumulative_compaction(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id), tablet_id)
- logger.info("Run compaction: code=" + code + ", out=" + out + ",
err=" + err)
+ def (code, out, err) =
be_run_cumulative_compaction(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id), tablet_id)
+ def logger.info("Run compaction: code=" + code + ", out=" + out +
", err=" + err)
assertEquals(code, 0)
def compactJson = parseJson(out.trim())
if (compactJson.status.toLowerCase() == "fail") {
@@ -126,7 +126,7 @@ suite("test_compaction_uniq_keys") {
Thread.sleep(1000)
String tablet_id = tablet[0]
backend_id = tablet[2]
- (code, out, err) =
be_get_compaction_status(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id), tablet_id)
+ def (code, out, err) =
be_get_compaction_status(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id), tablet_id)
logger.info("Get compaction status: code=" + code + ", out=" +
out + ", err=" + err)
assertEquals(code, 0)
def compactionStatus = parseJson(out.trim())
@@ -139,7 +139,7 @@ suite("test_compaction_uniq_keys") {
for (String[] tablet in tablets) {
String tablet_id = tablet[0]
def compactionStatusUrlIndex = 18
- (code, out, err) = curl("GET", tablet[compactionStatusUrlIndex])
+ def (code, out, err) = curl("GET",
tablet[compactionStatusUrlIndex])
logger.info("Show tablets status: code=" + code + ", out=" + out +
", err=" + err)
assertEquals(code, 0)
def tabletJson = parseJson(out.trim())
diff --git
a/regression-test/suites/compaction/test_compaction_uniq_keys_row_store.groovy
b/regression-test/suites/compaction/test_compaction_uniq_keys_row_store.groovy
index 2eaf5f212d..c7f0eba5a1 100644
---
a/regression-test/suites/compaction/test_compaction_uniq_keys_row_store.groovy
+++
b/regression-test/suites/compaction/test_compaction_uniq_keys_row_store.groovy
@@ -43,7 +43,7 @@ suite("test_compaction_uniq_keys_row_store") {
getBackendIpHttpPort(backendId_to_backendIP,
backendId_to_backendHttpPort);
backend_id = backendId_to_backendIP.keySet()[0]
- (code, out, err) =
show_be_config(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id))
+ def (code, out, err) =
show_be_config(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id))
logger.info("Show config: code=" + code + ", out=" + out + ", err=" +
err)
assertEquals(code, 0)
@@ -162,7 +162,7 @@ suite("test_compaction_uniq_keys_row_store") {
for (String[] tablet in tablets) {
String tablet_id = tablet[0]
backend_id = tablet[2]
- (code, out, err) =
be_run_cumulative_compaction(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id), tablet_id)
+ def (code, out, err) =
be_run_cumulative_compaction(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id), tablet_id)
logger.info("Run compaction: code=" + code + ", out=" + out + ",
err=" + err)
assertEquals(code, 0)
def compactJson = parseJson(out.trim())
@@ -182,7 +182,7 @@ suite("test_compaction_uniq_keys_row_store") {
Thread.sleep(1000)
String tablet_id = tablet[0]
backend_id = tablet[2]
- (code, out, err) =
be_get_compaction_status(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id), tablet_id)
+ def (code, out, err) =
be_get_compaction_status(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id), tablet_id)
logger.info("Get compaction status: code=" + code + ", out=" +
out + ", err=" + err)
assertEquals(code, 0)
@@ -196,7 +196,7 @@ suite("test_compaction_uniq_keys_row_store") {
for (String[] tablet in tablets) {
String tablet_id = tablet[0]
def compactionStatusUrlIndex = 18
- (code, out, err) = curl("GET", tablet[compactionStatusUrlIndex])
+ def (code, out, err) = curl("GET",
tablet[compactionStatusUrlIndex])
logger.info("Show tablets status: code=" + code + ", out=" + out +
", err=" + err)
assertEquals(code, 0)
def tabletJson = parseJson(out.trim())
diff --git
a/regression-test/suites/compaction/test_compaction_uniq_keys_with_delete.groovy
b/regression-test/suites/compaction/test_compaction_uniq_keys_with_delete.groovy
index 805bc61347..e74a2f26d6 100644
---
a/regression-test/suites/compaction/test_compaction_uniq_keys_with_delete.groovy
+++
b/regression-test/suites/compaction/test_compaction_uniq_keys_with_delete.groovy
@@ -27,7 +27,7 @@ suite("test_compaction_uniq_keys_with_delete") {
getBackendIpHttpPort(backendId_to_backendIP,
backendId_to_backendHttpPort);
backend_id = backendId_to_backendIP.keySet()[0]
- (code, out, err) =
show_be_config(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id))
+ def (code, out, err) =
show_be_config(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id))
logger.info("Show config: code=" + code + ", out=" + out + ", err=" +
err)
assertEquals(code, 0)
@@ -122,7 +122,7 @@ suite("test_compaction_uniq_keys_with_delete") {
for (String[] tablet in tablets) {
String tablet_id = tablet[0]
backend_id = tablet[2]
- (code, out, err) =
be_run_cumulative_compaction(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id), tablet_id)
+ def (code, out, err) =
be_run_cumulative_compaction(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id), tablet_id)
logger.info("Run compaction: code=" + code + ", out=" + out + ",
err=" + err)
assertEquals(code, 0)
def compactJson = parseJson(out.trim())
@@ -142,7 +142,7 @@ suite("test_compaction_uniq_keys_with_delete") {
Thread.sleep(1000)
String tablet_id = tablet[0]
backend_id = tablet[2]
- (code, out, err) =
be_get_compaction_status(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id), tablet_id)
+ def (code, out, err) =
be_get_compaction_status(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id), tablet_id)
logger.info("Get compaction status: code=" + code + ", out=" +
out + ", err=" + err)
assertEquals(code, 0)
def compactionStatus = parseJson(out.trim())
@@ -155,7 +155,7 @@ suite("test_compaction_uniq_keys_with_delete") {
for (String[] tablet in tablets) {
String tablet_id = tablet[0]
def compactionStatusUrlIndex = 18
- (code, out, err) = curl("GET", tablet[compactionStatusUrlIndex])
+ def (code, out, err) = curl("GET",
tablet[compactionStatusUrlIndex])
logger.info("Show tablets status: code=" + code + ", out=" + out +
", err=" + err)
assertEquals(code, 0)
def tabletJson = parseJson(out.trim())
diff --git
a/regression-test/suites/compaction/test_vertical_compaction_agg_keys.groovy
b/regression-test/suites/compaction/test_vertical_compaction_agg_keys.groovy
index 036cb44b6b..528ce51e32 100644
--- a/regression-test/suites/compaction/test_vertical_compaction_agg_keys.groovy
+++ b/regression-test/suites/compaction/test_vertical_compaction_agg_keys.groovy
@@ -27,7 +27,7 @@ suite("test_vertical_compaction_agg_keys") {
getBackendIpHttpPort(backendId_to_backendIP,
backendId_to_backendHttpPort);
backend_id = backendId_to_backendIP.keySet()[0]
- (code, out, err) =
show_be_config(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id))
+ def (code, out, err) =
show_be_config(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id))
logger.info("Show config: code=" + code + ", out=" + out + ", err=" +
err)
assertEquals(code, 0)
def configList = parseJson(out.trim())
@@ -119,7 +119,7 @@ suite("test_vertical_compaction_agg_keys") {
for (String[] tablet in tablets) {
String tablet_id = tablet[0]
backend_id = tablet[2]
- (code, out, err) =
be_run_cumulative_compaction(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id), tablet_id)
+ def (code, out, err) =
be_run_cumulative_compaction(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id), tablet_id)
logger.info("Run compaction: code=" + code + ", out=" + out + ",
err=" + err)
assertEquals(code, 0)
def compactJson = parseJson(out.trim())
@@ -138,7 +138,7 @@ suite("test_vertical_compaction_agg_keys") {
do {
Thread.sleep(1000)
String tablet_id = tablet[0]
- (code, out, err) =
be_get_compaction_status(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id), tablet_id)
+ def (code, out, err) =
be_get_compaction_status(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id), tablet_id)
logger.info("Get compaction status: code=" + code + ", out=" +
out + ", err=" + err)
assertEquals(code, 0)
def compactionStatus = parseJson(out.trim())
@@ -151,7 +151,7 @@ suite("test_vertical_compaction_agg_keys") {
for (String[] tablet in tablets) {
String tablet_id = tablet[0]
def compactionStatusUrlIndex = 18
- (code, out, err) = curl("GET", tablet[compactionStatusUrlIndex])
+ def (code, out, err) = curl("GET",
tablet[compactionStatusUrlIndex])
logger.info("Show tablets status: code=" + code + ", out=" + out +
", err=" + err)
assertEquals(code, 0)
def tabletJson = parseJson(out.trim())
diff --git
a/regression-test/suites/compaction/test_vertical_compaction_dup_keys.groovy
b/regression-test/suites/compaction/test_vertical_compaction_dup_keys.groovy
index 1380e5e817..f69fe34296 100644
--- a/regression-test/suites/compaction/test_vertical_compaction_dup_keys.groovy
+++ b/regression-test/suites/compaction/test_vertical_compaction_dup_keys.groovy
@@ -27,7 +27,7 @@ suite("test_vertical_compaction_dup_keys") {
getBackendIpHttpPort(backendId_to_backendIP,
backendId_to_backendHttpPort);
backend_id = backendId_to_backendIP.keySet()[0]
- (code, out, err) =
show_be_config(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id))
+ def (code, out, err) =
show_be_config(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id))
logger.info("Show config: code=" + code + ", out=" + out + ", err=" +
err)
assertEquals(code, 0)
@@ -119,7 +119,7 @@ suite("test_vertical_compaction_dup_keys") {
for (String[] tablet in tablets) {
String tablet_id = tablet[0]
backend_id = tablet[2]
- (code, out, err) =
be_run_cumulative_compaction(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id), tablet_id)
+ def (code, out, err) =
be_run_cumulative_compaction(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id), tablet_id)
logger.info("Run compaction: code=" + code + ", out=" + out + ",
err=" + err)
assertEquals(code, 0)
def compactJson = parseJson(out.trim())
@@ -139,7 +139,7 @@ suite("test_vertical_compaction_dup_keys") {
Thread.sleep(1000)
String tablet_id = tablet[0]
backend_id = tablet[2]
- (code, out, err) =
be_get_compaction_status(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id), tablet_id)
+ def (code, out, err) =
be_get_compaction_status(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id), tablet_id)
logger.info("Get compaction status: code=" + code + ", out=" +
out + ", err=" + err)
assertEquals(code, 0)
def compactionStatus = parseJson(out.trim())
@@ -152,7 +152,7 @@ suite("test_vertical_compaction_dup_keys") {
for (String[] tablet in tablets) {
String tablet_id = tablet[0]
def compactionStatusUrlIndex = 18
- (code, out, err) = curl("GET", tablet[compactionStatusUrlIndex])
+ def (code, out, err) = curl("GET",
tablet[compactionStatusUrlIndex])
logger.info("Show tablets status: code=" + code + ", out=" + out +
", err=" + err)
assertEquals(code, 0)
def tabletJson = parseJson(out.trim())
diff --git
a/regression-test/suites/compaction/test_vertical_compaction_uniq_keys.groovy
b/regression-test/suites/compaction/test_vertical_compaction_uniq_keys.groovy
index 3da11dbc60..6c137b2982 100644
---
a/regression-test/suites/compaction/test_vertical_compaction_uniq_keys.groovy
+++
b/regression-test/suites/compaction/test_vertical_compaction_uniq_keys.groovy
@@ -27,7 +27,7 @@ suite("test_vertical_compaction_uniq_keys") {
getBackendIpHttpPort(backendId_to_backendIP,
backendId_to_backendHttpPort);
backend_id = backendId_to_backendIP.keySet()[0]
- (code, out, err) =
show_be_config(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id))
+ def (code, out, err) =
show_be_config(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id))
logger.info("Show config: code=" + code + ", out=" + out + ", err=" +
err)
assertEquals(code, 0)
def configList = parseJson(out.trim())
@@ -116,7 +116,7 @@ suite("test_vertical_compaction_uniq_keys") {
for (String[] tablet in tablets) {
String tablet_id = tablet[0]
backend_id = tablet[2]
- (code, out, err) =
be_run_cumulative_compaction(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id), tablet_id)
+ def (code, out, err) =
be_run_cumulative_compaction(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id), tablet_id)
logger.info("Run compaction: code=" + code + ", out=" + out + ",
err=" + err)
assertEquals(code, 0)
def compactJson = parseJson(out.trim())
@@ -136,7 +136,7 @@ suite("test_vertical_compaction_uniq_keys") {
Thread.sleep(1000)
String tablet_id = tablet[0]
backend_id = tablet[2]
- (code, out, err) =
be_get_compaction_status(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id), tablet_id)
+ def (code, out, err) =
be_get_compaction_status(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id), tablet_id)
logger.info("Get compaction status: code=" + code + ", out=" +
out + ", err=" + err)
assertEquals(code, 0)
def compactionStatus = parseJson(out.trim())
@@ -149,7 +149,7 @@ suite("test_vertical_compaction_uniq_keys") {
for (String[] tablet in tablets) {
String tablet_id = tablet[0]
def compactionStatusUrlIndex = 18
- (code, out, err) = curl("GET", tablet[compactionStatusUrlIndex])
+ def (code, out, err) = curl("GET",
tablet[compactionStatusUrlIndex])
logger.info("Show tablets status: code=" + code + ", out=" + out +
", err=" + err)
assertEquals(code, 0)
def tabletJson = parseJson(out.trim())
diff --git a/regression-test/suites/json_p0/test_json_load_and_function.groovy
b/regression-test/suites/json_p0/test_json_load_and_function.groovy
index 756810933b..a02268c096 100644
--- a/regression-test/suites/json_p0/test_json_load_and_function.groovy
+++ b/regression-test/suites/json_p0/test_json_load_and_function.groovy
@@ -51,7 +51,7 @@ suite("test_json_load_and_function", "p0") {
log.info("Stream load result: ${result}".toString())
def json = parseJson(result)
- (code, out, err) = curl("GET", json.ErrorURL)
+ def (code, out, err) = curl("GET", json.ErrorURL)
log.info("error result: " + out)
assertEquals("fail", json.Status.toLowerCase())
@@ -84,7 +84,7 @@ suite("test_json_load_and_function", "p0") {
log.info("Stream load result: ${result}".toString())
def json = parseJson(result)
- (code, out, err) = curl("GET", json.ErrorURL)
+ def (code, out, err) = curl("GET", json.ErrorURL)
log.info("error result: " + out)
assertEquals("success", json.Status.toLowerCase())
diff --git
a/regression-test/suites/jsonb_p0/test_jsonb_load_and_function.groovy
b/regression-test/suites/jsonb_p0/test_jsonb_load_and_function.groovy
index fd2b246c7c..b1a91d06f0 100644
--- a/regression-test/suites/jsonb_p0/test_jsonb_load_and_function.groovy
+++ b/regression-test/suites/jsonb_p0/test_jsonb_load_and_function.groovy
@@ -50,7 +50,7 @@ suite("test_jsonb_load_and_function", "p0") {
}
log.info("Stream load result: ${result}".toString())
def json = parseJson(result)
- (code, out, err) = curl("GET", json.ErrorURL)
+ def (code, out, err) = curl("GET", json.ErrorURL)
log.info("error result: " + out)
assertEquals("fail", json.Status.toLowerCase())
@@ -82,7 +82,7 @@ suite("test_jsonb_load_and_function", "p0") {
}
log.info("Stream load result: ${result}".toString())
def json = parseJson(result)
- (code, out, err) = curl("GET", json.ErrorURL)
+ def (code, out, err) = curl("GET", json.ErrorURL)
log.info("error result: " + out)
assertEquals("success", json.Status.toLowerCase())
diff --git
a/regression-test/suites/load_p0/stream_load/test_map_load_and_compaction.groovy
b/regression-test/suites/load_p0/stream_load/test_map_load_and_compaction.groovy
index 52063dca57..cf5c8164ec 100644
---
a/regression-test/suites/load_p0/stream_load/test_map_load_and_compaction.groovy
+++
b/regression-test/suites/load_p0/stream_load/test_map_load_and_compaction.groovy
@@ -69,7 +69,7 @@ suite("test_map_load_and_compaction", "p0") {
}
def checkCompactionStatus = {compactionStatus, assertRowSetNum->
- (code, out, err) = curl("GET", compactionStatus)
+ def (code, out, err) = curl("GET", compactionStatus)
logger.info("Check compaction status: code=" + code + ", out=" + out +
", err=" + err)
assertEquals(code, 0)
def compactStatusJson = parseJson(out.trim())
@@ -110,7 +110,7 @@ suite("test_map_load_and_compaction", "p0") {
getBackendIpHttpPort(backendId_to_backendIP,
backendId_to_backendHttpPort);
String tablet_id = tablet[0]
backend_id = tablet[2]
- (code, out, err) =
be_run_cumulative_compaction(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id), tablet_id)
+ def (code, out, err) =
be_run_cumulative_compaction(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id), tablet_id)
logger.info("Run compaction: code=" + code + ", out=" + out + ", err="
+ err)
assertEquals(code, 0)
def compactJson = parseJson(out.trim())
@@ -119,7 +119,7 @@ suite("test_map_load_and_compaction", "p0") {
// wait compactions done
do {
Thread.sleep(1000)
- (code, out, err) =
be_get_compaction_status(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id), tablet_id)
+ def (code, out, err) =
be_get_compaction_status(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id), tablet_id)
logger.info("Get compaction status: code=" + code + ", out=" + out
+ ", err=" + err)
assertEquals(code, 0)
def cs = parseJson(out.trim())
diff --git a/regression-test/suites/schema_change/test_number_overflow.groovy
b/regression-test/suites/schema_change/test_number_overflow.groovy
index 7eb0b2b5f0..e69bb4e6ce 100644
--- a/regression-test/suites/schema_change/test_number_overflow.groovy
+++ b/regression-test/suites/schema_change/test_number_overflow.groovy
@@ -31,7 +31,7 @@ suite ("test_number_overflow") {
getBackendIpHttpPort(backendId_to_backendIP,
backendId_to_backendHttpPort);
backend_id = backendId_to_backendIP.keySet()[0]
- (code, out, err) =
show_be_config(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id))
+ def (code, out, err) =
show_be_config(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id))
logger.info("Show config: code=" + code + ", out=" + out + ", err=" +
err)
assertEquals(code, 0)
diff --git
a/regression-test/suites/schema_change_p0/datev2/test_agg_keys_schema_change_datev2.groovy
b/regression-test/suites/schema_change_p0/datev2/test_agg_keys_schema_change_datev2.groovy
index 11e0440612..adcff6dc6c 100644
---
a/regression-test/suites/schema_change_p0/datev2/test_agg_keys_schema_change_datev2.groovy
+++
b/regression-test/suites/schema_change_p0/datev2/test_agg_keys_schema_change_datev2.groovy
@@ -30,7 +30,7 @@ suite("test_agg_keys_schema_change_datev2") {
getBackendIpHttpPort(backendId_to_backendIP, backendId_to_backendHttpPort);
backend_id = backendId_to_backendIP.keySet()[0]
- (code, out, err) = show_be_config(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id))
+ def (code, out, err) =
show_be_config(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id))
logger.info("Show config: code=" + code + ", out=" + out + ", err=" + err)
assertEquals(code, 0)
@@ -43,7 +43,7 @@ suite("test_agg_keys_schema_change_datev2") {
String tablet_id = tablet[0]
backend_id = tablet[2]
logger.info("run compaction:" + tablet_id)
- (code, out, err) =
be_run_cumulative_compaction(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id), tablet_id)
+ def (code, out, err) =
be_run_cumulative_compaction(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id), tablet_id)
logger.info("Run compaction: code=" + code + ", out=" + out + ",
err=" + err)
}
@@ -54,7 +54,7 @@ suite("test_agg_keys_schema_change_datev2") {
Thread.sleep(100)
String tablet_id = tablet[0]
backend_id = tablet[2]
- (code, out, err) =
be_get_compaction_status(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id), tablet_id)
+ def (code, out, err) =
be_get_compaction_status(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id), tablet_id)
logger.info("Get compaction status: code=" + code + ", out=" +
out + ", err=" + err)
assertEquals(code, 0)
def compactionStatus = parseJson(out.trim())
diff --git
a/regression-test/suites/schema_change_p0/datev2/test_dup_keys_schema_change_datev2.groovy
b/regression-test/suites/schema_change_p0/datev2/test_dup_keys_schema_change_datev2.groovy
index 25f4eb8956..3173e26bb4 100644
---
a/regression-test/suites/schema_change_p0/datev2/test_dup_keys_schema_change_datev2.groovy
+++
b/regression-test/suites/schema_change_p0/datev2/test_dup_keys_schema_change_datev2.groovy
@@ -30,7 +30,7 @@ suite("test_dup_keys_schema_change_datev2") {
getBackendIpHttpPort(backendId_to_backendIP, backendId_to_backendHttpPort);
backend_id = backendId_to_backendIP.keySet()[0]
- (code, out, err) = show_be_config(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id))
+ def (code, out, err) =
show_be_config(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id))
logger.info("Show config: code=" + code + ", out=" + out + ", err=" + err)
assertEquals(code, 0)
@@ -43,7 +43,7 @@ suite("test_dup_keys_schema_change_datev2") {
String tablet_id = tablet[0]
backend_id = tablet[2]
logger.info("run compaction:" + tablet_id)
- (code, out, err) =
be_run_cumulative_compaction(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id), tablet_id)
+ def (code, out, err) =
be_run_cumulative_compaction(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id), tablet_id)
logger.info("Run compaction: code=" + code + ", out=" + out + ",
err=" + err)
}
@@ -54,7 +54,7 @@ suite("test_dup_keys_schema_change_datev2") {
Thread.sleep(100)
String tablet_id = tablet[0]
backend_id = tablet[2]
- (code, out, err) =
be_get_compaction_status(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id), tablet_id)
+ def (code, out, err) =
be_get_compaction_status(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id), tablet_id)
logger.info("Get compaction status: code=" + code + ", out=" +
out + ", err=" + err)
assertEquals(code, 0)
def compactionStatus = parseJson(out.trim())
diff --git
a/regression-test/suites/schema_change_p0/datev2/test_schema_change_varchar_to_datev2.groovy
b/regression-test/suites/schema_change_p0/datev2/test_schema_change_varchar_to_datev2.groovy
index 35125cd63d..c4e2336d68 100644
---
a/regression-test/suites/schema_change_p0/datev2/test_schema_change_varchar_to_datev2.groovy
+++
b/regression-test/suites/schema_change_p0/datev2/test_schema_change_varchar_to_datev2.groovy
@@ -30,7 +30,7 @@ suite("test_schema_change_varchar_to_datev2") {
getBackendIpHttpPort(backendId_to_backendIP, backendId_to_backendHttpPort);
backend_id = backendId_to_backendIP.keySet()[0]
- (code, out, err) = show_be_config(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id))
+ def (code, out, err) =
show_be_config(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id))
logger.info("Show config: code=" + code + ", out=" + out + ", err=" + err)
assertEquals(code, 0)
def configList = parseJson(out.trim())
@@ -42,7 +42,7 @@ suite("test_schema_change_varchar_to_datev2") {
String tablet_id = tablet[0]
backend_id = tablet[2]
logger.info("run compaction:" + tablet_id)
- (code, out, err) =
be_run_cumulative_compaction(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id), tablet_id)
+ def (code, out, err) =
be_run_cumulative_compaction(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id), tablet_id)
logger.info("Run compaction: code=" + code + ", out=" + out + ",
err=" + err)
}
@@ -53,7 +53,7 @@ suite("test_schema_change_varchar_to_datev2") {
Thread.sleep(100)
String tablet_id = tablet[0]
backend_id = tablet[2]
- (code, out, err) =
be_get_compaction_status(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id), tablet_id)
+ def (code, out, err) =
be_get_compaction_status(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id), tablet_id)
logger.info("Get compaction status: code=" + code + ", out=" +
out + ", err=" + err)
assertEquals(code, 0)
def compactionStatus = parseJson(out.trim())
diff --git
a/regression-test/suites/schema_change_p0/decimalv3/test_agg_keys_schema_change_decimalv3.groovy
b/regression-test/suites/schema_change_p0/decimalv3/test_agg_keys_schema_change_decimalv3.groovy
index 033de35e83..777c3f8975 100644
---
a/regression-test/suites/schema_change_p0/decimalv3/test_agg_keys_schema_change_decimalv3.groovy
+++
b/regression-test/suites/schema_change_p0/decimalv3/test_agg_keys_schema_change_decimalv3.groovy
@@ -31,7 +31,7 @@ suite("test_agg_keys_schema_change_decimalv3") {
getBackendIpHttpPort(backendId_to_backendIP, backendId_to_backendHttpPort);
backend_id = backendId_to_backendIP.keySet()[0]
- (code, out, err) = show_be_config(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id))
+ def (code, out, err) =
show_be_config(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id))
logger.info("Show config: code=" + code + ", out=" + out + ", err=" + err)
assertEquals(code, 0)
def configList = parseJson(out.trim())
@@ -43,7 +43,7 @@ suite("test_agg_keys_schema_change_decimalv3") {
String tablet_id = tablet[0]
backend_id = tablet[2]
logger.info("run compaction:" + tablet_id)
- (code, out, err) =
be_run_cumulative_compaction(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id), tablet_id )
+ def (code, out, err) =
be_run_cumulative_compaction(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id), tablet_id )
logger.info("Run compaction: code=" + code + ", out=" + out + ",
err=" + err)
}
@@ -54,7 +54,7 @@ suite("test_agg_keys_schema_change_decimalv3") {
Thread.sleep(100)
String tablet_id = tablet[0]
backend_id = tablet[2]
- (code, out, err) =
be_get_compaction_status(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id), tablet_id)
+ def (code, out, err) =
be_get_compaction_status(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id), tablet_id)
logger.info("Get compaction status: code=" + code + ", out=" +
out + ", err=" + err)
assertEquals(code, 0)
def compactionStatus = parseJson(out.trim())
diff --git
a/regression-test/suites/schema_change_p0/test_agg_keys_schema_change.groovy
b/regression-test/suites/schema_change_p0/test_agg_keys_schema_change.groovy
index db55c4e806..ba391b1c98 100644
--- a/regression-test/suites/schema_change_p0/test_agg_keys_schema_change.groovy
+++ b/regression-test/suites/schema_change_p0/test_agg_keys_schema_change.groovy
@@ -33,7 +33,7 @@ suite ("test_agg_keys_schema_change") {
getBackendIpHttpPort(backendId_to_backendIP,
backendId_to_backendHttpPort);
backend_id = backendId_to_backendIP.keySet()[0]
- (code, out, err) =
show_be_config(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id))
+ def (code, out, err) =
show_be_config(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id))
logger.info("Show config: code=" + code + ", out=" + out + ", err=" +
err)
assertEquals(code, 0)
@@ -193,7 +193,7 @@ suite ("test_agg_keys_schema_change") {
String tablet_id = tablet[0]
backend_id = tablet[2]
logger.info("run compaction:" + tablet_id)
- (code, out, err) =
be_run_cumulative_compaction(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id), tablet_id)
+ def (code, out, err) =
be_run_cumulative_compaction(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id), tablet_id)
logger.info("Run compaction: code=" + code + ", out=" + out +
", err=" + err)
}
@@ -204,7 +204,7 @@ suite ("test_agg_keys_schema_change") {
Thread.sleep(100)
String tablet_id = tablet[0]
backend_id = tablet[2]
- (code, out, err) =
be_get_compaction_status(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id), tablet_id)
+ def (code, out, err) =
be_get_compaction_status(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id), tablet_id)
logger.info("Get compaction status: code=" + code + ",
out=" + out + ", err=" + err)
assertEquals(code, 0)
def compactionStatus = parseJson(out.trim())
diff --git
a/regression-test/suites/schema_change_p0/test_agg_mv_schema_change.groovy
b/regression-test/suites/schema_change_p0/test_agg_mv_schema_change.groovy
index 8808dfb2d1..2a94110b18 100644
--- a/regression-test/suites/schema_change_p0/test_agg_mv_schema_change.groovy
+++ b/regression-test/suites/schema_change_p0/test_agg_mv_schema_change.groovy
@@ -50,7 +50,7 @@ suite ("test_agg_mv_schema_change") {
getBackendIpHttpPort(backendId_to_backendIP,
backendId_to_backendHttpPort);
backend_id = backendId_to_backendIP.keySet()[0]
- (code, out, err) =
show_be_config(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id))
+ def (code, out, err) =
show_be_config(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id))
logger.info("Show config: code=" + code + ", out=" + out + ", err=" +
err)
assertEquals(code, 0)
@@ -158,7 +158,7 @@ suite ("test_agg_mv_schema_change") {
String tablet_id = tablet[0]
backend_id = tablet[2]
logger.info("run compaction:" + tablet_id)
- (code, out, err) =
be_run_cumulative_compaction(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id), tablet_id)
+ def (code, out, err) =
be_run_cumulative_compaction(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id), tablet_id)
logger.info("Run compaction: code=" + code + ", out=" + out +
", err=" + err)
//assertEquals(code, 0)
}
@@ -170,7 +170,7 @@ suite ("test_agg_mv_schema_change") {
Thread.sleep(100)
String tablet_id = tablet[0]
backend_id = tablet[2]
- (code, out, err) =
be_get_compaction_status(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id), tablet_id)
+ def (code, out, err) =
be_get_compaction_status(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id), tablet_id)
logger.info("Get compaction status: code=" + code + ",
out=" + out + ", err=" + err)
assertEquals(code, 0)
def compactionStatus = parseJson(out.trim())
diff --git
a/regression-test/suites/schema_change_p0/test_agg_rollup_schema_change.groovy
b/regression-test/suites/schema_change_p0/test_agg_rollup_schema_change.groovy
index 19e3716664..215b8fa493 100644
---
a/regression-test/suites/schema_change_p0/test_agg_rollup_schema_change.groovy
+++
b/regression-test/suites/schema_change_p0/test_agg_rollup_schema_change.groovy
@@ -50,7 +50,7 @@ suite ("test_agg_rollup_schema_change") {
getBackendIpHttpPort(backendId_to_backendIP,
backendId_to_backendHttpPort);
backend_id = backendId_to_backendIP.keySet()[0]
- (code, out, err) =
show_be_config(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id))
+ def (code, out, err) =
show_be_config(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id))
logger.info("Show config: code=" + code + ", out=" + out + ", err=" +
err)
assertEquals(code, 0)
@@ -169,7 +169,7 @@ suite ("test_agg_rollup_schema_change") {
String tablet_id = tablet[0]
backend_id = tablet[2]
logger.info("run compaction:" + tablet_id)
- (code, out, err) =
be_run_cumulative_compaction(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id), tablet_id)
+ def (code, out, err) =
be_run_cumulative_compaction(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id), tablet_id)
logger.info("Run compaction: code=" + code + ", out=" + out +
", err=" + err)
//assertEquals(code, 0)
}
@@ -181,7 +181,7 @@ suite ("test_agg_rollup_schema_change") {
Thread.sleep(100)
String tablet_id = tablet[0]
backend_id = tablet[2]
- (code, out, err) =
be_get_compaction_status(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id), tablet_id)
+ def (code, out, err) =
be_get_compaction_status(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id), tablet_id)
logger.info("Get compaction status: code=" + code + ",
out=" + out + ", err=" + err)
assertEquals(code, 0)
def compactionStatus = parseJson(out.trim())
diff --git
a/regression-test/suites/schema_change_p0/test_agg_vals_schema_change.groovy
b/regression-test/suites/schema_change_p0/test_agg_vals_schema_change.groovy
index 43766aa499..ea87e95841 100644
--- a/regression-test/suites/schema_change_p0/test_agg_vals_schema_change.groovy
+++ b/regression-test/suites/schema_change_p0/test_agg_vals_schema_change.groovy
@@ -28,7 +28,7 @@ suite ("test_agg_vals_schema_change") {
getBackendIpHttpPort(backendId_to_backendIP,
backendId_to_backendHttpPort);
backend_id = backendId_to_backendIP.keySet()[0]
- (code, out, err) =
show_be_config(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id))
+ def (code, out, err) =
show_be_config(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id))
logger.info("Show config: code=" + code + ", out=" + out + ", err=" +
err)
assertEquals(code, 0)
@@ -156,7 +156,7 @@ suite ("test_agg_vals_schema_change") {
String tablet_id = tablet[0]
backend_id = tablet[2]
logger.info("run compaction:" + tablet_id)
- (code, out, err) =
be_run_cumulative_compaction(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id), tablet_id)
+ def (code, out, err) =
be_run_cumulative_compaction(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id), tablet_id)
logger.info("Run compaction: code=" + code + ", out=" + out + ",
err=" + err)
//assertEquals(code, 0)
}
@@ -168,7 +168,7 @@ suite ("test_agg_vals_schema_change") {
Thread.sleep(100)
String tablet_id = tablet[0]
backend_id = tablet[2]
- (code, out, err) =
be_get_compaction_status(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id), tablet_id)
+ def (code, out, err) =
be_get_compaction_status(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id), tablet_id)
logger.info("Get compaction status: code=" + code + ", out=" +
out + ", err=" + err)
assertEquals(code, 0)
def compactionStatus = parseJson(out.trim())
diff --git
a/regression-test/suites/schema_change_p0/test_dup_keys_schema_change.groovy
b/regression-test/suites/schema_change_p0/test_dup_keys_schema_change.groovy
index 8eb6329db9..35dfcac3bc 100644
--- a/regression-test/suites/schema_change_p0/test_dup_keys_schema_change.groovy
+++ b/regression-test/suites/schema_change_p0/test_dup_keys_schema_change.groovy
@@ -31,7 +31,7 @@ suite ("test_dup_keys_schema_change") {
getBackendIpHttpPort(backendId_to_backendIP,
backendId_to_backendHttpPort);
backend_id = backendId_to_backendIP.keySet()[0]
- (code, out, err) =
show_be_config(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id))
+ def (code, out, err) =
show_be_config(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id))
logger.info("Show config: code=" + code + ", out=" + out + ", err=" +
err)
assertEquals(code, 0)
@@ -162,7 +162,7 @@ suite ("test_dup_keys_schema_change") {
String tablet_id = tablet[0]
backend_id = tablet[2]
logger.info("run compaction:" + tablet_id)
- (code, out, err) =
be_run_cumulative_compaction(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id), tablet_id)
+ def (code, out, err) =
be_run_cumulative_compaction(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id), tablet_id)
logger.info("Run compaction: code=" + code + ", out=" + out +
", err=" + err)
//assertEquals(code, 0)
}
@@ -174,7 +174,7 @@ suite ("test_dup_keys_schema_change") {
Thread.sleep(100)
String tablet_id = tablet[0]
backend_id = tablet[2]
- (code, out, err) =
be_get_compaction_status(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id), tablet_id)
+ def (code, out, err) =
be_get_compaction_status(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id), tablet_id)
logger.info("Get compaction status: code=" + code + ",
out=" + out + ", err=" + err)
assertEquals(code, 0)
def compactionStatus = parseJson(out.trim())
diff --git
a/regression-test/suites/schema_change_p0/test_dup_mv_schema_change.groovy
b/regression-test/suites/schema_change_p0/test_dup_mv_schema_change.groovy
index aeafa8d15b..10745b27c4 100644
--- a/regression-test/suites/schema_change_p0/test_dup_mv_schema_change.groovy
+++ b/regression-test/suites/schema_change_p0/test_dup_mv_schema_change.groovy
@@ -48,7 +48,7 @@ suite ("test_dup_mv_schema_change") {
getBackendIpHttpPort(backendId_to_backendIP,
backendId_to_backendHttpPort);
backend_id = backendId_to_backendIP.keySet()[0]
- (code, out, err) =
show_be_config(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id))
+ def (code, out, err) =
show_be_config(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id))
logger.info("Show config: code=" + code + ", out=" + out + ", err=" +
err)
assertEquals(code, 0)
@@ -177,7 +177,7 @@ suite ("test_dup_mv_schema_change") {
String tablet_id = tablet[0]
backend_id = tablet[2]
logger.info("run compaction:" + tablet_id)
- (code, out, err) =
be_run_cumulative_compaction(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id), tablet_id)
+ def (code, out, err) =
be_run_cumulative_compaction(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id), tablet_id)
logger.info("Run compaction: code=" + code + ", out=" + out +
", err=" + err)
//assertEquals(code, 0)
}
@@ -189,7 +189,7 @@ suite ("test_dup_mv_schema_change") {
Thread.sleep(100)
String tablet_id = tablet[0]
backend_id = tablet[2]
- (code, out, err) =
be_get_compaction_status(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id), tablet_id)
+ def (code, out, err) =
be_get_compaction_status(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id), tablet_id)
logger.info("Get compaction status: code=" + code + ",
out=" + out + ", err=" + err)
assertEquals(code, 0)
def compactionStatus = parseJson(out.trim())
diff --git
a/regression-test/suites/schema_change_p0/test_dup_rollup_schema_change.groovy
b/regression-test/suites/schema_change_p0/test_dup_rollup_schema_change.groovy
index e31a2f8c57..402b0e7c24 100644
---
a/regression-test/suites/schema_change_p0/test_dup_rollup_schema_change.groovy
+++
b/regression-test/suites/schema_change_p0/test_dup_rollup_schema_change.groovy
@@ -50,7 +50,7 @@ suite ("test_dup_rollup_schema_change") {
getBackendIpHttpPort(backendId_to_backendIP,
backendId_to_backendHttpPort);
backend_id = backendId_to_backendIP.keySet()[0]
- (code, out, err) =
show_be_config(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id))
+ def (code, out, err) =
show_be_config(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id))
logger.info("Show config: code=" + code + ", out=" + out + ", err=" +
err)
assertEquals(code, 0)
@@ -188,7 +188,7 @@ suite ("test_dup_rollup_schema_change") {
String tablet_id = tablet[0]
backend_id = tablet[2]
logger.info("run compaction:" + tablet_id)
- (code, out, err) =
be_run_cumulative_compaction(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id), tablet_id)
+ def (code, out, err) =
be_run_cumulative_compaction(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id), tablet_id)
logger.info("Run compaction: code=" + code + ", out=" + out +
", err=" + err)
//assertEquals(code, 0)
}
@@ -200,7 +200,7 @@ suite ("test_dup_rollup_schema_change") {
Thread.sleep(100)
String tablet_id = tablet[0]
backend_id = tablet[2]
- (code, out, err) =
be_get_compaction_status(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id), tablet_id)
+ def (code, out, err) =
be_get_compaction_status(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id), tablet_id)
logger.info("Get compaction status: code=" + code + ",
out=" + out + ", err=" + err)
assertEquals(code, 0)
def compactionStatus = parseJson(out.trim())
diff --git
a/regression-test/suites/schema_change_p0/test_dup_vals_schema_change.groovy
b/regression-test/suites/schema_change_p0/test_dup_vals_schema_change.groovy
index 635c4fbfeb..fd1af964ff 100644
--- a/regression-test/suites/schema_change_p0/test_dup_vals_schema_change.groovy
+++ b/regression-test/suites/schema_change_p0/test_dup_vals_schema_change.groovy
@@ -27,7 +27,7 @@ suite ("test_dup_vals_schema_change") {
getBackendIpHttpPort(backendId_to_backendIP,
backendId_to_backendHttpPort);
backend_id = backendId_to_backendIP.keySet()[0]
- (code, out, err) =
show_be_config(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id))
+ def (code, out, err) =
show_be_config(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id))
logger.info("Show config: code=" + code + ", out=" + out + ", err=" +
err)
assertEquals(code, 0)
@@ -143,7 +143,7 @@ suite ("test_dup_vals_schema_change") {
String tablet_id = tablet[0]
backend_id = tablet[2]
logger.info("run compaction:" + tablet_id)
- (code, out, err) =
be_run_cumulative_compaction(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id), tablet_id)
+ def (code, out, err) =
be_run_cumulative_compaction(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id), tablet_id)
logger.info("Run compaction: code=" + code + ", out=" + out +
", err=" + err)
//assertEquals(code, 0)
}
@@ -155,7 +155,7 @@ suite ("test_dup_vals_schema_change") {
Thread.sleep(100)
String tablet_id = tablet[0]
backend_id = tablet[2]
- (code, out, err) =
be_get_compaction_status(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id), tablet_id)
+ def (code, out, err) =
be_get_compaction_status(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id), tablet_id)
logger.info("Get compaction status: code=" + code + ",
out=" + out + ", err=" + err)
assertEquals(code, 0)
def compactionStatus = parseJson(out.trim())
diff --git
a/regression-test/suites/schema_change_p0/test_uniq_keys_schema_change.groovy
b/regression-test/suites/schema_change_p0/test_uniq_keys_schema_change.groovy
index 3375af18a8..5a12e07d74 100644
---
a/regression-test/suites/schema_change_p0/test_uniq_keys_schema_change.groovy
+++
b/regression-test/suites/schema_change_p0/test_uniq_keys_schema_change.groovy
@@ -27,7 +27,7 @@ suite ("test_uniq_keys_schema_change") {
getBackendIpHttpPort(backendId_to_backendIP,
backendId_to_backendHttpPort);
backend_id = backendId_to_backendIP.keySet()[0]
- (code, out, err) =
show_be_config(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id))
+ def (code, out, err) =
show_be_config(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id))
logger.info("Show config: code=" + code + ", out=" + out + ", err=" +
err)
assertEquals(code, 0)
@@ -139,7 +139,7 @@ suite ("test_uniq_keys_schema_change") {
String tablet_id = tablet[0]
backend_id = tablet[2]
logger.info("run compaction:" + tablet_id)
- (code, out, err) =
be_run_cumulative_compaction(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id), tablet_id)
+ def (code, out, err) =
be_run_cumulative_compaction(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id), tablet_id)
logger.info("Run compaction: code=" + code + ", out=" + out + ",
err=" + err)
//assertEquals(code, 0)
}
@@ -151,7 +151,7 @@ suite ("test_uniq_keys_schema_change") {
Thread.sleep(100)
String tablet_id = tablet[0]
backend_id = tablet[2]
- (code, out, err) =
be_get_compaction_status(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id), tablet_id)
+ def (code, out, err) =
be_get_compaction_status(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id), tablet_id)
logger.info("Get compaction status: code=" + code + ", out=" +
out + ", err=" + err)
assertEquals(code, 0)
def compactionStatus = parseJson(out.trim())
diff --git
a/regression-test/suites/schema_change_p0/test_uniq_mv_schema_change.groovy
b/regression-test/suites/schema_change_p0/test_uniq_mv_schema_change.groovy
index 535437bf4b..f872c38109 100644
--- a/regression-test/suites/schema_change_p0/test_uniq_mv_schema_change.groovy
+++ b/regression-test/suites/schema_change_p0/test_uniq_mv_schema_change.groovy
@@ -45,7 +45,7 @@ suite ("test_uniq_mv_schema_change") {
getBackendIpHttpPort(backendId_to_backendIP,
backendId_to_backendHttpPort);
backend_id = backendId_to_backendIP.keySet()[0]
- (code, out, err) =
show_be_config(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id))
+ def (code, out, err) =
show_be_config(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id))
logger.info("Show config: code=" + code + ", out=" + out + ", err=" +
err)
assertEquals(code, 0)
@@ -180,7 +180,7 @@ suite ("test_uniq_mv_schema_change") {
String tablet_id = tablet[0]
backend_id = tablet[2]
logger.info("run compaction:" + tablet_id)
- (code, out, err) =
be_run_cumulative_compaction(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id), tablet_id)
+ def (code, out, err) =
be_run_cumulative_compaction(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id), tablet_id)
logger.info("Run compaction: code=" + code + ", out=" + out + ",
err=" + err)
//assertEquals(code, 0)
}
@@ -192,7 +192,7 @@ suite ("test_uniq_mv_schema_change") {
Thread.sleep(100)
String tablet_id = tablet[0]
backend_id = tablet[2]
- (code, out, err) =
be_get_compaction_status(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id), tablet_id)
+ def (code, out, err) =
be_get_compaction_status(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id), tablet_id)
logger.info("Get compaction status: code=" + code + ", out=" +
out + ", err=" + err)
assertEquals(code, 0)
def compactionStatus = parseJson(out.trim())
diff --git
a/regression-test/suites/schema_change_p0/test_uniq_rollup_schema_change.groovy
b/regression-test/suites/schema_change_p0/test_uniq_rollup_schema_change.groovy
index b2b40b0bf6..d9d14dcb8e 100644
---
a/regression-test/suites/schema_change_p0/test_uniq_rollup_schema_change.groovy
+++
b/regression-test/suites/schema_change_p0/test_uniq_rollup_schema_change.groovy
@@ -49,7 +49,7 @@ suite ("test_uniq_rollup_schema_change") {
getBackendIpHttpPort(backendId_to_backendIP,
backendId_to_backendHttpPort);
backend_id = backendId_to_backendIP.keySet()[0]
- (code, out, err) =
show_be_config(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id))
+ def (code, out, err) =
show_be_config(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id))
logger.info("Show config: code=" + code + ", out=" + out + ", err=" +
err)
assertEquals(code, 0)
@@ -186,7 +186,7 @@ suite ("test_uniq_rollup_schema_change") {
String tablet_id = tablet[0]
backend_id = tablet[2]
logger.info("run compaction:" + tablet_id)
- (code, out, err) =
be_run_cumulative_compaction(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id), tablet_id)
+ def (code, out, err) =
be_run_cumulative_compaction(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id), tablet_id)
logger.info("Run compaction: code=" + code + ", out=" + out + ",
err=" + err)
//assertEquals(code, 0)
}
@@ -198,7 +198,7 @@ suite ("test_uniq_rollup_schema_change") {
Thread.sleep(100)
String tablet_id = tablet[0]
backend_id = tablet[2]
- (code, out, err) =
be_get_compaction_status(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id), tablet_id)
+ def (code, out, err) =
be_get_compaction_status(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id), tablet_id)
logger.info("Get compaction status: code=" + code + ", out=" +
out + ", err=" + err)
assertEquals(code, 0)
def compactionStatus = parseJson(out.trim())
diff --git
a/regression-test/suites/schema_change_p0/test_uniq_vals_schema_change.groovy
b/regression-test/suites/schema_change_p0/test_uniq_vals_schema_change.groovy
index 87283f24d9..a831d2df15 100644
---
a/regression-test/suites/schema_change_p0/test_uniq_vals_schema_change.groovy
+++
b/regression-test/suites/schema_change_p0/test_uniq_vals_schema_change.groovy
@@ -29,7 +29,7 @@ suite ("test_uniq_vals_schema_change") {
getBackendIpHttpPort(backendId_to_backendIP,
backendId_to_backendHttpPort);
backend_id = backendId_to_backendIP.keySet()[0]
- (code, out, err) =
show_be_config(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id))
+ def (code, out, err) =
show_be_config(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id))
logger.info("Show config: code=" + code + ", out=" + out + ", err=" +
err)
assertEquals(code, 0)
@@ -147,7 +147,7 @@ suite ("test_uniq_vals_schema_change") {
String tablet_id = tablet[0]
backend_id = tablet[2]
logger.info("run compaction:" + tablet_id)
- (code, out, err) =
be_run_cumulative_compaction(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id), tablet_id)
+ def (code, out, err) =
be_run_cumulative_compaction(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id), tablet_id)
logger.info("Run compaction: code=" + code + ", out=" + out +
", err=" + err)
//assertEquals(code, 0)
}
@@ -159,7 +159,7 @@ suite ("test_uniq_vals_schema_change") {
Thread.sleep(100)
String tablet_id = tablet[0]
backend_id = tablet[2]
- (code, out, err) =
be_get_compaction_status(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id), tablet_id)
+ def (code, out, err) =
be_get_compaction_status(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id), tablet_id)
logger.info("Get compaction status: code=" + code + ",
out=" + out + ", err=" + err)
assertEquals(code, 0)
def compactionStatus = parseJson(out.trim())
diff --git
a/regression-test/suites/schema_change_p0/test_varchar_schema_change.groovy
b/regression-test/suites/schema_change_p0/test_varchar_schema_change.groovy
index e98ff259f5..643bc174be 100644
--- a/regression-test/suites/schema_change_p0/test_varchar_schema_change.groovy
+++ b/regression-test/suites/schema_change_p0/test_varchar_schema_change.groovy
@@ -33,7 +33,7 @@ suite ("test_varchar_schema_change") {
getBackendIpHttpPort(backendId_to_backendIP,
backendId_to_backendHttpPort);
backend_id = backendId_to_backendIP.keySet()[0]
- (code, out, err) =
show_be_config(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id))
+ def (code, out, err) =
show_be_config(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id))
logger.info("Show config: code=" + code + ", out=" + out + ", err=" +
err)
assertEquals(code, 0)
@@ -137,7 +137,7 @@ suite ("test_varchar_schema_change") {
String tablet_id = tablet[0]
backend_id = tablet[2]
logger.info("run compaction:" + tablet_id)
- (code, out, err) =
be_run_cumulative_compaction(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id), tablet_id)
+ def (code, out, err) =
be_run_cumulative_compaction(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id), tablet_id)
logger.info("Run compaction: code=" + code + ", out=" + out +
", err=" + err)
}
@@ -148,7 +148,7 @@ suite ("test_varchar_schema_change") {
Thread.sleep(100)
String tablet_id = tablet[0]
backend_id = tablet[2]
- (code, out, err) =
be_get_compaction_status(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id), tablet_id)
+ def (code, out, err) =
be_get_compaction_status(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id), tablet_id)
logger.info("Get compaction status: code=" + code + ",
out=" + out + ", err=" + err)
assertEquals(code, 0)
def compactionStatus = parseJson(out.trim())
diff --git
a/regression-test/suites/segcompaction_p2/test_segcompaction_agg_keys.groovy
b/regression-test/suites/segcompaction_p2/test_segcompaction_agg_keys.groovy
index 6e05c4edfc..409bfd89c3 100644
--- a/regression-test/suites/segcompaction_p2/test_segcompaction_agg_keys.groovy
+++ b/regression-test/suites/segcompaction_p2/test_segcompaction_agg_keys.groovy
@@ -32,7 +32,7 @@ suite("test_segcompaction_agg_keys") {
def backendId_to_backendHttpPort = [:]
getBackendIpHttpPort(backendId_to_backendIP,
backendId_to_backendHttpPort);
backend_id = backendId_to_backendIP.keySet()[0]
- (code, out, err) =
show_be_config(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id))
+ def (code, out, err) =
show_be_config(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id))
logger.info("Show config: code=" + code + ", out=" + out + ", err=" +
err)
assertEquals(code, 0)
diff --git
a/regression-test/suites/segcompaction_p2/test_segcompaction_agg_keys_index.groovy
b/regression-test/suites/segcompaction_p2/test_segcompaction_agg_keys_index.groovy
index 3dd6316541..596f70ca68 100644
---
a/regression-test/suites/segcompaction_p2/test_segcompaction_agg_keys_index.groovy
+++
b/regression-test/suites/segcompaction_p2/test_segcompaction_agg_keys_index.groovy
@@ -32,7 +32,7 @@ suite("test_segcompaction_agg_keys_index") {
def backendId_to_backendHttpPort = [:]
getBackendIpHttpPort(backendId_to_backendIP,
backendId_to_backendHttpPort);
backend_id = backendId_to_backendIP.keySet()[0]
- (code, out, err) =
show_be_config(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id))
+ def (code, out, err) =
show_be_config(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id))
logger.info("Show config: code=" + code + ", out=" + out + ", err=" +
err)
assertEquals(code, 0)
def configList = parseJson(out.trim())
diff --git
a/regression-test/suites/segcompaction_p2/test_segcompaction_dup_keys.groovy
b/regression-test/suites/segcompaction_p2/test_segcompaction_dup_keys.groovy
index bd1bb06c58..6dcea441f0 100644
--- a/regression-test/suites/segcompaction_p2/test_segcompaction_dup_keys.groovy
+++ b/regression-test/suites/segcompaction_p2/test_segcompaction_dup_keys.groovy
@@ -33,7 +33,7 @@ suite("test_segcompaction_dup_keys") {
getBackendIpHttpPort(backendId_to_backendIP,
backendId_to_backendHttpPort);
backend_id = backendId_to_backendIP.keySet()[0]
- (code, out, err) =
show_be_config(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id))
+ def (code, out, err) =
show_be_config(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id))
logger.info("Show config: code=" + code + ", out=" + out + ", err=" +
err)
assertEquals(code, 0)
diff --git
a/regression-test/suites/segcompaction_p2/test_segcompaction_dup_keys_index.groovy
b/regression-test/suites/segcompaction_p2/test_segcompaction_dup_keys_index.groovy
index b5b4d8eb8e..b2ef39c64b 100644
---
a/regression-test/suites/segcompaction_p2/test_segcompaction_dup_keys_index.groovy
+++
b/regression-test/suites/segcompaction_p2/test_segcompaction_dup_keys_index.groovy
@@ -33,7 +33,7 @@ suite("test_segcompaction_dup_keys_index") {
getBackendIpHttpPort(backendId_to_backendIP,
backendId_to_backendHttpPort);
backend_id = backendId_to_backendIP.keySet()[0]
- (code, out, err) =
show_be_config(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id))
+ def (code, out, err) =
show_be_config(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id))
logger.info("Show config: code=" + code + ", out=" + out + ", err=" +
err)
assertEquals(code, 0)
def configList = parseJson(out.trim())
diff --git
a/regression-test/suites/segcompaction_p2/test_segcompaction_unique_keys.groovy
b/regression-test/suites/segcompaction_p2/test_segcompaction_unique_keys.groovy
index 9e5308314f..5e31abfd22 100644
---
a/regression-test/suites/segcompaction_p2/test_segcompaction_unique_keys.groovy
+++
b/regression-test/suites/segcompaction_p2/test_segcompaction_unique_keys.groovy
@@ -33,7 +33,7 @@ suite("test_segcompaction_unique_keys") {
getBackendIpHttpPort(backendId_to_backendIP,
backendId_to_backendHttpPort);
backend_id = backendId_to_backendIP.keySet()[0]
- (code, out, err) =
show_be_config(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id))
+ def (code, out, err) =
show_be_config(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id))
logger.info("Show config: code=" + code + ", out=" + out + ", err=" +
err)
assertEquals(code, 0)
diff --git
a/regression-test/suites/segcompaction_p2/test_segcompaction_unique_keys_index.groovy
b/regression-test/suites/segcompaction_p2/test_segcompaction_unique_keys_index.groovy
index 8bd6e3d7b4..0cbb33c39c 100644
---
a/regression-test/suites/segcompaction_p2/test_segcompaction_unique_keys_index.groovy
+++
b/regression-test/suites/segcompaction_p2/test_segcompaction_unique_keys_index.groovy
@@ -33,7 +33,7 @@ suite("test_segcompaction_unique_keys_index") {
getBackendIpHttpPort(backendId_to_backendIP,
backendId_to_backendHttpPort);
backend_id = backendId_to_backendIP.keySet()[0]
- (code, out, err) =
show_be_config(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id))
+ def (code, out, err) =
show_be_config(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id))
logger.info("Show config: code=" + code + ", out=" + out + ", err=" +
err)
assertEquals(code, 0)
def configList = parseJson(out.trim())
diff --git
a/regression-test/suites/segcompaction_p2/test_segcompaction_unique_keys_mow.groovy
b/regression-test/suites/segcompaction_p2/test_segcompaction_unique_keys_mow.groovy
index 2f35a1fec0..d1a7e77406 100644
---
a/regression-test/suites/segcompaction_p2/test_segcompaction_unique_keys_mow.groovy
+++
b/regression-test/suites/segcompaction_p2/test_segcompaction_unique_keys_mow.groovy
@@ -33,7 +33,7 @@ suite("test_segcompaction_unique_keys_mow") {
getBackendIpHttpPort(backendId_to_backendIP,
backendId_to_backendHttpPort);
backend_id = backendId_to_backendIP.keySet()[0]
- (code, out, err) =
show_be_config(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id))
+ def (code, out, err) =
show_be_config(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id))
logger.info("Show config: code=" + code + ", out=" + out + ", err=" +
err)
assertEquals(code, 0)
diff --git
a/regression-test/suites/segcompaction_p2/test_segcompaction_unique_keys_mow_index.groovy
b/regression-test/suites/segcompaction_p2/test_segcompaction_unique_keys_mow_index.groovy
index 0eaca8dc80..628ac6dffd 100644
---
a/regression-test/suites/segcompaction_p2/test_segcompaction_unique_keys_mow_index.groovy
+++
b/regression-test/suites/segcompaction_p2/test_segcompaction_unique_keys_mow_index.groovy
@@ -33,7 +33,7 @@ suite("test_segcompaction_unique_keys_mow_index") {
getBackendIpHttpPort(backendId_to_backendIP,
backendId_to_backendHttpPort);
backend_id = backendId_to_backendIP.keySet()[0]
- (code, out, err) =
show_be_config(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id))
+ def (code, out, err) =
show_be_config(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id))
logger.info("Show config: code=" + code + ", out=" + out + ", err=" +
err)
assertEquals(code, 0)
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
