[zeta][telemetry] fix job thread metrics bug

apache · Aug 9, 2023 · d307fea · d307fea
1 parent 284dd33
commit d307fea
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 3 deletions.
diff --git a/...unnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/SeaTunnelServer.java b/...unnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/SeaTunnelServer.java
@@ -25,6 +25,7 @@
 import org.apache.seatunnel.engine.server.execution.TaskGroupLocation;
 import org.apache.seatunnel.engine.server.service.slot.DefaultSlotService;
 import org.apache.seatunnel.engine.server.service.slot.SlotService;
+import org.apache.seatunnel.engine.server.telemetry.metrics.entity.ThreadPoolStatus;
 
 import com.hazelcast.internal.services.ManagedService;
 import com.hazelcast.internal.services.MembershipAwareService;
@@ -253,4 +254,8 @@ private void printExecutionInfo() {
             coordinatorService.printJobDetailInfo();
         }
     }
+
+    public ThreadPoolStatus getThreadPoolStatusMetrics() {
+        return coordinatorService.getThreadPoolStatusMetrics();
+    }
 }
diff --git a/.../apache/seatunnel/engine/server/telemetry/metrics/exports/JobThreadPoolStatusExports.java b/.../apache/seatunnel/engine/server/telemetry/metrics/exports/JobThreadPoolStatusExports.java
@@ -17,7 +17,6 @@
 
 package org.apache.seatunnel.engine.server.telemetry.metrics.exports;
 
-import org.apache.seatunnel.engine.server.CoordinatorService;
 import org.apache.seatunnel.engine.server.telemetry.metrics.AbstractCollector;
 import org.apache.seatunnel.engine.server.telemetry.metrics.entity.ThreadPoolStatus;
 
@@ -40,11 +39,10 @@ public JobThreadPoolStatusExports(Node node) {
     @Override
     public List<MetricFamilySamples> collect() {
         List<MetricFamilySamples> mfs = new ArrayList();
-        CoordinatorService coordinatorService = getCoordinatorService();
 
         List<String> labelValues = labelValues(localAddress());
 
-        ThreadPoolStatus threadPoolStatusMetrics = coordinatorService.getThreadPoolStatusMetrics();
+        ThreadPoolStatus threadPoolStatusMetrics = getServer().getThreadPoolStatusMetrics();
         List<String> labelNames = clusterLabelNames(ADDRESS);
 
         GaugeMetricFamily activeCount =