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