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 71b903ca16d..bc7a030c406 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 void testSystemMonitoringInformation() { .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 2adf87aa412..f7489b2c755 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 @@ 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())