This is an automated email from the ASF dual-hosted git repository.
kxiao 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 5c9785045f [Fix](Full compaction) Fix local variable using in test
case (#24440)
5c9785045f is described below
commit 5c9785045f72a64711b2ddc132b20aa14960a88a
Author: abmdocrt <yukang.lian2...@gmail.com>
AuthorDate: Sun Sep 17 00:08:32 2023 +0800
[Fix](Full compaction) Fix local variable using in test case (#24440)
---
.../compaction/test_full_compaction_by_table_id.groovy | 16 ++++++++--------
1 file changed, 8 insertions(+), 8 deletions(-)
diff --git
a/regression-test/suites/compaction/test_full_compaction_by_table_id.groovy
b/regression-test/suites/compaction/test_full_compaction_by_table_id.groovy
index dc3c47c5a3..cd721774c2 100644
--- a/regression-test/suites/compaction/test_full_compaction_by_table_id.groovy
+++ b/regression-test/suites/compaction/test_full_compaction_by_table_id.groovy
@@ -50,7 +50,7 @@ suite("test_full_compaction_by_table_id") {
`user_id` INT NOT NULL, `value` INT NOT NULL)
UNIQUE KEY(`user_id`)
DISTRIBUTED BY HASH(`user_id`)
- BUCKETS 32
+ BUCKETS 8
PROPERTIES ("replication_allocation" = "tag.location.default: 1",
"disable_auto_compaction" = "true",
"enable_unique_key_merge_on_write" = "true");"""
@@ -105,7 +105,7 @@ suite("test_full_compaction_by_table_id") {
// before full compaction, there are 7 rowsets in all tablets.
for (int i=0; i<tablets.size(); ++i) {
int rowsetCount = 0
- (code, out, err) = curl("GET", tablets[i][18])
+ def (code, out, err) = curl("GET", tablets[i][18])
logger.info("Show tablets status: code=" + code + ", out=" + out +
", err=" + err)
assertEquals(code, 0)
def tabletJson = parseJson(out.trim())
@@ -120,10 +120,10 @@ suite("test_full_compaction_by_table_id") {
String tablet_id = tablets[i][0]
String[][] tablet_info = sql """ show tablet ${tablet_id}; """
logger.info("tablet"+tablet_info)
- table_id = tablet_info[0][5]
+ def table_id = tablet_info[0][5]
backend_id = tablets[i][2]
- times = 1
-
+ def times = 1
+ def code, out, err
do{
(code, out, err) =
be_run_full_compaction_by_table_id(backendId_to_backendIP.get(backend_id),
backendId_to_backendHttpPort.get(backend_id), table_id)
logger.info("Run compaction: code=" + code + ", out=" + out +
", err=" + err)
@@ -147,9 +147,9 @@ suite("test_full_compaction_by_table_id") {
boolean running = true
do {
Thread.sleep(1000)
- tablet_id = tablets[i][0]
+ def tablet_id = tablets[i][0]
backend_id = tablets[i][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())
@@ -163,7 +163,7 @@ suite("test_full_compaction_by_table_id") {
for (int i=0; i<tablets.size(); ++i) {
int rowsetCount = 0
- (code, out, err) = curl("GET", tablets[i][18])
+ def (code, out, err) = curl("GET", tablets[i][18])
logger.info("Show tablets status: code=" + code + ", out=" + out +
", err=" + err)
assertEquals(code, 0)
def tabletJson = parseJson(out.trim())
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
