不能在flink中接收Typesafe-Config jvm选项

Question

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

Answer 1

使用

ParameterTool parameter = ParameterTool.fromSystemProperties();

若要访问config和us参数，请执行以下操作。

将配置值输入ParameterTool：

practices.html#getting-your-configuration-values-into-the-parametertool