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