From 22a177236e8b4dac7c1f6ae57b16281c6622625f Mon Sep 17 00:00:00 2001
From: liugddx <liugddx@gmail.com>
Date: Sun, 13 Oct 2024 08:46:46 +0800
Subject: [PATCH] 1

---
 .../seatunnel/engine/server/task/flow/SinkFlowLifeCycle.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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 -> {