Skip to content

Commit e944a06

Browse files
committed
minor: rename config name
Signed-off-by: yuxiqian <34335406+yuxiqian@users.noreply.github.com>
1 parent 9ae80c6 commit e944a06

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/src/main/java/org/apache/flink/cdc/connectors/mysql/source/MySqlDataSourceOptions.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -284,7 +284,7 @@ public class MySqlDataSourceOptions {
284284

285285
@Experimental
286286
public static final ConfigOption<Boolean> PARSE_ONLINE_SCHEMA_CHANGES =
287-
ConfigOptions.key("scan.parse.online.schema.changes")
287+
ConfigOptions.key("scan.parse.online.schema.changes.enabled")
288288
.booleanType()
289289
.defaultValue(false)
290290
.withDescription(

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/config/MySqlSourceOptions.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -265,7 +265,7 @@ public class MySqlSourceOptions {
265265

266266
@Experimental
267267
public static final ConfigOption<Boolean> PARSE_ONLINE_SCHEMA_CHANGES =
268-
ConfigOptions.key("scan.parse.online.schema.changes")
268+
ConfigOptions.key("scan.parse.online.schema.changes.enabled")
269269
.booleanType()
270270
.defaultValue(false)
271271
.withDescription(

0 commit comments

Comments
 (0)