Hi,

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 :
-Drules.consumer.topic=test
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.

Reply via email to