1、目的
啟動Flink任務方法的命令為 flink run flink.jar
但是有時候啟動時需要向里面傳入一些參數,比如配置文件的路徑等。
2、帶參執行命令
首先在代碼中配置:
ParameterTool parameters = ParameterTool.fromArgs(args); String local_path = parameters.get("local_path",null); //指定參數名:local_path //讀取配置文件 ParameterTool paramFromProps = ParameterTool.fromPropertiesFile(local_path);
代碼打包完成jar,在服務器啟動Flink任務時,需要添加自定義參數local_path,指定配置文件的絕對路徑。比如:
flink run flink.jar -local_path ./config.properties