问题描述
如果我想直接在Intellij内部运行Flink应用程序，但是我需要指定配置参数(如fs.hdfs.hdfssite来设置S3访问权限)，是否有其他方法可以提供这些配置参数除了ExecutionEnvironment.createLocalEnvironment(conf)?如果我想使用StreamExecutionEnvironment.getExecutionEnvironment怎么办?我可以在项目中有Flink配置并将本地应用程序指向它吗?
If I'd like to run a Flink app locally, directly from within Intellij but I need to specify config params (like fs.hdfs.hdfssite to set up S3 access), is there any other way to provide those config params apart from ExecutionEnvironment.createLocalEnvironment(conf)? What if I want to use StreamExecutionEnvironment.getExecutionEnvironment? Can I have a Flink config in my project and point the local app to it?
这是正确的方法吗?还是您将设置IDE将应用程序提交到真正的本地Flink实例?
Is this the proper way to do it? Or would you set up your IDE to submit the app to a real local Flink instance?
推荐答案
要使用配置选项创建StreamExecutionEnvironment，请使用此调用StreamExecutionEnvironment.createLocalEnvironment(int parallelism, Configuration configuration)
To create a StreamExecutionEnvironment with configuration options, use this call StreamExecutionEnvironment.createLocalEnvironment(int parallelism, Configuration configuration)
这篇关于从IDE独立运行的本地Flink配置的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持！