如果我想在本地直接从 Intellij 中运行 Flink 应用程序，但我需要指定配置参数(如 fs.hdfs.hdfssite 来设置 S3 访问)，除了 ExecutionEnvironment.createLocalEnvironment(conf) 之外，还有其他方法可以提供这些配置参数吗？ ?如果我想使用 StreamExecutionEnvironment.getExecutionEnvironment 怎么办？我可以在我的项目中有一个 Flink 配置并将本地应用程序指向它吗？
这是正确的方法吗？或者你会设置你的 IDE 来将应用程序提交给一个真正的本地 Flink 实例吗？
最佳答案
创建一个 StreamExecutionEnvironment使用配置选项，使用此调用 StreamExecutionEnvironment.createLocalEnvironment(int parallelism, Configuration configuration)
关于apache-flink - 从 IDE 独立运行的本地 Flink 配置，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/37743194/