Skip to content

Commit 98f9f15

Browse files
[hotfix][docs] Add missed enumeration in MySQL Source
This closes #3832
1 parent baba9c6 commit 98f9f15

File tree

1 file changed

+2
-2
lines changed

1 file 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: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -126,8 +126,8 @@ public class MySqlDataSourceOptions {
126126
.defaultValue("initial")
127127
.withDescription(
128128
"Optional startup mode for MySQL CDC consumer, valid enumerations are "
129-
+ "\"initial\", \"earliest-offset\", \"latest-offset\", \"timestamp\"\n"
130-
+ "or \"specific-offset\"");
129+
+ "\"initial\", \"earliest-offset\", \"latest-offset\", \"timestamp\", "
130+
+ "\"specific-offset\" or \"snapshot\".");
131131

132132
public static final ConfigOption<String> SCAN_STARTUP_SPECIFIC_OFFSET_FILE =
133133
ConfigOptions.key("scan.startup.specific-offset.file")

0 commit comments

Comments
 (0)