flink-user-zh mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "wchxii@163.com" <wch...@163.com>
Subject Re: 如何在启动taskmanager时传入自定义的java参数
Date Tue, 15 Sep 2020 11:18:09 GMT
官网有相关配置 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



wchxii@163.com
 
发件人: xiao cai
发送时间: 2020-09-15 17:46
收件人: user-zh
主题: 如何在启动taskmanager时传入自定义的java参数
Hi:
我修改了flink的一些源码,需要通过外部-Dkey=value的形式动态将值传入,试了下无法直接通过bin/flink
run 后加-D的方式来添加,有什么好的办法吗?
Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message