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 7fd008946f3 [fix](regression-test) fix unstable test (#33628)
7fd008946f3 is described below
commit 7fd008946f31a07a715b5333b36243fca0213bc2
Author: 924060929 <[email protected]>
AuthorDate: Sun Apr 14 16:54:19 2024 +0800
[fix](regression-test) fix unstable test (#33628)
---
.../nereids_p0/cache/parse_sql_from_sql_cache.groovy | 18 ++++++++++++++++--
1 file changed, 16 insertions(+), 2 deletions(-)
diff --git
a/regression-test/suites/nereids_p0/cache/parse_sql_from_sql_cache.groovy
b/regression-test/suites/nereids_p0/cache/parse_sql_from_sql_cache.groovy
index 7523df43f0c..0a318218301 100644
--- a/regression-test/suites/nereids_p0/cache/parse_sql_from_sql_cache.groovy
+++ b/regression-test/suites/nereids_p0/cache/parse_sql_from_sql_cache.groovy
@@ -226,7 +226,7 @@ suite("parse_sql_from_sql_cache") {
sql "alter view test_use_plan_cache9_view as select id from
test_use_plan_cache9"
assertNoCache "select * from test_use_plan_cache9_view"
}),
- extraThread( "testDropView", {
+ extraThread("testDropView", {
createTestTable "test_use_plan_cache10"
sql "drop view if exists test_use_plan_cache10_view"
@@ -291,6 +291,8 @@ suite("parse_sql_from_sql_cache") {
sql "select * from test_use_plan_cache12"
assertHasCache "select * from test_use_plan_cache12"
+ sql "sync"
+
extraThread("test_cache_user1_thread", {
connect(user = "test_cache_user1", password="DORIS@2024") {
@@ -321,6 +323,8 @@ suite("parse_sql_from_sql_cache") {
// after partition changed 10s, the sql cache can be used
sleep(10000)
+ sql "sync"
+
extraThread("test_cache_user2_thread", {
connect(user = "test_cache_user2", password="DORIS@2024") {
sql "use ${dbName}"
@@ -342,6 +346,8 @@ suite("parse_sql_from_sql_cache") {
USING (id = 'concat(id, "**")')"""
sql "set enable_nereids_planner=true"
+ sql "sync"
+
// after row policy changed, the cache is invalidate
extraThread("test_cache_user2_thread2", {
connect(user = "test_cache_user2", password="DORIS@2024") {
@@ -377,6 +383,8 @@ suite("parse_sql_from_sql_cache") {
USING (id = 'concat(id, "**")')"""
sql "set enable_nereids_planner=true"
+ sql "sync"
+
// after partition changed 10s, the sql cache can be used
sleep(10000)
@@ -400,6 +408,8 @@ suite("parse_sql_from_sql_cache") {
FOR test_cache_user3"""
sql "set enable_nereids_planner=true"
+ sql "sync"
+
// after row policy changed, the cache is invalidate
extraThread("test_cache_user3_thread2", {
connect(user = "test_cache_user3", password="DORIS@2024") {
@@ -425,6 +435,8 @@ suite("parse_sql_from_sql_cache") {
sql "GRANT SELECT_PRIV ON regression_test.* TO test_cache_user4"
sql "GRANT SELECT_PRIV ON ${dbName}.test_use_plan_cache15 TO
test_cache_user4"
+ sql "sync"
+
extraThread("test_cache_user4_thread", {
connect(user = "test_cache_user4", password="DORIS@2024") {
sql "use ${dbName}"
@@ -440,6 +452,8 @@ suite("parse_sql_from_sql_cache") {
sql "REVOKE SELECT_PRIV ON ${dbName}.test_use_plan_cache15 FROM
test_cache_user4"
+ sql "sync"
+
// after privileges changed, the cache is invalidate
extraThread("test_cache_user4_thread2", {
connect(user = "test_cache_user4", password="DORIS@2024") {
@@ -484,7 +498,7 @@ suite("parse_sql_from_sql_cache") {
extraThread("testUserVariable", {
// make sure if the table has been dropped, the cache should
invalidate,
// so we should retry twice to check
- for (i in 0..2) {
+ for (def i in 0..2) {
createTestTable "test_use_plan_cache17"
// after partition changed 10s, the sql cache can be used
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
