(seatunnel) branch dev updated: [Feature][rest-api] Add whether master node identifier (#7603)

[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 9ba94b6a61 [Feature][rest-api] Add whether master node identifier 
(#7603)
9ba94b6a61 is described below

commit 9ba94b6a61299081d602fe417cf3e69992e09bfd
Author: Guangdong Liu <804167...@qq.com>
AuthorDate: Wed Sep 11 10:03:45 2024 +0800

    [Feature][rest-api] Add whether master node identifier (#7603)
---
 .../src/test/java/org/apache/seatunnel/engine/e2e/RestApiIT.java     | 1 +
 .../org/apache/seatunnel/engine/server/SeaTunnelHealthMonitor.java   | 5 +++++
 2 files changed, 6 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 61ea25981f..5e912e845f 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
@@ -390,6 +390,7 @@ public class RestApiIT {
                                     .time(lessThan(5000L))
                                     .body("[0].host", equalTo("localhost"))
                                     .body("[0].port", notNullValue())
+                                    .body("[0].isMaster", 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 f7489b2c75..10b3bb6a5a 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);
+            isMasterFlag();
             ipPort();
             renderProcessors();
             renderPhysicalMemory();
@@ -226,6 +227,10 @@ public class SeaTunnelHealthMonitor {
             sb.append("port=").append(node.address.getPort()).append(", ");
         }
 
+        private void isMasterFlag() {
+            sb.append("isMaster=").append(node.isMaster()).append(", ");
+        }
+
         private void renderConnection() {
             sb.append("connection.active.count=")
                     .append(tcpConnectionActiveCount.read())