[FLINK-38840][postgres] Postgres YAML connector supports emitting complete Table ID

Author: Mrart

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/source/utils/CustomPostgresSchema.java

@@ -125,14 +125,15 @@ private List<TableChange> readTableSchema(List<TableId> tableIds) throws SQLExce
             offsetContext.event(tableId, Instant.now());
 
             // TODO: check whether we always set isFromSnapshot = true
-            SchemaChangeEvent schemaChangeEvent = SchemaChangeEvent.ofCreate(
-                    partition,
-                    offsetContext,
-                    dbzConfig.databaseName(),
-                    tableId.schema(),
-                    tableId.table(),
-                    table,
-                    true);
+            SchemaChangeEvent schemaChangeEvent =
+                    SchemaChangeEvent.ofCreate(
+                            partition,
+                            offsetContext,
+                            dbzConfig.databaseName(),
+                            tableId.schema(),
+                            tableId.table(),
+                            table,
+                            true);
 
             for (TableChanges.TableChange tableChange : schemaChangeEvent.getTableChanges()) {
                 this.schemasByTableId.put(tableId, tableChange);