在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
这样就可以动态设置参数值,而不需要修改代码并重新打包程序。