This is an automated email from the ASF dual-hosted git repository.
dataroaring pushed a commit to branch branch-2.0
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-2.0 by this push:
new a8803fe6b84 [branch-2.0](regression test) fix
test_decommission_with_replica_num_fail due to concurrent run cases (#34841)
a8803fe6b84 is described below
commit a8803fe6b847221fc99904570c4f886e40274ce1
Author: yujun <[email protected]>
AuthorDate: Wed May 15 19:59:29 2024 +0800
[branch-2.0](regression test) fix test_decommission_with_replica_num_fail
due to concurrent run cases (#34841)
---
.../alter_p0/test_decommission_with_replica_num_fail.groovy | 11 ++++++++++-
regression-test/suites/node_p0/test_backend.groovy | 2 +-
2 files changed, 11 insertions(+), 2 deletions(-)
diff --git
a/regression-test/suites/alter_p0/test_decommission_with_replica_num_fail.groovy
b/regression-test/suites/alter_p0/test_decommission_with_replica_num_fail.groovy
index d7941591eec..0fb3ebbbbba 100644
---
a/regression-test/suites/alter_p0/test_decommission_with_replica_num_fail.groovy
+++
b/regression-test/suites/alter_p0/test_decommission_with_replica_num_fail.groovy
@@ -15,7 +15,7 @@
// specific language governing permissions and limitations
// under the License.
-suite('test_decommission_with_replica_num_fail') {
+suite('test_decommission_with_replica_num_fail', 'nonConcurrent') {
def tbl = 'test_decommission_with_replica_num_fail'
def backends = sql_return_maparray('show backends')
def replicaNum = 0
@@ -43,6 +43,11 @@ suite('test_decommission_with_replica_num_fail') {
"replication_num" = "${replicaNum}"
);
"""
+
+ // fix set force_olap_table_replication_num
+ sql "ALTER TABLE ${tbl} SET ('default.replication_num' = '${replicaNum}')"
+ sql "ALTER TABLE ${tbl} MODIFY PARTITION (*) SET ('replication_num' =
'${replicaNum}')"
+
try {
test {
sql "ALTER SYSTEM DECOMMISSION BACKEND
'${targetBackend.Host}:${targetBackend.HeartbeatPort}'"
@@ -50,6 +55,10 @@ suite('test_decommission_with_replica_num_fail') {
}
} finally {
sql "CANCEL DECOMMISSION BACKEND
'${targetBackend.Host}:${targetBackend.HeartbeatPort}'"
+ backends = sql_return_maparray('show backends')
+ for (def be : backends) {
+ logger.info("backend=${be}")
+ }
}
sql "DROP TABLE IF EXISTS ${tbl} FORCE"
}
diff --git a/regression-test/suites/node_p0/test_backend.groovy
b/regression-test/suites/node_p0/test_backend.groovy
index 4c85ff1b54a..f9699c786d4 100644
--- a/regression-test/suites/node_p0/test_backend.groovy
+++ b/regression-test/suites/node_p0/test_backend.groovy
@@ -15,7 +15,7 @@
// specific language governing permissions and limitations
// under the License.
-suite("test_backend") {
+suite("test_backend", "nonConcurrent") {
def address = "127.0.0.1"
def notExistPort = 12346
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
