This is an automated email from the ASF dual-hosted git repository.
dataroaring pushed a commit to branch branch-3.0
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-3.0 by this push:
new d529627fe8d [fix](docker case) Enhance the robustness of
test_multi_follower case #42149 (#42391)
d529627fe8d is described below
commit d529627fe8d14316bd5d28b2e6454f5db2c6af0e
Author: deardeng <[email protected]>
AuthorDate: Mon Oct 28 10:25:05 2024 +0800
[fix](docker case) Enhance the robustness of test_multi_follower case
#42149 (#42391)
cherry pick from #42149
---
.../suites/cloud_p0/multi_cluster/test_multi_follower.groovy | 8 +++++---
1 file changed, 5 insertions(+), 3 deletions(-)
diff --git
a/regression-test/suites/cloud_p0/multi_cluster/test_multi_follower.groovy
b/regression-test/suites/cloud_p0/multi_cluster/test_multi_follower.groovy
index 864655a5344..792e2a98b24 100644
--- a/regression-test/suites/cloud_p0/multi_cluster/test_multi_follower.groovy
+++ b/regression-test/suites/cloud_p0/multi_cluster/test_multi_follower.groovy
@@ -82,10 +82,12 @@ suite('test_multi_followr_in_cloud', 'multi_cluster,
docker') {
log.info("show frontends: {}", ret)
ret.size() == 4
}
+ def connectedUrl =
context.threadLocalConn.get().conn.getMetaData().getURL()
+ log.info("current connected url {}", connectedUrl)
check(4) { def ret ->
ret.each {
assertTrue(it.Role.contains(f))
- if (!Boolean.parseBoolean(it.IsMaster)) {
+ if (!Boolean.parseBoolean(it.IsMaster) &&
!connectedUrl.contains(it.Host)) {
toDropIP = it.Host
toDropPort = it.EditLogPort
toDropType = transferType(it.Role)
@@ -117,7 +119,7 @@ suite('test_multi_followr_in_cloud', 'multi_cluster,
docker') {
drop_node(toDropUniqueId, toDropIP, 0,
toDropPort, toDropType, feClusterName, feClusterId, ms)
- dockerAwaitUntil(5) {
+ dockerAwaitUntil(50) {
def ret = sql """SHOW FRONTENDS"""
log.info("show frontends: {}", ret)
ret.size() == 3
@@ -153,7 +155,7 @@ suite('test_multi_followr_in_cloud', 'multi_cluster,
docker') {
drop_node(toDropUniqueId, toDropIP, 0,
toDropPort, toDropType, feClusterName, feClusterId, ms)
- dockerAwaitUntil(5) {
+ dockerAwaitUntil(50) {
def ret = sql """SHOW FRONTENDS"""
log.info("show frontends: {}", ret)
ret.size() == 3
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
