1

liugddx · Oct 13, 2024 · 22a1772 · 22a1772
1 parent dcb7b88
commit 22a1772
Showing 1 changed file with 1 addition and 1 deletion.
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
@@ -276,7 +276,7 @@ public void received(Record<?> record) {
                 if (record.getData() instanceof SeaTunnelRow) {
                     if (this.sinkAction.getSink() instanceof MultiTableSink) {
                         if (((SeaTunnelRow) record.getData()).getTableId().isEmpty()) {
-                            tableId.set(TablePath.DEFAULT.getFullName());
+                            tableId.set(((SeaTunnelRow) record.getData()).getTableId());
                         } else {
                             tablesMaps.forEach(
                                     tablePathTablePathMap -> {