参考官网
一、idea 本地运行
使用Flink官方的ParameterTool或者其他工具都可以。
二、集群运行flink run/run-application
（1）ParameterTool 获取参数
以-D开头的参数：
ParameterTool parameter = ParameterTool.fromSystemProperties();
（2）Env获取参数
举个例子使用以下方式启动flink job。
flink run application -Dstate.savepoints.dir=hdfs://mycluster/flink/flink-checkpoints/my-job ...
可通过以下代码获取：state.savepoints.dir 参数文章来源：https://www.toymoban.com/news/detail-740622.html
ExecutionEnvironment env = ExecutionEnvironment.getExecutionEnvironment();
// flink run/run-application添加参数-s 和 --fromSavepoint
String savepointRestorePath = env.getConfiguration().get(SavepointConfigOptions.SAVEPOINT_PATH);
需要说明：使用StreamExecutionEnvironment 和 StreamTableEnvironment 都无法获取参数。文章来源地址https://www.toymoban.com/news/detail-740622.html
到了这里，关于【flink】flink获取-D参数方式的文章就介绍完了。如果您还想了解更多内容，请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章，希望大家以后多多支持TOY模板网！
