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 · 6c10171 · 6c10171
1 parent 1a13ddb
commit 6c10171
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
@@ -135,7 +135,7 @@ public void collect(T row) {
                 flowControlGate.audit((SeaTunnelRow) row);
                 if (StringUtils.isNotEmpty(tableId)) {
                     String tableName =
-                            Optional.of(TablePath.of(tableId).getTableName()).orElse("null");
+                            Optional.of(TablePath.of(tableId).getFullName()).orElse("null");
                     Counter sourceTableCounter = sourceReceivedCountPerTable.get(tableName);
                     if (Objects.nonNull(sourceTableCounter)) {
                         sourceTableCounter.inc();