gpt4 book ai didi

apache-flink - 从 IDE 独立运行的本地 Flink 配置

转载 作者:行者123 更新时间:2023-12-04 15:09:05 24 4
gpt4 key购买 nike

如果我想在本地直接从 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/

24 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com