Hi,
I'm working with Flink 1.5.0 and I try to run a job from a savepoint. My
jobmanager is dockerized and I try to run my flink job in another container.
The command :
flink run -m jobmanager:8081 myJar.jar
works fine, but when I try to run a job from a savepoint, I got an Internal
server error
juillet 2018 14:04
À : Cussac, Franck
Cc : user
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
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 ha
