有一个使用typesafe配置的flink项目，当我试图用命令在独立集群中运行该项目时 flink run x.jar -Dconfig=XXXX -Dus=XXXX... ，我发现jvm选项（这里是config和us）无法正确识别。通常，它应该替换中相应键的值 application.conf 带E值 XXXX .
flink run x.jar -Dconfig=XXXX -Dus=XXXX...
application.conf
XXXX
3htmauhk1#
使用 ParameterTool parameter = ParameterTool.fromSystemProperties(); 访问您的 config 以及 us 参数。将配置值放入参数工具：https://ci.apache.org/projects/flink/flink-docs-master/dev/best_practices.html#getting-将配置值输入参数工具
ParameterTool parameter = ParameterTool.fromSystemProperties();
config
us
1条答案
按热度按时间3htmauhk1#
使用
ParameterTool parameter = ParameterTool.fromSystemProperties();访问您的config以及us参数。将配置值放入参数工具：
https://ci.apache.org/projects/flink/flink-docs-master/dev/best_practices.html#getting-将配置值输入参数工具