This is an automated email from the ASF dual-hosted git repository.

hello-stephen 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 6fed3e17814 [fix](test) filter joined FEs in sql cache case (#65098)
6fed3e17814 is described below

commit 6fed3e1781465ec0b31a352a2d328b62133b2fa0
Author: shuke <[email protected]>
AuthorDate: Thu Jul 2 10:19:08 2026 +0800

    [fix](test) filter joined FEs in sql cache case (#65098)
---
 .../suites/query_p0/cache/parse_sql_from_sql_cache.groovy | 15 +++++++++------
 1 file changed, 9 insertions(+), 6 deletions(-)

diff --git 
a/regression-test/suites/query_p0/cache/parse_sql_from_sql_cache.groovy 
b/regression-test/suites/query_p0/cache/parse_sql_from_sql_cache.groovy
index 812249ff15f..c12ccf50273 100644
--- a/regression-test/suites/query_p0/cache/parse_sql_from_sql_cache.groovy
+++ b/regression-test/suites/query_p0/cache/parse_sql_from_sql_cache.groovy
@@ -702,19 +702,22 @@ suite("parse_sql_from_sql_cache") {
                 }),
                 extraThread("testMultiFrontends", {
                     retryTestSqlCache(3, 1000) {
-                        def aliveFrontends = sql_return_maparray("show 
frontends")
+                        def aliveJoinedFrontends = sql_return_maparray("show 
frontends")
                                 .stream()
-                                .filter { 
it["Alive"].toString().equalsIgnoreCase("true") }
+                                .filter {
+                                    
it["Alive"].toString().equalsIgnoreCase("true")
+                                            && 
it["Join"].toString().equalsIgnoreCase("true")
+                                }
                                 .collect(Collectors.toList())
 
-                        if (aliveFrontends.size() <= 1) {
+                        if (aliveJoinedFrontends.size() <= 1) {
                             return
                         }
 
-                        def fe1 = aliveFrontends[0]["Host"] + ":" + 
aliveFrontends[0]["QueryPort"]
+                        def fe1 = aliveJoinedFrontends[0]["Host"] + ":" + 
aliveJoinedFrontends[0]["QueryPort"]
                         def fe2 = fe1
-                        if (aliveFrontends.size() > 1) {
-                            fe2 = aliveFrontends[1]["Host"] + ":" + 
aliveFrontends[1]["QueryPort"]
+                        if (aliveJoinedFrontends.size() > 1) {
+                            fe2 = aliveJoinedFrontends[1]["Host"] + ":" + 
aliveJoinedFrontends[1]["QueryPort"]
                         }
 
                         log.info("fe1: ${fe1}")


---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to