optimize code

apache · Jan 17, 2025 · 7c54426 · 7c54426
1 parent f9c3736
commit 7c54426
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/seatunnel-api/src/main/java/org/apache/seatunnel/api/sink/multitablesink/MultiTableSink.java b/seatunnel-api/src/main/java/org/apache/seatunnel/api/sink/multitablesink/MultiTableSink.java
@@ -135,21 +135,21 @@ public SinkWriter<SeaTunnelRow, MultiTableCommitInfo, MultiTableState> restoreWr
                 } else {
                     if (state.isEmpty()) {
                         writers.put(
-                                SinkIdentifier.of(tableIdentifier, index),
+                                SinkIdentifier.of(tablePath.toString(), index),
                                 new MultiTableTtlWriter(
                                         writers,
-                                        tableIdentifier,
+                                        tablePath.toString(),
                                         index,
                                         replicaNum,
                                         sink,
                                         context,
                                         multiTableWriterTtl));
                     } else {
                         writers.put(
-                                SinkIdentifier.of(tableIdentifier, index),
+                                SinkIdentifier.of(tablePath.toString(), index),
                                 new MultiTableTtlWriter(
                                         writers,
-                                        tableIdentifier,
+                                        tablePath.toString(),
                                         index,
                                         replicaNum,
                                         sink,