從IDE獨立運行的本地Flink配置

如果我想直接從Intellij內部運行Flink應用程序，但我需要指定config params（如fs.hdfs.hdfssite設置S3訪問），是否有任何其他方式提供這些配置參數ExecutionEnvironment.createLocalEnvironment(conf)除？如果我想用StreamExecutionEnvironment.getExecutionEnvironment怎麼辦？我可以在我的項目中使用Flink配置並將本地應用指向它嗎？從IDE獨立運行的本地Flink配置

這是正確的方法嗎？或者，您是否將您的IDE設置爲將應用程序提交給本地Flink實例？

來源

2016-06-10 bibac

要創建具有配置選項的StreamExecutionEnvironment，使用此電話StreamExecutionEnvironment.createLocalEnvironment(int parallelism, Configuration configuration)

來源

2017-02-09 13:28:43

您可以使用StreamExecutionEnvironment.getExecutionEnvironment() - 它會計算出當前設置，如果在IDE中執行將返回「LocalEnvironemnt」。

因此，應該能夠使用conf/flink-conf.yaml來設置您的配置值。

來源

2016-06-10 09:36:33

所以我可以把一個弗林克-conf.yaml在我的項目/ src目錄/主/資源/ conf目錄和執行環境會找到它？ – bibac

不知道......我猜conf/flink-conf.yaml應該在你的IDE工作目錄中。 –

@bibac @ matthias-j-sax你能告訴我在IDEA中運行Flink作業時應該把conf/flink-conf.yaml放在哪裏嗎？ – Grzes

從IDE獨立運行的本地Flink配置

回答

相關問題