(seatunnel-web) branch main updated: [Chore] Code clean

[fanjia]

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

fanjia pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/seatunnel-web.git


The following commit(s) were added to refs/heads/main by this push:
     new 5bb86f76 [Chore] Code clean
5bb86f76 is described below

commit 5bb86f76d1632587821d444289e12da95634c8cd
Author: mr.z <54729175+zhangweike2...@users.noreply.github.com>
AuthorDate: Sun Aug 25 14:32:08 2024 +0800

    [Chore] Code clean
---
 .../app/thirdparty/engine/SeaTunnelEngineMetricsExtractor.java    | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git 
a/seatunnel-server/seatunnel-app/src/main/java/org/apache/seatunnel/app/thirdparty/engine/SeaTunnelEngineMetricsExtractor.java
 
b/seatunnel-server/seatunnel-app/src/main/java/org/apache/seatunnel/app/thirdparty/engine/SeaTunnelEngineMetricsExtractor.java
index 91607e07..c8426293 100644
--- 
a/seatunnel-server/seatunnel-app/src/main/java/org/apache/seatunnel/app/thirdparty/engine/SeaTunnelEngineMetricsExtractor.java
+++ 
b/seatunnel-server/seatunnel-app/src/main/java/org/apache/seatunnel/app/thirdparty/engine/SeaTunnelEngineMetricsExtractor.java
@@ -92,7 +92,7 @@ public class SeaTunnelEngineMetricsExtractor implements 
IEngineMetricsExtractor
 
     @Override
     public List<JobMetrics> getMetricsByJobEngineId(@NonNull String 
jobEngineId) {
-        LinkedHashMap<Integer, JobMetrics> metricsMap = new LinkedHashMap();
+        LinkedHashMap<Integer, JobMetrics> metricsMap = new LinkedHashMap<>();
 
         LinkedHashMap<Integer, String> jobPipelineStatus = 
getJobPipelineStatus(jobEngineId);
         try {
@@ -258,7 +258,7 @@ public class SeaTunnelEngineMetricsExtractor implements 
IEngineMetricsExtractor
             value = value.replace(" ", "");
             Map<String, String> otherMetrics = JsonUtils.toMap(value);
             for (String key : clusterHealthMetricsKeys) {
-                hostMetrics.put(key, otherMetrics.get(key).toString());
+                hostMetrics.put(key, otherMetrics.get(key));
             }
             zetaClusterMetrics.add(hostMetrics);
         }
@@ -267,7 +267,7 @@ public class SeaTunnelEngineMetricsExtractor implements 
IEngineMetricsExtractor
 
     @Override
     public Map<Integer, JobMetrics> getMetricsByJobEngineIdRTMap(@NonNull 
String jobEngineId) {
-        LinkedHashMap<Integer, JobMetrics> metricsMap = new LinkedHashMap();
+        LinkedHashMap<Integer, JobMetrics> metricsMap = new LinkedHashMap<>();
 
         LinkedHashMap<Integer, String> jobPipelineStatus = 
getJobPipelineStatus(jobEngineId);
         try {
@@ -370,7 +370,7 @@ public class SeaTunnelEngineMetricsExtractor implements 
IEngineMetricsExtractor
             JsonNode jsonNode = 
JsonUtils.stringToJsonNode(allJobMetricsContent);
             Iterator<JsonNode> iterator = jsonNode.iterator();
             while (iterator.hasNext()) {
-                LinkedHashMap<Integer, JobMetrics> metricsMap = new 
LinkedHashMap();
+                LinkedHashMap<Integer, JobMetrics> metricsMap = new 
LinkedHashMap<>();
                 JsonNode next = iterator.next();
 
                 JsonNode sourceReceivedCount = 
next.get("metrics").get("SourceReceivedCount");