(seatunnel) branch dev updated: [Improve][Restapi] Add ip and port to monitoring information (#7203)

[wanghailin]

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

wanghailin pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/seatunnel.git


The following commit(s) were added to refs/heads/dev by this push:
     new 063f83ca6c [Improve][Restapi] Add ip and port to monitoring 
information (#7203)
063f83ca6c is described below

commit 063f83ca6cf97c0b574dda22c7908e81014cb165
Author: Guangdong Liu <804167...@qq.com>
AuthorDate: Mon Jul 22 10:40:58 2024 +0800

    [Improve][Restapi] Add ip and port to monitoring information (#7203)
---
 .../src/test/java/org/apache/seatunnel/engine/e2e/RestApiIT.java    | 2 ++
 .../org/apache/seatunnel/engine/server/SeaTunnelHealthMonitor.java  | 6 ++++++
 2 files changed, 8 insertions(+)

diff --git 
a/seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/java/org/apache/seatunnel/engine/e2e/RestApiIT.java
 
b/seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/java/org/apache/seatunnel/engine/e2e/RestApiIT.java
index 71b903ca16..bc7a030c40 100644
--- 
a/seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/java/org/apache/seatunnel/engine/e2e/RestApiIT.java
+++ 
b/seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/java/org/apache/seatunnel/engine/e2e/RestApiIT.java
@@ -306,6 +306,8 @@ public class RestApiIT {
                                     .then()
                                     .assertThat()
                                     .time(lessThan(5000L))
+                                    .body("[0].host", equalTo("localhost"))
+                                    .body("[0].port", notNullValue())
                                     .statusCode(200);
                         });
     }
diff --git 
a/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/SeaTunnelHealthMonitor.java
 
b/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/SeaTunnelHealthMonitor.java
index 2adf87aa41..f7489b2c75 100644
--- 
a/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/SeaTunnelHealthMonitor.java
+++ 
b/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/SeaTunnelHealthMonitor.java
@@ -202,6 +202,7 @@ public class SeaTunnelHealthMonitor {
         public String render() {
             update();
             sb.setLength(0);
+            ipPort();
             renderProcessors();
             renderPhysicalMemory();
             renderSwap();
@@ -220,6 +221,11 @@ public class SeaTunnelHealthMonitor {
             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())