Apache Flink 동적으로 JVM_OPT를 설정 env.java.opts

Question

conf/flink-conf.yaml 파일에 지정하지 않고 작업을 제출할 때 사용자 정의 JVM 옵션 env.java.opts을 설정할 수 있습니까?

내가 묻는 이유는 내 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>에는 =이 분명히 잘못되었다고 가정합니다. 따라서 잠시 동안 flink-conf.yaml을 통해 env.java.opts을 지정해야합니다.

이 문제를 해결하기 위해 JIRA issue을 열었습니다.