有一个使用 typesafe config 的 Flink 项目,当我尝试使用命令 flink run xxxx.jar -Dconfig=XXXX -Dus=XXXX... 独立集群 中运行该项目时,我发现无法正确识别 JVM 选项(这里是 config 和 us)。通常,它应该 用值 application.conf 替换 XXXX 中对应键的值。

最佳答案


ParameterTool parameter = ParameterTool.fromSystemProperties();
访问您的 configus 参数。

将您的配置值放入 ParameterTool:

https://ci.apache.org/projects/flink/flink-docs-master/dev/best_practices.html#getting-your-configuration-values-into-the-parametertool

关于apache-flink - 在 flink 中无法接收 Typesafe-Config jvm 选项,我们在Stack Overflow上找到一个类似的问题:https://stackoverflow.com/questions/49488297/

10-16 05:21