You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ku...@apache.org on 2026/07/03 11:17:36 UTC
(flink-cdc) branch master updated: [FLINK-39916][mysql] Fix MySQL batch startup option validation error (#4441)
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 <ll...@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 <ll...@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);