Setting flink-conf params in IDE

classic Classic list List threaded Threaded
2 messages Options
Reply | Threaded
Open this post in threaded view
|

Setting flink-conf params in IDE

Alexx
Hi everyone!

Is there a way to set flink-conf.yaml params but when running from the IDE?

What I'm trying to do is to setup JMX metrics:
metrics.reporter.jmx.class: org.apache.flink.metrics.jmx.JMXReporter
metrics.reporter.jmx.port: 8789

Thanks!
Reply | Threaded
Open this post in threaded view
|

Re: Setting flink-conf params in IDE

Till Rohrmann
Hi Alexandru,

you can call `StreamExecutionEnvironment#createLocalEnvironment` which you can pass a Flink configuration object.

Cheers,
Till

On Wed, Jan 16, 2019 at 1:05 PM Alexandru Gutan <[hidden email]> wrote:
Hi everyone!

Is there a way to set flink-conf.yaml params but when running from the IDE?

What I'm trying to do is to setup JMX metrics:
metrics.reporter.jmx.class: org.apache.flink.metrics.jmx.JMXReporter
metrics.reporter.jmx.port: 8789

Thanks!