diff --git a/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/task/flow/SinkFlowLifeCycle.java b/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/task/flow/SinkFlowLifeCycle.java
index a38373c1ac9..59034670237 100644
--- a/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/task/flow/SinkFlowLifeCycle.java
+++ b/seatunnel-engine/seatunnel-engine-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 -> {