Flink -如何将JVM选项传递给CLI

Question

我想在我的工作中添加一个JVM选项。因此，我在flink- line . the中添加了以下一行：

env.java.opts: "-Dspring.config.location=/root/application.properties"

当我使用命令./start-local.sh启动flink时，jobmanager和taskmanager很好地加载了JVM选项：

• JobManager日志：

​

org.apache.flink.runtime.jobmanager.JobManager                -  JVM Options:
org.apache.flink.runtime.jobmanager.JobManager                -     -Xms2048m
org.apache.flink.runtime.jobmanager.JobManager                -     -Xmx2048m
org.apache.flink.runtime.jobmanager.JobManager                -     -Dspring.config.location=/root/application.properties
org.apache.flink.runtime.jobmanager.JobManager                -     -Dlog.file=/sicdbgagrv2/flink-1.4.0/log/flink-root-jobmanager-1-sic-dbg-agrv2.log
org.apache.flink.runtime.jobmanager.JobManager                -     -Dlog4j.configuration=file:/sicdbgagrv2/flink-1.4.0/conf/log4j.properties
org.apache.flink.runtime.jobmanager.JobManager                -     -Dlogback.configurationFile=file:/sicdbgagrv2/flink-1.4.0/conf/logback.xml

​

• JobManager日志：

​

org.apache.flink.runtime.taskmanager.TaskManager              -  JVM Options:
org.apache.flink.runtime.taskmanager.TaskManager              -     -Xms1024M
org.apache.flink.runtime.taskmanager.TaskManager              -     -Xmx1024M
org.apache.flink.runtime.taskmanager.TaskManager              -     -XX:MaxDirectMemorySize=8388607T
org.apache.flink.runtime.taskmanager.TaskManager              -     -Dspring.config.location=/root/application.properties
org.apache.flink.runtime.taskmanager.TaskManager              -     -Dlog.file=/sicdbgagrv2/flink-1.4.0/log/flink-root-taskmanager-0-sic-dbg-agrv2.log
org.apache.flink.runtime.taskmanager.TaskManager              -     -Dlog4j.configuration=file:/sicdbgagrv2/flink-1.4.0/conf/log4j.properties
org.apache.flink.runtime.taskmanager.TaskManager              -     -Dlogback.configurationFile=file:/sicdbgagrv2/flink-1.4.0/conf/logback.xml

但在CLI日志中，-Dspring.config.location=/root/application.properties没有出现.

org.apache.flink.client.CliFrontend                           -  JVM Options:
org.apache.flink.client.CliFrontend                           -     -Dlog.file=/sicdbgagrv2/flink-1.4.0/log/flink-root-client-sic-dbg-agrv2.log
org.apache.flink.client.CliFrontend                           -     -Dlog4j.configuration=file:/sicdbgagrv2/flink-1.4.0/conf/log4j-cli.properties
org.apache.flink.client.CliFrontend                           -     -Dlogback.configurationFile=file:/sicdbgagrv2/flink-1.4.0/conf/logback.xml

在启动flink运算符(MapFunction、FilterFunction、.)之前，我的工作需要阅读JVM选项。

如何添加JVM选项以使其出现在CLI日志中？

Answer 1

最后，我理解为什么JVM选项没有出现在CLI日志中:因为我不以纱线集群模式运行Flink (而是在独立集群中)。

所以我的做法不同:我使用了一个环境变量。