如果我想在本地运行一个应用程序弗林克,从内部的IntelliJ直接,但我需要指定配置PARAMS(如fs.hdfs.hdfssite成立S3访问),还有没有其他的办法从提供这些配置PARAMS分开ExecutionEnvironment.createLocalEnvironment(conf)？如果我想使用StreamExecutionEnvironment.getExecutionEnvironment怎么办？我可以在项目中使用Flink配置并将本地应用程序指向它吗？
这是正确的方法吗？或者您是否会设置IDE以将应用程序提交给真正的本地Flink实例？
要创建StreamExecutionEnvironment带有配置选项的文件，请使用此调用StreamExecutionEnvironment.createLocalEnvironment(int parallelism, Configuration configuration)
| 归档时间： |
|
| 查看次数： |
1363 次 |
| 最近记录： |