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

…ics in multi-table mode #6959
apache · Jul 23, 2024 · 13e3ff1 · 13e3ff1
1 parent 6081609
commit 13e3ff1
Showing 1 changed file with 5 additions and 4 deletions.
diff --git a/...ine-server/src/main/java/org/apache/seatunnel/engine/server/task/SourceSeaTunnelTask.java b/...ine-server/src/main/java/org/apache/seatunnel/engine/server/task/SourceSeaTunnelTask.java
@@ -17,10 +17,6 @@
 
 package org.apache.seatunnel.engine.server.task;
 
-import com.hazelcast.logging.ILogger;
-import com.hazelcast.logging.Logger;
-import lombok.Getter;
-import lombok.NonNull;
 import org.apache.seatunnel.api.common.metrics.MetricsContext;
 import org.apache.seatunnel.api.serialization.Serializer;
 import org.apache.seatunnel.api.source.SourceSplit;
@@ -37,6 +33,11 @@
 import org.apache.seatunnel.engine.server.task.flow.SourceFlowLifeCycle;
 import org.apache.seatunnel.engine.server.task.record.Barrier;
 
+import com.hazelcast.logging.ILogger;
+import com.hazelcast.logging.Logger;
+import lombok.Getter;
+import lombok.NonNull;
+
 import java.util.ArrayList;
 import java.util.List;
 import java.util.Map;