[Feature][Zeta engine] Added the metrics information of table statist…

…ics in multi-table mode apache#6959
hawk9821 · Jul 15, 2024 · f971e89 · f971e89
1 parent 242cc36
commit f971e89
Show file tree

Hide file tree

Showing 3 changed files with 2 additions and 4 deletions.
diff --git a/...l-engine-client/src/test/java/org/apache/seatunnel/engine/client/SeaTunnelClientTest.java b/...l-engine-client/src/test/java/org/apache/seatunnel/engine/client/SeaTunnelClientTest.java
@@ -540,7 +540,7 @@ public void testGetMultiTableJobMetrics() {
             Assertions.assertTrue(jobMetrics.contains(SINK_WRITE_COUNT + "#fake1"));
             Assertions.assertTrue(jobMetrics.contains(SINK_WRITE_COUNT + "#fake2"));
 
-            log.info("jobMetrics : {}" , jobMetrics);
+            log.info("jobMetrics : {}", jobMetrics);
             JsonNode jobMetricsStr = new ObjectMapper().readTree(jobMetrics);
             List<String> metricNameList =
                     StreamSupport.stream(

diff --git a/...er/src/main/java/org/apache/seatunnel/engine/server/rest/RestHttpGetCommandProcessor.java b/...er/src/main/java/org/apache/seatunnel/engine/server/rest/RestHttpGetCommandProcessor.java
@@ -68,7 +68,6 @@
 import java.util.Spliterators;
 import java.util.concurrent.ExecutionException;
 import java.util.stream.Collectors;
-import java.util.stream.Collectors;
 import java.util.stream.StreamSupport;
 
 import static com.hazelcast.internal.ascii.rest.HttpStatusCode.SC_500;

diff --git a/...-server/src/main/java/org/apache/seatunnel/engine/server/task/flow/SinkFlowLifeCycle.java b/...-server/src/main/java/org/apache/seatunnel/engine/server/task/flow/SinkFlowLifeCycle.java
@@ -282,8 +282,7 @@ public void received(Record<?> record) {
                                 sinkTableCounter.inc();
                             } else {
                                 Counter counter =
-                                        metricsContext.counter(
-                                                SINK_WRITE_COUNT + "#" + tableName);
+                                        metricsContext.counter(SINK_WRITE_COUNT + "#" + tableName);
                                 counter.inc();
                                 sinkWriteCountPerTable.put(tableName, counter);
                             }