[Improve][Restapi] Add ip and port to monitoring information (apache#…

…7203)
jovezhong · Jul 22, 2024 · 063f83c · 063f83c
1 parent c4ca741
commit 063f83c
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 0 deletions.
diff --git a/...connector-seatunnel-e2e-base/src/test/java/org/apache/seatunnel/engine/e2e/RestApiIT.java b/...connector-seatunnel-e2e-base/src/test/java/org/apache/seatunnel/engine/e2e/RestApiIT.java
@@ -306,6 +306,8 @@ public void testSystemMonitoringInformation() {
                                     .then()
                                     .assertThat()
                                     .time(lessThan(5000L))
+                                    .body("[0].host", equalTo("localhost"))
+                                    .body("[0].port", notNullValue())
                                     .statusCode(200);
                         });
     }

diff --git a/...ngine-server/src/main/java/org/apache/seatunnel/engine/server/SeaTunnelHealthMonitor.java b/...ngine-server/src/main/java/org/apache/seatunnel/engine/server/SeaTunnelHealthMonitor.java
@@ -202,6 +202,7 @@ boolean exceedsThreshold() {
         public String render() {
             update();
             sb.setLength(0);
+            ipPort();
             renderProcessors();
             renderPhysicalMemory();
             renderSwap();
@@ -220,6 +221,11 @@ public String render() {
             return sb.toString();
         }
 
+        private void ipPort() {
+            sb.append("host=").append(node.address.getHost()).append(", ");
+            sb.append("port=").append(node.address.getPort()).append(", ");
+        }
+
         private void renderConnection() {
             sb.append("connection.active.count=")
                     .append(tcpConnectionActiveCount.read())