flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Cussac, Franck" <Franck.Cus...@ext.bleckwen.ai>
Subject RE: override jvm params
Date Wed, 25 Jul 2018 12:27:44 GMT
Hi Hequn,

Thanks for your answer. I just tested and it doesn’t work.

I’m using PureConfig to parse my conf files. With java I can override any argument using
–D<param>=<value> syntax. How can I do same with flink in yarn mode ?


De : Hequn Cheng [mailto:chenghequn@gmail.com]
Envoyé : mercredi 25 juillet 2018 14:04
À : Cussac, Franck <Franck.Cussac@ext.bleckwen.ai>
Cc : user <user@flink.apache.org>
Objet : Re: override jvm params

Hi Cussac,
If I understand correctly, you want to pass rules.consumer.topic=test and rules.consumer.topic=test
to flink jvm.
I think you can try:
flink run -m $HOSTPORT -yD rules.consumer.topic=test -yD rules.consumer.topic=test

Hope this helps.

On Wed, Jul 25, 2018 at 3:26 PM, Cussac, Franck <Franck.Cussac@ext.bleckwen.ai<mailto:Franck.Cussac@ext.bleckwen.ai>>

Following the documentation I want to use –yD option to override some params in my conf
like this :

flink run -m $HOSTPORT -yD "env.java.opts.taskmanager=-Drules.consumer.topic=test" -yD "env.java.opts.jobmanager=-Drules.consumer.topic=test"
myjar mymain

but it is just ignored. Nothing happend. But if I run with java on my IDE and :
in JVM’s parameter it works eprfectly.

What do I have to do to override my params with yarn and flink ?

Best regards,
Franck Cussac.

View raw message