Update seatunnel-engine/seatunnel-engine-server/src/main/java/org/apa…

…che/seatunnel/engine/server/task/SeaTunnelSourceCollector.java Co-authored-by: Jia Fan <[email protected]>
apache · Jul 23, 2024 · 1a13ddb · 1a13ddb
1 parent e3147d1
commit 1a13ddb
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...erver/src/main/java/org/apache/seatunnel/engine/server/task/SeaTunnelSourceCollector.java b/...erver/src/main/java/org/apache/seatunnel/engine/server/task/SeaTunnelSourceCollector.java
@@ -103,7 +103,7 @@ public SeaTunnelSourceCollector(
             tablePaths.forEach(
                     tablePath ->
                             sourceReceivedCountPerTable.put(
-                                    tablePath.getTableName(),
+                                    tablePath.getFullName(),
                                     metricsContext.counter(
                                             SOURCE_RECEIVED_COUNT
                                                     + "#"