在Flink中,使用flink-conf.yaml文件配置全局參數,在Job運行時可以通過ParameterTool類動態配置參數。動態配置參數的步驟如下:
my.parameter: default_value
ParameterTool params = ParameterTool.fromArgs(args);
String myParameter = params.get("my.parameter", "default_value");
flink run -Dmy.parameter=new_value YourFlinkJob.jar
這樣就可以動態設置參數值,而不需要修改代碼并重新打包程序。