Apache Flink動的にJVM_OPTを設定するenv.java.opts

Question

conf/flink-conf.yamlファイルでジョブを指定せずにジョブを送信するときに、カスタムJVMオプションenv.java.optsを設定することはできますか？

私が求めているのは、私のlog4jでカスタム変数を使いたいのです。私はYARNでも仕事をしています。

私はCLIを使用して、次のコマンドを試してみましたが、それは、これが原因FLINKが動的に解析する方法には不可能である瞬間以降

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

Answer 1

=記号からすべてを取り除きプロパティ。 Flinkでは、動的プロパティの形式が-D<KEY>=<VALUE>であり、<VALUE>には=が含まれていないことが明らかに間違っています。したがって、現時点では、でenv.java.optsを指定する必要があります。

この問題を解決するためにJIRA issueを開けました。