可以在flink-conf.yaml里设置,例如:
env.java.opts: -Djob.name={{job_name}}xiao cai <[email protected]> 于2020年9月15日周二 下午5:46写道: > Hi: > 我修改了flink的一些源码,需要通过外部-Dkey=value的形式动态将值传入,试了下无法直接通过bin/flink run > 后加-D的方式来添加,有什么好的办法吗?
可以在flink-conf.yaml里设置,例如:
env.java.opts: -Djob.name={{job_name}}xiao cai <[email protected]> 于2020年9月15日周二 下午5:46写道: > Hi: > 我修改了flink的一些源码,需要通过外部-Dkey=value的形式动态将值传入,试了下无法直接通过bin/flink run > 后加-D的方式来添加,有什么好的办法吗?