Re: [External] Flink 1.7.1 on EMR metrics

2019-06-01 Thread Padarn Wilson
Doh - stupid mistake. Thanks for pointing that out. On Sun, Jun 2, 2019 at 12:52 PM Bowen Li wrote: > To answer your question on your debugging code, your reporter has a bug: > > log.info("STATSD SENDING: ", name, value); > > should be -> > > log.info("STATSD SENDING: {} {}", name, value); > > >

Re: [External] Flink 1.7.1 on EMR metrics

2019-06-01 Thread Bowen Li
To answer your question on your debugging code, your reporter has a bug: log.info("STATSD SENDING: ", name, value); should be -> log.info("STATSD SENDING: {} {}", name, value); - On Sat, Jun 1, 2019 at 7:30 PM Padarn Wilson wrote: > Thanks both: Using the the inbuilt Slf4j reporter is a

Re: [External] Flink 1.7.1 on EMR metrics

2019-06-01 Thread Padarn Wilson
Thanks both: Using the the inbuilt Slf4j reporter is a great idea, I will do this. @Peter.Groesbeck - appreciate the config. This looks very similar to what I had, but if it is working for you perhaps there is something else missing from our EMR setup. Will go back and double check the connectivi