如何在启动taskmanager时传入自定义的java参数

[xiao cai]

Hi：
我修改了flink的一些源码，需要通过外部-Dkey=value的形式动态将值传入，试了下无法直接通过bin/flink run 后加-D的方式来添加，有什么好的办法吗？

[zilong xiao]

可以在flink-conf.yaml里设置，例如：
env.java.opts: -Djob.name={{job_name}}

xiao cai <[hidden email]> 于2020年9月15日周二 下午5:46写道：

> Hi：
> 我修改了flink的一些源码，需要通过外部-Dkey=value的形式动态将值传入，试了下无法直接通过bin/flink run
> 后加-D的方式来添加，有什么好的办法吗？

[xiao cai]

解决了我的问题，非常感谢。


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


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

[阿西]

官网有相关配置 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



[hidden email]
 
发件人： xiao cai
发送时间： 2020-09-15 17:46
收件人： user-zh
主题： 如何在启动taskmanager时传入自定义的java参数
Hi：
我修改了flink的一些源码，需要通过外部-Dkey=value的形式动态将值传入，试了下无法直接通过bin/flink run 后加-D的方式来添加，有什么好的办法吗？

[xiao cai]

学习了，非常感谢~


 原始邮件
发件人: [hidden email]<[hidden email]>
收件人: [hidden email]<[hidden email]>
发送时间: 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 [hidden email] 发件人： xiao cai 发送时间： 2020-09-15 17:46 收件人： user-zh 主题： 如何在启动taskmanager时传入自定义的java参数 Hi： 我修改了flink的一些源码，需要通过外部-Dkey=value的形式动态将值传入，试了下无法直接通过bin/flink run 后加-D的方式来添加，有什么好的办法吗？