Apache Flink Dynamische Einstellung von JVM_OPT env.java.opts

Question

Ist es möglich, die benutzerdefinierten JVM-Optionen env.java.opts beim Übermitteln eines Auftrags ohne Angabe in der Datei conf/flink-conf.yaml festzulegen?

Der Grund, warum ich frage, ist, ich möchte einige benutzerdefinierte Variablen in meinem log4j verwenden. Ich führe auch meinen Job bei YARN.

Ich habe versucht, den folgenden Befehl den CLI verwenden und es Streifen alles weg vom = Zeichen ab

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

Answer 1

Im Moment dies aufgrund der Art und Weise nicht möglich ist Flink analysiert die dynamische Eigenschaften. Flink geht davon aus, dass dynamische Eigenschaften die Form -D<KEY>=<VALUE> haben und dass <VALUE> keine = enthält, was eindeutig falsch ist. Daher müssen Sie im Moment den env.java.opts über flink-conf.yaml angeben.

Ich habe eine JIRA issue geöffnet, um dieses Problem zu beheben.