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. Hequn On Wed, Jul 25, 2018 at 3:26 PM, Cussac, Franck < [email protected]> wrote: > 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. > > >
