fix npe

apache · Jan 20, 2025 · fc68bf7 · fc68bf7
1 parent ffd94d9
commit fc68bf7
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/...nnectors/seatunnel/cdc/postgres/source/reader/snapshot/PostgresSnapshotSplitReadTask.java b/...nnectors/seatunnel/cdc/postgres/source/reader/snapshot/PostgresSnapshotSplitReadTask.java
@@ -166,8 +166,9 @@ private void createDataEvents(PostgresSnapshotContext snapshotContext, TableId t
         EventDispatcher.SnapshotReceiver snapshotReceiver =
                 dispatcher.getSnapshotChangeEventReceiver();
         log.debug("Snapshotting table {}", tableId);
+        TableId newTableId = new TableId(tableId.catalog(), tableId.schema(), tableId.table());
         createDataEventsForTable(
-                snapshotContext, snapshotReceiver, databaseSchema.tableFor(tableId));
+                snapshotContext, snapshotReceiver, databaseSchema.tableFor(newTableId));
         snapshotReceiver.completeSnapshot();
     }