8

xinyiZzz · Sep 19, 2023 · cebb67f · cebb67f
1 parent 141f403
commit cebb67f
Show file tree

Hide file tree

Showing 7 changed files with 8 additions and 5 deletions.
diff --git a/fe/fe-core/src/main/java/org/apache/doris/tablefunction/MetadataGenerator.java b/fe/fe-core/src/main/java/org/apache/doris/tablefunction/MetadataGenerator.java
@@ -188,6 +188,7 @@ private static TFetchSchemaTableDataResult backendsMetadataResult(TMetadataTable
                 trow.addToColumnValue(new TCell().setIntVal(backend.getBePort()));
                 trow.addToColumnValue(new TCell().setIntVal(backend.getHttpPort()));
                 trow.addToColumnValue(new TCell().setIntVal(backend.getBrpcPort()));
+                trow.addToColumnValue(new TCell().setIntVal(backend.getArrowFlightSqlPort()));
             }
             trow.addToColumnValue(new TCell().setStringVal(TimeUtils.longToTimeString(backend.getLastStartTime())));
             trow.addToColumnValue(new TCell().setStringVal(TimeUtils.longToTimeString(backend.getLastUpdateMs())));

diff --git a/regression-test/data/performance_p0/redundant_conjuncts.out b/regression-test/data/performance_p0/redundant_conjuncts.out
@@ -6,6 +6,7 @@ PLAN FRAGMENT 0
   PARTITION: HASH_PARTITIONED: `default_cluster:regression_test_performance_p0`.`redundant_conjuncts`.`k1`
 
   VRESULT SINK
+     MYSQL_PROTOCAL
 
   0:VOlapScanNode
      TABLE: default_cluster:regression_test_performance_p0.redundant_conjuncts(redundant_conjuncts), PREAGGREGATION: OFF. Reason: No AggregateInfo
@@ -21,6 +22,7 @@ PLAN FRAGMENT 0
   PARTITION: HASH_PARTITIONED: `default_cluster:regression_test_performance_p0`.`redundant_conjuncts`.`k1`
 
   VRESULT SINK
+     MYSQL_PROTOCAL
 
   0:VOlapScanNode
      TABLE: default_cluster:regression_test_performance_p0.redundant_conjuncts(redundant_conjuncts), PREAGGREGATION: OFF. Reason: No AggregateInfo

diff --git a/regression-test/suites/demo_p0/httpTest_action.groovy b/regression-test/suites/demo_p0/httpTest_action.groovy
@@ -24,7 +24,7 @@ suite("http_test_action") {
     def backendIdToBackendIP = [:]
     def backendIdToBackendBrpcPort = [:]
     for (String[] backend in backends) {
-        if (backend[8].equals("true")) {
+        if (backend[9].equals("true")) {
             backendIdToBackendIP.put(backend[0], backend[1])
             backendIdToBackendBrpcPort.put(backend[0], backend[5])
         }

diff --git a/regression-test/suites/external_table_p0/tvf/test_backends_tvf.groovy b/regression-test/suites/external_table_p0/tvf/test_backends_tvf.groovy
@@ -19,7 +19,7 @@
 suite("test_backends_tvf","p0,external,tvf,external_docker") {
     List<List<Object>> table =  sql """ select * from backends(); """
     assertTrue(table.size() > 0)
-    assertEquals(24, table[0].size)
+    assertEquals(25, table[0].size)
 
     // filter columns
     table = sql """ select BackendId, Host, Alive, TotalCapacity, Version, NodeRole from backends();"""

diff --git a/regression-test/suites/external_table_p0/tvf/test_frontends_tvf.groovy b/regression-test/suites/external_table_p0/tvf/test_frontends_tvf.groovy
@@ -19,7 +19,7 @@
 suite("test_frontends_tvf","p0,external,tvf,external_docker") {
     List<List<Object>> table =  sql """ select * from `frontends`(); """
     assertTrue(table.size() > 0)
-    assertTrue(table[0].size == 17)
+    assertTrue(table[0].size == 18)
 
     // filter columns
     table = sql """ select Name from `frontends`();"""

diff --git a/regression-test/suites/load_p0/stream_load/test_map_load_and_compaction.groovy b/regression-test/suites/load_p0/stream_load/test_map_load_and_compaction.groovy
@@ -134,7 +134,7 @@ suite("test_map_load_and_compaction", "p0") {
         backends = sql """ show backends; """
         assertTrue(backends.size() > 0)
         for (String[] b : backends) {
-            assertEquals("true", b[8])
+            assertEquals("true", b[9])
         }
     } finally {
         try_sql("DROP TABLE IF EXISTS ${testTable}")

diff --git a/regression-test/suites/nereids_syntax_p0/information_schema.groovy b/regression-test/suites/nereids_syntax_p0/information_schema.groovy
@@ -18,7 +18,7 @@
 suite("information_schema") {
     List<List<Object>> table =  sql """ select * from backends(); """
     assertTrue(table.size() > 0)
-    assertTrue(table[0].size == 24)
+    assertTrue(table[0].size == 25)
 
     sql "SELECT DATABASE();"
     sql "select USER();"