学习了,非常感谢~

 原始邮件 
发件人: [email protected]<[email protected]>
收件人: [email protected]<[email protected]>
发送时间: 2020年9月15日(周二) 19:18
主题: Re: 如何在启动taskmanager时传入自定义的java参数


官网有相关配置 
https://ci.apache.org/projects/flink/flink-docs-stable/ops/config.html#jvm-and-logging-options
 taskmanager自定义参数应该是使用 env.java.opts.taskmanager 下面是我的部分启动启动参数: 
/data1/flink-1.10.0/bin/flink run -m yarn-cluster -ynm smartStareJob -yjm 2048 
-ytm 4096 -ys 2 -p 6 \ -yD 
env.java.opts="-Dxdiamond.server.host=daily.inzwc.com 
-Dxdiamond.project.profile=daily" \ -yD zookeeper.sasl.disable=true \ -yD 
taskmanager.exit-on-fatal-akka-erro=ture \ -yD 
taskmanager.network.netty.client.numThreads=2 \ -yD 
taskmanager.network.netty.server.numThreads=2 \ -c 
com.hstong.fintech.cep.main.SmartStareJob /data0/www/quant-cep.jar \ --profile 
daily --channalName smartStareChannal [email protected] 发件人: xiao cai 发送时间: 
2020-09-15 17:46 收件人: user-zh 主题: 如何在启动taskmanager时传入自定义的java参数 Hi: 
我修改了flink的一些源码,需要通过外部-Dkey=value的形式动态将值传入,试了下无法直接通过bin/flink run 
后加-D的方式来添加,有什么好的办法吗?

回复