[Improve] Delete duplicate code (#262)

apache · Jan 10, 2025 · 894e9dc · 894e9dc
1 parent 7084272
commit 894e9dc
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/...main/java/org/apache/seatunnel/app/thirdparty/engine/SeaTunnelEngineMetricsExtractor.java b/...main/java/org/apache/seatunnel/app/thirdparty/engine/SeaTunnelEngineMetricsExtractor.java
@@ -98,8 +98,7 @@ public List<JobMetrics> getMetricsByJobEngineId(@NonNull String jobEngineId) {
                 return new ArrayList<>();
             }
 
-            JsonNode jsonNode =
-                    JsonUtils.stringToJsonNode(seaTunnelEngineProxy.getMetricsContent(jobEngineId));
+            JsonNode jsonNode = JsonUtils.stringToJsonNode(metricsContent);
             LinkedHashMap<Integer, JobMetrics> metricsMap =
                     extractMetrics(jobPipelineStatus, jsonNode);
             return Arrays.asList(metricsMap.values().toArray(new JobMetrics[0]));