From 235343333bbd0cf68eeea557290b183a8ed0e9b0 Mon Sep 17 00:00:00 2001 From: "zhangchaoming.zcm" Date: Fri, 3 Jan 2025 16:08:10 +0800 Subject: [PATCH] [hotfix] Add missing enumeration --- .../cdc/connectors/mysql/source/MySqlDataSourceOptions.java | 4 ++-- 1 file changed, 2 insertions(+), 2 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/source/MySqlDataSourceOptions.java b/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/src/main/java/org/apache/flink/cdc/connectors/mysql/source/MySqlDataSourceOptions.java index f37703f6941..b2284ed1c30 100644 --- a/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/src/main/java/org/apache/flink/cdc/connectors/mysql/source/MySqlDataSourceOptions.java +++ b/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/src/main/java/org/apache/flink/cdc/connectors/mysql/source/MySqlDataSourceOptions.java @@ -126,8 +126,8 @@ public class MySqlDataSourceOptions { .defaultValue("initial") .withDescription( "Optional startup mode for MySQL CDC consumer, valid enumerations are " - + "\"initial\", \"earliest-offset\", \"latest-offset\", \"timestamp\"\n" - + "or \"specific-offset\""); + + "\"initial\", \"earliest-offset\", \"latest-offset\", \"timestamp\", " + + "\"specific-offset\" or \"snapshot\"."); public static final ConfigOption SCAN_STARTUP_SPECIFIC_OFFSET_FILE = ConfigOptions.key("scan.startup.specific-offset.file")