(flink-cdc) branch master updated: [FLINK-39916][mysql] Fix MySQL batch startup option validation error (#4441)

[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 6914d7028 [FLINK-39916][mysql] Fix MySQL batch startup option 
validation error (#4441)
6914d7028 is described below

commit 6914d70283d43028676b6116413aaf360dc9214a
Author: yueqingshu <llphx...@gmail.com>
AuthorDate: Fri Jul 3 19:17:31 2026 +0800

    [FLINK-39916][mysql] Fix MySQL batch startup option validation error (#4441)
    
    Signed-off-by: huanxiaodong <llphx...@gmail.com>
---
 .../flink/cdc/connectors/mysql/factory/MySqlDataSourceFactory.java    | 4 +---
 1 file changed, 1 insertion(+), 3 deletions(-)

diff --git 
a/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/src/main/java/org/apache/flink/cdc/connectors/mysql/factory/MySqlDataSourceFactory.java
 
b/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/src/main/java/org/apache/flink/cdc/connectors/mysql/factory/MySqlDataSourceFactory.java
index 1b3540da0..1b9cea561 100644
--- 
a/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/src/main/java/org/apache/flink/cdc/connectors/mysql/factory/MySqlDataSourceFactory.java
+++ 
b/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/src/main/java/org/apache/flink/cdc/connectors/mysql/factory/MySqlDataSourceFactory.java
@@ -139,7 +139,7 @@ public class MySqlDataSourceFactory implements 
DataSourceFactory {
                 && !StartupOptions.snapshot().equals(startupOptions)) {
             throw new IllegalArgumentException(
                     String.format(
-                            "Only \"snapshot\" of MySQLDataSource 
StartupOption is supported in BATCH pipeline, but actual MySQLDataSource 
StartupOption is {}.",
+                            "Only \"snapshot\" of MySQLDataSource 
StartupOption is supported in BATCH pipeline, but actual MySQLDataSource 
StartupOption is %s.",
                             startupOptions.startupMode));
         }
         boolean includeSchemaChanges = config.get(SCHEMA_CHANGE_ENABLED);
@@ -513,8 +513,6 @@ public class MySqlDataSourceFactory implements 
DataSourceFactory {
                         distributionFactorLower));
     }
 
-    private static final String DOT_PLACEHOLDER = "_$dot_placeholder$_";
-
     /** Replaces the default timezone placeholder with session timezone, if 
applicable. */
     private static ZoneId getServerTimeZone(Configuration config) {
         final String serverTimeZone = config.get(SERVER_TIME_ZONE);