怎么尝试使用 Flink CDC 3.0 按照官网案例同步 MySQL 数据库到 Doris？

在Flink CDC中，从savepoint启动作业的命令与常规Flink作业略有不同。对于使用flink-cdc.sh脚本启动的作业，您可以通过以下步骤从savepoint重新启动作业：

1. 首先，确保您的savepoint文件已经成功创建并保存在指定的目录中。您可以在state.savepoints.dir参数所指定的目录中找到savepoint文件。
2. 接下来，您需要将savepoint文件移动到Flink的savepoint目录中，以便Flink能够识别并加载它。假设您的Flink安装目录为/path/to/flink，则可以将savepoint文件移动到/path/to/flink/savepoints目录下。

3. 然后，您可以使用以下命令从savepoint启动作业：

   ./bin/flink run -s <savepoint_directory> -p <job_parallelism> -c <main_class> -- <job_arguments>
   

   其中，<savepoint_directory>是包含savepoint文件的目录路径，<job_parallelism>是作业的并行度，<main_class>是主类的名称，<job_arguments>是传递给主类的参数。

   例如，如果您的主类名为com.example.MyJob，并且没有额外的参数，则可以使用以下命令从savepoint启动作业：

   ./bin/flink run -s /path/to/flink/savepoints/my_job_id -p 1 -c com.example.MyJob
   

   这将从savepoint文件中恢复作业的状态，并启动作业。

请注意，上述命令中的-s选项用于指定savepoint目录，而不是savepoint文件的完整路径。Flink会自动在指定的目录中查找最新的savepoint文件。

通过按照上述步骤执行命令，您应该能够从savepoint重新启动Flink CDC作业。

在flink-conf里面手动添加下路径，3.1会把这个参数暴露出来。pipeline，目前不能动态加表，这个参数没有暴露出来。此回答来自钉群Flink CDC 社区。