Flink CDC中这个参数怎么传进去啊？

Flink CDC从savepoint恢复时,需要设置savepoint的路径信息。有以下几种方式设置:

直接在程序代码中设置:
java
Copy
StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();

env.getConfig().setString(SavepointConfigOptions.SAVEPOINT_PATH, "file:///savepoint/path");
通过程序参数传入:
Copy
-DExecution.savepoint.path=file:///savepoint/path
自定义配置文件设置:
properties
Copy
execution.savepoint.path=file:///savepoint/path
配置文件路径传给ExecutionConfig:

java
Copy
env.configure(config);
Flink CLI方式运行任务时传入:
Copy
flink run -s :savepointPath file:///savepoint/path ...
Flink WebUI页面导入savepoint时选择路径
所以一般来说,可通过代码配置、程序参数、自定义配置等方式设置SAVEPOINT_PATH,保证从savepoint恢复时加载正确路径。