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 88264b3e7b [regression-test](unique) Check the table version upper 1
before select operation. #13205
88264b3e7b is described below
commit 88264b3e7b55c2a2950cf56a03f71f9d92cd2f83
Author: Hong Liu <844981...@qq.com>
AuthorDate: Tue Oct 11 15:44:17 2022 +0800
[regression-test](unique) Check the table version upper 1 before select
operation. #13205
Co-authored-by: smallhibiscus <8449081...@qq.com>
---
.../four/load_four_step.groovy | 23 ++++++++++++++++++----
.../one/load_one_step.groovy | 23 ++++++++++++++++++----
.../three/load_three_step.groovy | 23 ++++++++++++++++++----
.../two/load_two_step.groovy | 23 ++++++++++++++++++----
4 files changed, 76 insertions(+), 16 deletions(-)
diff --git
a/regression-test/suites/primary_index/ssb_unique_load_zstd_p0/four/load_four_step.groovy
b/regression-test/suites/primary_index/ssb_unique_load_zstd_p0/four/load_four_step.groovy
index b3f5853388..5fbd0d88e0 100644
---
a/regression-test/suites/primary_index/ssb_unique_load_zstd_p0/four/load_four_step.groovy
+++
b/regression-test/suites/primary_index/ssb_unique_load_zstd_p0/four/load_four_step.groovy
@@ -56,10 +56,25 @@ suite("load_four_step") {
}
}
sql 'sync'
- for (int i = 1; i <= 5; i++) {
- def loadRowCount = sql "select count(1) from ${tableName}"
- logger.info("select ${tableName} numbers:
${loadRowCount[0][0]}".toString())
- assertTrue(loadRowCount[0][0] == rows[1])
+ int flag = 1
+ while (flag < 30){
+ def tableVersion = sql "admin show replica status from
${tableName}"
+ logger.info(" ${tableName} version:
${tableVersion[0][3]}".toString())
+ if (tableVersion[0][3] > 1){
+ for (int i = 1; i <= 5; i++) {
+ def loadRowCount = sql "select count(1) from
${tableName}"
+ logger.info("select ${tableName} numbers:
${loadRowCount[0][0]}".toString())
+ assertTrue(loadRowCount[0][0] == rows[1])
+ }
+ break
+ } else {
+ flag ++
+ sleep(1000)
+ }
+ }
+ if (flag >= 30){
+ logger.info("wait version timeout")
+ assertTrue(1 == 2)
}
}
sql """ set delete_without_partition = true; """
diff --git
a/regression-test/suites/primary_index/ssb_unique_load_zstd_p0/one/load_one_step.groovy
b/regression-test/suites/primary_index/ssb_unique_load_zstd_p0/one/load_one_step.groovy
index 68c8e98a88..eb8b5a7e9f 100644
---
a/regression-test/suites/primary_index/ssb_unique_load_zstd_p0/one/load_one_step.groovy
+++
b/regression-test/suites/primary_index/ssb_unique_load_zstd_p0/one/load_one_step.groovy
@@ -51,10 +51,25 @@ suite("load_one_step") {
}
}
sql 'sync'
- for (int i = 1; i <= 5; i++) {
- def loadRowCount = sql "select count(1) from ${tableName}"
- logger.info("select ${tableName} numbers:
${loadRowCount[0][0]}".toString())
- assertTrue(loadRowCount[0][0] == rows[1])
+ int flag = 1
+ while (flag < 30){
+ def tableVersion = sql "admin show replica status from
${tableName}"
+ logger.info(" ${tableName} version:
${tableVersion[0][3]}".toString())
+ if (tableVersion[0][3] > 1){
+ for (int i = 1; i <= 5; i++) {
+ def loadRowCount = sql "select count(1) from ${tableName}"
+ logger.info("select ${tableName} numbers:
${loadRowCount[0][0]}".toString())
+ assertTrue(loadRowCount[0][0] == rows[1])
+ }
+ break
+ } else {
+ flag ++
+ sleep(1000)
+ }
+ }
+ if (flag >= 30){
+ logger.info("wait version timeout")
+ assertTrue(1 == 2)
}
}
}
diff --git
a/regression-test/suites/primary_index/ssb_unique_load_zstd_p0/three/load_three_step.groovy
b/regression-test/suites/primary_index/ssb_unique_load_zstd_p0/three/load_three_step.groovy
index bbd9e0f4ba..672174d504 100644
---
a/regression-test/suites/primary_index/ssb_unique_load_zstd_p0/three/load_three_step.groovy
+++
b/regression-test/suites/primary_index/ssb_unique_load_zstd_p0/three/load_three_step.groovy
@@ -53,10 +53,25 @@ suite("load_three_step") {
}
}
sql 'sync'
- for (int i = 1; i <= 5; i++) {
- def loadRowCount = sql "select count(1) from ${tableName}"
- logger.info("select ${tableName} numbers:
${loadRowCount[0][0]}".toString())
- assertTrue(loadRowCount[0][0] == rows[1])
+ int flag = 1
+ while (flag < 30){
+ def tableVersion = sql "admin show replica status from
${tableName}"
+ logger.info(" ${tableName} version:
${tableVersion[0][3]}".toString())
+ if (tableVersion[0][3] > 1){
+ for (int i = 1; i <= 5; i++) {
+ def loadRowCount = sql "select count(1) from
${tableName}"
+ logger.info("select ${tableName} numbers:
${loadRowCount[0][0]}".toString())
+ assertTrue(loadRowCount[0][0] == rows[1])
+ }
+ break
+ } else {
+ flag ++
+ sleep(1000)
+ }
+ }
+ if (flag >= 30){
+ logger.info("wait version timeout")
+ assertTrue(1 == 2)
}
}
sql new
File("""${context.file.parentFile.parent}/ddl/${tableName}_delete.sql""").text
diff --git
a/regression-test/suites/primary_index/ssb_unique_load_zstd_p0/two/load_two_step.groovy
b/regression-test/suites/primary_index/ssb_unique_load_zstd_p0/two/load_two_step.groovy
index 4e2e7ae3b8..ade9581fd1 100644
---
a/regression-test/suites/primary_index/ssb_unique_load_zstd_p0/two/load_two_step.groovy
+++
b/regression-test/suites/primary_index/ssb_unique_load_zstd_p0/two/load_two_step.groovy
@@ -52,10 +52,25 @@ suite("load_two_step") {
}
}
sql 'sync'
- for (int i = 1; i <= 5; i++) {
- def loadRowCount = sql "select count(1) from ${tableName}"
- logger.info("select ${tableName} numbers:
${loadRowCount[0][0]}".toString())
- assertTrue(loadRowCount[0][0] == rows[1])
+ int flag = 1
+ while (flag < 30){
+ def tableVersion = sql "admin show replica status from
${tableName}"
+ logger.info(" ${tableName} version:
${tableVersion[0][3]}".toString())
+ if (tableVersion[0][3] > 1){
+ for (int i = 1; i <= 5; i++) {
+ def loadRowCount = sql "select count(1) from ${tableName}"
+ logger.info("select ${tableName} numbers:
${loadRowCount[0][0]}".toString())
+ assertTrue(loadRowCount[0][0] == rows[1])
+ }
+ break
+ } else {
+ flag ++
+ sleep(1000)
+ }
+ }
+ if (flag >= 30){
+ logger.info("wait version timeout")
+ assertTrue(1 == 2)
}
sql new
File("""${context.file.parentFile.parent}/ddl/${tableName}_delete.sql""").text
for (int i = 1; i <= 5; i++) {
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
