帶配置文件參數啟動Flink任務


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


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM