Flink无法收到Typesafe-Config JVM选项



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

使用

ParameterTool parameter = ParameterTool.fromSystemProperties();

访问您的configus参数。

将您的配置值纳入参数:

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

相关内容

  • 没有找到相关文章

最新更新