(flink-cdc) branch master updated: [FLINK-39934][postgres] Fix invalid tables format error message (#4442)

[kunni]

This is an automated email from the ASF dual-hosted git repository.

lvyanquan pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink-cdc.git


The following commit(s) were added to refs/heads/master by this push:
     new 279278af6 [FLINK-39934][postgres] Fix invalid tables format error 
message (#4442)
279278af6 is described below

commit 279278af664ce025de4c084e52b673405dbe9df0
Author: Ran Tao <chucheng...@gmail.com>
AuthorDate: Mon Jul 6 14:17:59 2026 +0800

    [FLINK-39934][postgres] Fix invalid tables format error message (#4442)
---
 .../cdc/connectors/postgres/factory/PostgresDataSourceFactory.java      | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-postgres/src/main/java/org/apache/flink/cdc/connectors/postgres/factory/PostgresDataSourceFactory.java
 
b/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-postgres/src/main/java/org/apache/flink/cdc/connectors/postgres/factory/PostgresDataSourceFactory.java
index 93d8657cf..bb6332f01 100644
--- 
a/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-postgres/src/main/java/org/apache/flink/cdc/connectors/postgres/factory/PostgresDataSourceFactory.java
+++ 
b/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-postgres/src/main/java/org/apache/flink/cdc/connectors/postgres/factory/PostgresDataSourceFactory.java
@@ -383,7 +383,7 @@ public class PostgresDataSourceFactory implements 
DataSourceFactory {
                     tableNameParts.length == 3,
                     String.format(
                             "Tables format must db.schema.table, can not 
'tables' = %s",
-                            TABLES.key()));
+                            trimmedTableName));
             String currentDbName = tableNameParts[0];
 
             checkState(