(flink-cdc) branch master updated: [minor] Fix incorrect log when malformed scan.startup.mode (#4234)

[kunni]

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

kunni 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 b9da3e45b [minor] Fix incorrect log when malformed scan.startup.mode 
(#4234)
b9da3e45b is described below

commit b9da3e45b7ecc28a1b6e642dd4a644b36a478fc7
Author: Mukhutdinov Artur <arturmuxutdi...@gmail.com>
AuthorDate: Mon Jan 26 09:38:10 2026 +0300

    [minor] Fix incorrect log when malformed scan.startup.mode (#4234)
---
 .../cdc/connectors/postgres/factory/PostgresDataSourceFactory.java     | 3 ++-
 1 file changed, 2 insertions(+), 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 5e6c446c5..f8d249c4d 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
@@ -310,11 +310,12 @@ public class PostgresDataSourceFactory implements 
DataSourceFactory {
             default:
                 throw new ValidationException(
                         String.format(
-                                "Invalid value for option '%s'. Supported 
values are [%s, %s, %s], but was: %s",
+                                "Invalid value for option '%s'. Supported 
values are [%s, %s, %s, %s], but was: %s",
                                 SourceOptions.SCAN_STARTUP_MODE.key(),
                                 SCAN_STARTUP_MODE_VALUE_INITIAL,
                                 SCAN_STARTUP_MODE_VALUE_SNAPSHOT,
                                 SCAN_STARTUP_MODE_VALUE_LATEST,
+                                SCAN_STARTUP_MODE_VALUE_COMMITTED_OFFSET,
                                 modeString));
         }
     }