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 · e3147d1 · e3147d1
1 parent 8d60b83
commit e3147d1
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
@@ -107,7 +107,7 @@ public SeaTunnelSourceCollector(
                                     metricsContext.counter(
                                             SOURCE_RECEIVED_COUNT
                                                     + "#"
-                                                    + tablePath.getTableName())));
+                                                    + tablePath.getFullName())));
         }
         sourceReceivedCount = metricsContext.counter(SOURCE_RECEIVED_COUNT);
         sourceReceivedQPS = metricsContext.meter(SOURCE_RECEIVED_QPS);