[Chore] Code clean

apache · Aug 25, 2024 · 5bb86f7 · 5bb86f7
1 parent c1a4e0c
commit 5bb86f7
Showing 1 changed file with 4 additions and 4 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
@@ -92,7 +92,7 @@ public static SeaTunnelEngineMetricsExtractor getInstance() {
 
     @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 List<Map<String, String>> getClusterHealthMetrics() {
             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 List<Map<String, String>> getClusterHealthMetrics() {
 
     @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 Map<Long, HashMap<Integer, JobMetrics>> getAllRunningJobMetrics() {
             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");