apache-flink - Apache Flink 动态设置JVM_OPT env.java.opts

Question

是否可以设置自定义 JVM 选项 env.java.opts在提交作业时未在 conf/flink-conf.yaml 中指定它时文件？

我问的原因是我想在我的 log4j 中使用一些自定义变量。我也在 YARN 上运行我的工作。

我使用 CLI 尝试了以下命令，它从 = 中删除了所有内容以后签字

$ flink run -m yarn-cluster -yn 2 -yst -yD env.java.opts="-DappName=myapp -DcId=mycId"

Answer 1

由于 Flink 解析动态属性的方式，目前这是不可能的。 Flink 假设动态属性的形式为 -D<KEY>=<VALUE>还有那个<VALUE>不包含任何 =这显然是错误的。因此，目前您必须指定 env.java.opts通过 flink-conf.yaml .

我开了一个 JIRA issue来解决这个问题。

更新

Flink >= 1.3.0 和 >= 1.2.2 已修复该问题。