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假設動態屬性的格式爲-D<KEY>=<VALUE>，<VALUE>不包含任何=，這顯然是錯誤的。因此，目前您必須通過flink-conf.yaml指定env.java.opts。

我打開了一個JIRA issue來解決這個問題。