有一个使用 typesafe config 的 Flink 项目,当我尝试使用命令 flink run xxxx.jar -Dconfig=XXXX -Dus=XXXX...
在 独立集群 中运行该项目时,我发现无法正确识别 JVM 选项(这里是 config 和 us)。通常,它应该 用值 application.conf
替换 XXXX
中对应键的值。
最佳答案
用ParameterTool parameter = ParameterTool.fromSystemProperties();
访问您的 config
和 us
参数。
将您的配置值放入 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/